Skip to content

Commit 4b8b266

Browse files
reduce diff
1 parent 578a2f1 commit 4b8b266

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -93,12 +93,10 @@ private Table initSourceTable() {
9393
namespace == null
9494
? TableIdentifier.of(tableName)
9595
: TableIdentifier.of(Namespace.of(namespace), tableName);
96-
Table table = tableManager.getTable(
96+
return tableManager.getTable(
9797
(IcebergCatalogConfig) sourceTableConfig.getCatalogConfig(),
9898
tableIdentifier,
9999
sourceTableConfig.getBasePath());
100-
101-
return table;
102100
}
103101

104102
private FileIO initTableOps() {

0 commit comments

Comments
 (0)