Skip to content

Commit d8d7dad

Browse files
committed
Cleanup
1 parent 2fc804a commit d8d7dad

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

services/tables/src/main/java/com/linkedin/openhouse/tables/repository/impl/OpenHouseInternalRepositoryImpl.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -440,10 +440,8 @@ private boolean doUpdateSchemaIfNeeded(
440440
if (!writeSchema.sameSchema(tableSchema)) {
441441
try {
442442
schemaValidator.validateWriteSchema(tableSchema, writeSchema, tableDto.getTableUri());
443-
log.info("Intermediate schemas: " + tableDto.getIntermediateSchemas());
444443
doSetIntermediateSchemasIfNeeded(updateProperties, tableDto);
445444
updateProperties.set(CatalogConstants.EVOLVED_SCHEMA_KEY, SchemaParser.toJson(writeSchema));
446-
// Also set intermediate schemas if provided
447445
return true;
448446
} catch (Exception e) {
449447
// TODO: Make upstream change to have explicit SchemaEvolutionFailureException

services/tables/src/main/java/com/linkedin/openhouse/tables/services/TablesServiceImpl.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import java.util.List;
3030
import java.util.Map;
3131
import java.util.Optional;
32-
import lombok.extern.slf4j.Slf4j;
3332
import org.apache.iceberg.exceptions.BadRequestException;
3433
import org.apache.iceberg.exceptions.CommitFailedException;
3534
import org.apache.iceberg.exceptions.CommitStateUnknownException;
@@ -40,7 +39,6 @@
4039
import org.springframework.stereotype.Component;
4140

4241
/** Default Table Service Implementation for /tables REST endpoint. */
43-
@Slf4j
4442
@Component
4543
public class TablesServiceImpl implements TablesService {
4644

@@ -97,6 +95,7 @@ public Pair<TableDto, Boolean> putTable(
9795
Optional<TableDto> tableDto =
9896
openHouseInternalRepository.findById(
9997
TableDtoPrimaryKey.builder().databaseId(databaseId).tableId(tableId).build());
98+
10099
// Special case handling
101100
if (tableDto.isPresent()) {
102101
if (failOnExist) {

0 commit comments

Comments
 (0)