Revert "feat：support file cache mode"

This reverts commit 1080a59
apache · May 30, 2024 · 114bb8b · 114bb8b
1 parent 1b41169
commit 114bb8b
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/...in/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java b/...in/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java
@@ -36,10 +36,8 @@
 import org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeOptions;
 import org.apache.flink.cdc.connectors.maxcompute.utils.MaxComputeUtils;
 import org.apache.flink.cdc.connectors.maxcompute.utils.TypeConvertUtils;
-import org.apache.flink.cdc.connectors.maxcompute.utils.cache.UnifiedFileWriter;
 import org.apache.flink.cdc.runtime.operators.schema.event.CoordinationResponseUtils;
 import org.apache.flink.cdc.runtime.operators.sink.SchemaEvolutionClient;
-import org.apache.flink.cdc.runtime.serializer.event.DataChangeEventSerializer;
 import org.apache.flink.runtime.jobgraph.OperatorID;
 import org.apache.flink.runtime.jobgraph.tasks.TaskOperatorEventGateway;
 import org.apache.flink.runtime.operators.coordination.CoordinationRequest;