(incubator-paimon) branch master updated: [hotfix] Minor fix compile in FlinkSink

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 351e10338 [hotfix] Minor fix compile in FlinkSink
351e10338 is described below

commit 351e10338f837a646f3514dca150cae933c4190c
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Wed Nov 22 12:23:25 2023 +0800

    [hotfix] Minor fix compile in FlinkSink
---
 .../src/main/java/org/apache/paimon/flink/sink/FlinkSink.java           | 2 +-
 1 file changed, 1 insertion(+), 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
index b305f0c0a..d0bae779d 100644
--- 
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 abstract class FlinkSink<T> implements Serializable {
         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());
         }