removed validator class for now

Blazer-007 · Sep 24, 2024 · d8356e1 · d8356e1
1 parent 24b4823
commit d8356e1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 427 deletions.
diff --git a/...n/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionDatasetFinder.java b/...n/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionDatasetFinder.java
@@ -24,7 +24,6 @@
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.hadoop.fs.FileSystem;
-import org.apache.iceberg.TableMetadata;
 
 import com.google.common.base.Preconditions;
 
@@ -88,9 +87,10 @@ protected IcebergDataset createIcebergDataset(IcebergCatalog sourceIcebergCatalo
     IcebergTable destIcebergTable = destinationIcebergCatalog.openTable(destDbName, destTableName);
     Preconditions.checkArgument(destinationIcebergCatalog.tableAlreadyExists(destIcebergTable),
         String.format("Missing Destination Iceberg Table: {%s}.{%s}", destDbName, destTableName));
-    TableMetadata srcTableMetadata = srcIcebergTable.accessTableMetadata();
-    TableMetadata destTableMetadata = destIcebergTable.accessTableMetadata();
-    IcebergTableMetadataValidator.validateSourceAndDestinationTablesMetadata(srcTableMetadata, destTableMetadata);
+//    TODO: Add Validator for source and destination tables later
+//    TableMetadata srcTableMetadata = srcIcebergTable.accessTableMetadata();
+//    TableMetadata destTableMetadata = destIcebergTable.accessTableMetadata();
+//    IcebergTableMetadataValidator.validateSourceAndDestinationTablesMetadata(srcTableMetadata, destTableMetadata);
     return new IcebergPartitionDataset(srcIcebergTable, destIcebergTable, properties, fs, getConfigShouldCopyMetadataPath(properties));
   }
 }
diff --git a/...n/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTableMetadataValidator.java b/...n/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTableMetadataValidator.java