zhangwen0527 commented on issue #12988:
URL: https://github.com/apache/seatunnel/issues/12988#issuecomment-6570132161
我使用的elasticsearch:9.5.5，apache-seatunnel:3.0.0,配置写入 如下：
env {
parallelism = 4
job.name = "json_es"
job.mode = "BATCH"
checkpoint.interval = 10000
}
source {
LocalFile {
file_format_type = "json"
path = "/data/wen/face20261021.json"
schema = {
fields {
uuid = "string"
camera_id = "string"
target_img = "string"
target_scene = "string"
target_desc = "string"
face_vector = "array<float>"
face_valid = "int"
src_type = "int"
take_time = "timestamp"
create_time = "timestamp"
}
}
}
}
sink {
Elasticsearch {
hosts = ["http://127.0.0.1:9200";]
tls_verify_certificate = false
tls_verify_hostname = false
index = "t_face_vector"
username = "elastic"
password = "elastic"
schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
data_save_mode = "APPEND_DATA"
max_batch_size = 3000
max_retry_count = 3
}
}
连接报错如下：
2026-11-02 13:46:04,166 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-10] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (2/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=3}] turned from state CANCELING to CANCELED.
2026-11-02 13:46:04,166 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-10] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (2/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=3}] state process is stopped
2026-11-02 13:46:04,166 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-7] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (2/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=3}] future complete with state CANCELED
2026-11-02 13:46:04,167 INFO [o.a.s.e.s.m.JobMaster ]
[hz.main.seaTunnel.task.thread-10] - release the task group resource
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=3}
2026-11-02 13:46:04,168 INFO [a.s.e.s.s.s.DefaultSlotService]
[hz.main.generic-operation.thread-36] - received slot release request, jobID:
1169512690318573569, slot: SlotProfile{worker=[localhost]:5801, slotID=13,
ownerJobID=1169512690318573569, assigned=true,
resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}},
sequence='eafd287f-4c50-42dd-b56c-ef4668a49010'}
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=1}] - [localhost]:5801 [seatunnel-802956] [5.1] taskGroup
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=1}
complete with CANCELED
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-4] - [localhost]:5801 [seatunnel-802956] [5.1]
Task TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=1}
complete with state CANCELED
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] - [localhost]:5801 [seatunnel-802956] [5.1] taskGroup
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=2}
complete with CANCELED
2026-11-02 13:46:04,169 ERROR [.s.e.s.c.CheckpointCoordinator]
[hz.main.generic-operation.thread-35] - report error from task
org.apache.seatunnel.common.utils.SeaTunnelException:
org.apache.seatunnel.connectors.seatunnel.elasticsearch.exception.ElasticsearchConnectorException:
ErrorCode:[ELASTICSEARCH-02], ErrorDescription:[Get elasticsearch version
failed] - version=9,fail fo find ElasticsearchVersion.
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.constant.ElasticsearchVersion.get(ElasticsearchVersion.java:52)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.constant.ElasticsearchVersion.get(ElasticsearchVersion.java:58)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.dto.ElasticsearchClusterInfo.getElasticsearchVersion(ElasticsearchClusterInfo.java:36)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.serialize.type.IndexTypeSerializerFactory.getIndexTypeSerializer(IndexTypeSerializerFactory.java:41)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.serialize.ElasticsearchRowSerializer.<init>(ElasticsearchRowSerializer.java:75)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.sink.ElasticsearchSinkWriter.initializeSerializer(ElasticsearchSinkWriter.java:311)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.sink.ElasticsearchSinkWriter.setMultiTableResourceManager(ElasticsearchSinkWriter.java:160)
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.initResourceManager(MultiTableSinkWriter.java:301)
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.<init>(MultiTableSinkWriter.java:256)
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableSink.createWriter(MultiTableSink.java:150)
at
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.restoreState(SinkFlowLifeCycle.java:406)
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.lambda$restoreState$16(SeaTunnelTask.java:608)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1654)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.restoreState(SeaTunnelTask.java:605)
at
org.apache.seatunnel.engine.server.checkpoint.operation.NotifyTaskRestoreOperation.lambda$null$0(NotifyTaskRestoreOperation.java:107)
at
java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1736)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:519)
[seatunnel-starter.jar:3.0.0]
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:239)
[seatunnel-starter.jar:3.0.0]
at
org.apache.seatunnel.engine.server.checkpoint.operation.CheckpointErrorReportOperation.runInternal(CheckpointErrorReportOperation.java:48)
[seatunnel-starter.jar:3.0.0]
at
org.apache.seatunnel.engine.server.task.operation.TracingOperation.run(TracingOperation.java:42)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)
[seatunnel-starter.jar:3.0.0]
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-4] - [localhost]:5801 [seatunnel-802956] [5.1]
Received task end from execution TaskGroupLocation{jobId=1169512690318573569,
pipelineId=1, taskGroupId=1}, state CANCELED
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-802956] [5.1]
Task TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=2}
complete with state CANCELED
2026-11-02 13:46:04,169 INFO [o.a.s.a.e.LoggingEventHandler ]
[hz.main.generic-operation.thread-37] - log event:
EnumeratorCloseEvent(createdTime=1793598364169, jobId=1169512690318573569,
eventType=LIFECYCLE_ENUMERATOR_CLOSE)
2026-11-02 13:46:04,169 INFO [.MultipleTableFileSourceReader]
[BlockingWorker-TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] - Closed the MultipleTableLocalFileSourceReader
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=4}] - [localhost]:5801 [seatunnel-802956] [5.1] taskGroup
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=4}
complete with CANCELED
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.TaskExecutionService]
[BlockingWorker-TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=5}] - [localhost]:5801 [seatunnel-802956] [5.1] taskGroup
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=5}
complete with CANCELED
2026-11-02 13:46:04,169 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-802956] [5.1]
Received task end from execution TaskGroupLocation{jobId=1169512690318573569,
pipelineId=1, taskGroupId=2}, state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.a.e.LoggingEventHandler ]
[hz.main.generic-operation.thread-39] - log event:
ReaderCloseEvent(createdTime=1793598364169, jobId=1169512690318573569,
eventType=LIFECYCLE_READER_CLOSE)
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-9] - [localhost]:5801 [seatunnel-802956] [5.1]
Task TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=4}
complete with state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.TaskExecutionService]
[hz.main.seaTunnel.task.thread-10] - [localhost]:5801 [seatunnel-802956] [5.1]
Task TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=5}
complete with state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-9] - [localhost]:5801 [seatunnel-802956] [5.1]
Received task end from execution TaskGroupLocation{jobId=1169512690318573569,
pipelineId=1, taskGroupId=4}, state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.CoordinatorService ]
[hz.main.seaTunnel.task.thread-10] - [localhost]:5801 [seatunnel-802956] [5.1]
Received task end from execution TaskGroupLocation{jobId=1169512690318573569,
pipelineId=1, taskGroupId=5}, state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-4] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=1}] turned from state CANCELING to CANCELED.
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-4] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=1}] state process is stopped
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-2] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (1/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] turned from state CANCELING to CANCELED.
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-2] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (1/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] state process is stopped
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-7] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=1}] future complete with state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (1/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] future complete with state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-10] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (4/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=5}] turned from state CANCELING to CANCELED.
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-10] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (4/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=5}] state process is stopped
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (4/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=5}] future complete with state CANCELED
2026-11-02 13:46:04,170 INFO [o.a.s.e.s.m.JobMaster ]
[hz.main.seaTunnel.task.thread-2] - release the task group resource
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=2}
2026-11-02 13:46:04,171 INFO [a.s.e.s.s.s.DefaultSlotService]
[hz.main.generic-operation.thread-40] - received slot release request, jobID:
1169512690318573569, slot: SlotProfile{worker=[localhost]:5801, slotID=14,
ownerJobID=1169512690318573569, assigned=true,
resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}},
sequence='17ec053d-dbee-4cb5-93f9-dded65d88b87'}
2026-11-02 13:46:04,171 INFO [o.a.s.e.s.m.JobMaster ]
[hz.main.seaTunnel.task.thread-10] - release the task group resource
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=5}
2026-11-02 13:46:04,171 INFO [a.s.e.s.s.s.DefaultSlotService]
[hz.main.generic-operation.thread-41] - received slot release request, jobID:
1169512690318573569, slot: SlotProfile{worker=[localhost]:5801, slotID=15,
ownerJobID=1169512690318573569, assigned=true,
resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}},
sequence='999dd74b-6ba0-4edb-bbe6-bccec2d9022e'}
2026-11-02 13:46:04,173 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-9] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (3/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=4}] turned from state CANCELING to CANCELED.
2026-11-02 13:46:04,173 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.seaTunnel.task.thread-9] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (3/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=4}] state process is stopped
2026-11-02 13:46:04,173 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (3/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=4}] future complete with state CANCELED
2026-11-02 13:46:04,173 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Job json_es (1169512690318573569),
Pipeline: [(1/1)] will end with state FAILED
2026-11-02 13:46:04,174 INFO [o.a.s.e.s.m.JobMaster ]
[hz.main.seaTunnel.task.thread-9] - release the task group resource
TaskGroupLocation{jobId=1169512690318573569, pipelineId=1, taskGroupId=4}
2026-11-02 13:46:04,174 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Job json_es (1169512690318573569),
Pipeline: [(1/1)] turned from state CANCELING to FAILED.
2026-11-02 13:46:04,174 INFO [a.s.e.s.s.s.DefaultSlotService]
[hz.main.generic-operation.thread-42] - received slot release request, jobID:
1169512690318573569, slot: SlotProfile{worker=[localhost]:5801, slotID=12,
ownerJobID=1169512690318573569, assigned=true,
resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}},
sequence='ccf38e2a-7326-4c16-b01f-061227a9c83e'}
2026-11-02 13:46:04,174 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Restore time 3, pipeline Job json_es
(1169512690318573569), Pipeline: [(1/1)]
2026-11-02 13:46:04,174 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Reset pipeline Job json_es
(1169512690318573569), Pipeline: [(1/1)] state to CREATED
2026-11-02 13:46:04,175 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-6] - Reset pipeline Job json_es
(1169512690318573569), Pipeline: [(1/1)] state to CREATED complete
2026-11-02 13:46:04,175 ERROR [.s.e.s.c.CheckpointCoordinator]
[hz.main.generic-operation.thread-43] - report error from task
org.apache.seatunnel.common.utils.SeaTunnelException:
org.apache.seatunnel.connectors.seatunnel.elasticsearch.exception.ElasticsearchConnectorException:
ErrorCode:[ELASTICSEARCH-02], ErrorDescription:[Get elasticsearch version
failed] - version=9,fail fo find ElasticsearchVersion.
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.constant.ElasticsearchVersion.get(ElasticsearchVersion.java:52)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.constant.ElasticsearchVersion.get(ElasticsearchVersion.java:58)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.dto.ElasticsearchClusterInfo.getElasticsearchVersion(ElasticsearchClusterInfo.java:36)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.serialize.type.IndexTypeSerializerFactory.getIndexTypeSerializer(IndexTypeSerializerFactory.java:41)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.serialize.ElasticsearchRowSerializer.<init>(ElasticsearchRowSerializer.java:75)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.sink.ElasticsearchSinkWriter.initializeSerializer(ElasticsearchSinkWriter.java:311)
at
org.apache.seatunnel.connectors.seatunnel.elasticsearch.sink.ElasticsearchSinkWriter.setMultiTableResourceManager(ElasticsearchSinkWriter.java:160)
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.initResourceManager(MultiTableSinkWriter.java:301)
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.<init>(MultiTableSinkWriter.java:256)
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableSink.createWriter(MultiTableSink.java:150)
at
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.restoreState(SinkFlowLifeCycle.java:406)
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.lambda$restoreState$16(SeaTunnelTask.java:608)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1654)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.restoreState(SeaTunnelTask.java:605)
at
org.apache.seatunnel.engine.server.checkpoint.operation.NotifyTaskRestoreOperation.lambda$null$0(NotifyTaskRestoreOperation.java:107)
at
java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1736)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:519)
[seatunnel-starter.jar:3.0.0]
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:239)
[seatunnel-starter.jar:3.0.0]
at
org.apache.seatunnel.engine.server.checkpoint.operation.CheckpointErrorReportOperation.runInternal(CheckpointErrorReportOperation.java:48)
[seatunnel-starter.jar:3.0.0]
at
org.apache.seatunnel.engine.server.task.operation.TracingOperation.run(TracingOperation.java:42)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123)
[seatunnel-starter.jar:3.0.0]
at
com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)
[seatunnel-starter.jar:3.0.0]
2026-11-02 13:46:04,176 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=1}] turn to state CREATED.
2026-11-02 13:46:04,176 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (1/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] turn to state CREATED.
2026-11-02 13:46:04,177 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (2/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=3}] turn to state CREATED.
2026-11-02 13:46:04,177 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (3/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=4}] turn to state CREATED.
2026-11-02 13:46:04,178 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - Job (1169512690318573569), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (4/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=5}] turn to state CREATED.
2026-11-02 13:46:04,178 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-6] - received restore CheckpointCoordinator with
alreadyStarted: false
2026-11-02 13:46:04,178 WARN [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-6] - checkpoint_state_1169512690318573569_1 has
already been cleaned, skip persisting transition to RUNNING
2026-11-02 13:46:04,178 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-6] - start clean pending checkpoint cause
CheckpointCoordinator reset.
2026-11-02 13:46:04,179 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - The task Job (1169512690318573569),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (1/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=2}] is in state CREATED when init state future
2026-11-02 13:46:04,179 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - The task Job (1169512690318573569),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (2/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=3}] is in state CREATED when init state future
2026-11-02 13:46:04,179 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - The task Job (1169512690318573569),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (3/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=4}] is in state CREATED when init state future
2026-11-02 13:46:04,180 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - The task Job (1169512690318573569),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (4/4)],
taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569, pipelineId=1,
taskGroupId=5}] is in state CREATED when init state future
2026-11-02 13:46:04,180 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-6] - The task Job (1169512690318573569),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator
(1/1)], taskGroupLocation: [TaskGroupLocation{jobId=1169512690318573569,
pipelineId=1, taskGroupId=1}] is in state CREATED when init state future
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
