[incubator-paimon] branch master updated: [flink] add todo to CdcRecordStoreMultiWriteOperator

[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 39b0a865a [flink] add todo to CdcRecordStoreMultiWriteOperator
39b0a865a is described below

commit 39b0a865ad2a5bb8cf61b1b6fe51f2da2436cdde
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Fri Jun 30 16:38:03 2023 +0800

    [flink] add todo to CdcRecordStoreMultiWriteOperator
---
 .../apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java
index bcbde48c2..9ef826784 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java
@@ -103,6 +103,8 @@ public class CdcRecordStoreMultiWriteOperator
 
         FileStoreTable table = getTable(tableId);
 
+        // TODO memoryPool should not be null
+        // TODO set executor service to write
         StoreSinkWrite write =
                 writes.computeIfAbsent(
                         tableId,