[hotfix] Minor fix compile in FlinkSink

zhu3pang · Nov 22, 2023 · 351e103 · 351e103
1 parent 6e1b9d8
commit 351e103
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java
@@ -171,7 +171,7 @@ public SingleOutputStreamOperator<Committable> doWrite(
         Options options = Options.fromMap(table.options());
         if (options.get(SINK_USE_MANAGED_MEMORY)) {
             MemorySize memorySize = options.get(SINK_MANAGED_WRITER_BUFFER_MEMORY);
-            written.getTransformation().declareManagedMemoryUseCaseAtSlotScope()
+            written.getTransformation()
                     .declareManagedMemoryUseCaseAtOperatorScope(
                             ManagedMemoryUseCase.OPERATOR, memorySize.getMebiBytes());
         }