Skip to content

Commit

Permalink
small_fixes_after_debugging. (#304)
Browse files Browse the repository at this point in the history
* Fixing logging
* removing shutdown (always throws an exception) and fix log
  • Loading branch information
Patrick Duin authored Nov 30, 2023
1 parent cebb3a9 commit 6709593
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 12 deletions.
5 changes: 5 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,9 @@

## [3.11.7] - 2023-11-30
### Changed
- Fixed log statement that was not logging the exception correctly.
- Removed client.shutdown() call, this always throws an exception and the code ends up closing the transport directly.

## [3.11.6] - 2023-10-24
### Fixed
- Switch to ExecutorService instead of the default `ForkJoinPool` for `MetastoreMappingImpl.isAvailable()` calls. Using `ForkJoinPool` may cause threads to wait on each other.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -246,15 +246,6 @@ public void close() {
return;
}
isConnected = false;
try {
if (client != null) {
client.shutdown();
}
} catch (TException e) {
LOG.debug("Unable to shutdown metastore client. Will try closing transport directly.", e);
}
// Transport would have got closed via client.shutdown(), so we don't need this, but
// just in case, we make this call.
if ((transport != null) && transport.isOpen()) {
transport.close();
transport = null;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,8 @@ public Object invoke(Object proxy, Method method, Object[] args) throws Throwabl
} catch (Throwable t) {
log
.warn(
"Unable to invoke compatibility for metastore client method {}. Will rethrow original exception, logging exception from invocation handler",
method.getName(), t);
"Unable to invoke compatibility for metastore client method "+method.getName()+". Will rethrow original exception, logging exception from invocation handler",
t);
}
throw delegateException.getCause();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1371,7 +1371,7 @@ public void alter_partitions_with_environment_context(
mapping
.getClient()
.alter_partitions_with_environment_context(mapping.transformInboundDatabaseName(db_name), tbl_name,
mapping.transformInboundPartitions(new_parts), environment_context);
mapping.transformInboundPartitions(new_parts), environment_context);
}

@Override
Expand Down

0 comments on commit 6709593

Please sign in to comment.