This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-0.1 in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
commit 295bb237439673520f23e8e2efc3d6de00aa61c0 Author: JingsongLi <[email protected]> AuthorDate: Thu Mar 31 10:07:52 2022 +0800 [hotfix] Add thread name to StoreSinkWriter compaction thread pool --- .../org/apache/flink/table/store/connector/sink/StoreSinkWriter.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriter.java b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriter.java index 6a568a6..2995b74 100644 --- a/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriter.java +++ b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriter.java @@ -31,6 +31,7 @@ import org.apache.flink.table.store.file.utils.RecordWriter; import org.apache.flink.table.store.log.LogWriteCallback; import org.apache.flink.table.store.sink.SinkRecord; import org.apache.flink.table.store.sink.SinkRecordConverter; +import org.apache.flink.util.concurrent.ExecutorThreadFactory; import javax.annotation.Nullable; @@ -76,7 +77,9 @@ public class StoreSinkWriter<WriterStateT> this.overwrite = overwrite; this.logWriter = logWriter; this.logCallback = logCallback; - this.compactExecutor = Executors.newSingleThreadScheduledExecutor(); + this.compactExecutor = + Executors.newSingleThreadScheduledExecutor( + new ExecutorThreadFactory("compaction-thread")); this.writers = new HashMap<>(); }
