YuriyGavrilov opened a new issue, #8604: URL: https://github.com/apache/seatunnel/issues/8604
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened Hi, Get an error while trying to inference external LLM model by reading text file with \t delimiter. Getting this error during some time of running some config lines could be strange by it was another llm suggestion while i am trying to fix this error :) Few days ago run another case same way and processed more that 12000 lines without errors. ``` 2025-02-04 17:57:42,875 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-08], ErrorDescription:[File read failed] - Read data from this file [default.default.default_file:/config/2data44.csv] failed � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.MultipleTableFileSourceReader.pollNext(MultipleTableFileSourceReader.java:85) at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: java.lang.RuntimeException: Failed to inference model with row SeaTunnelRow{tableId=, kind=+I, fields=[2088667, ?]} at org.apache.seatunnel.transform.nlpmodel.llm.LLMTransform.getOutputFieldValue(LLMTransform.java:160) at org.apache.seatunnel.transform.common.SingleFieldOutputTransform.transformRow(SingleFieldOutputTransform.java:47) at org.apache.seatunnel.transform.common.SingleFieldOutputTransform.transformRow(SingleFieldOutputTransform.java:35) at org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform.transform(AbstractSeaTunnelTransform.java:80) at org.apache.seatunnel.transform.common.AbstractCatalogSupportMapTransform.map(AbstractCatalogSupportMapTransform.java:42) at org.apache.seatunnel.transform.common.AbstractCatalogSupportMapTransform.map(AbstractCatalogSupportMapTransform.java:27) at org.apache.seatunnel.transform.common.AbstractMultiCatalogMapTransform.map(AbstractMultiCatalogMapTransform.java:40) at org.apache.seatunnel.transform.common.AbstractMultiCatalogMapTransform.map(AbstractMultiCatalogMapTransform.java:28) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.transform(TransformFlowLifeCycle.java:160) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.received(TransformFlowLifeCycle.java:122) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.received(TransformFlowLifeCycle.java:43) at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:195) at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:112) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.lambda$readProcess$0(TextReadStrategy.java:133) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.SliceOps$1$1.accept(SliceOps.java:204) at java.util.Iterator.forEachRemaining(Iterator.java:116) at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.readProcess(TextReadStrategy.java:104) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.AbstractReadStrategy.resolveArchiveCompressedInputStream(AbstractReadStrategy.java:268) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.read(TextReadStrategy.java:71) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.MultipleTableFileSourceReader.pollNext(MultipleTableFileSourceReader.java:81) ... 12 more Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0 at java.util.ArrayList.rangeCheck(ArrayList.java:659) at java.util.ArrayList.get(ArrayList.java:435) at org.apache.seatunnel.transform.nlpmodel.llm.LLMTransform.getOutputFieldValue(LLMTransform.java:145) ... 39 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ... 2 more 2025-02-04 17:57:42,875 ERROR [o.a.s.c.s.SeaTunnel ] [main] - ``` ### SeaTunnel Version 2.3.9 Docker official ### SeaTunnel Config ```conf env { parallelism = 1 job.mode = "BATCH" read_limit.rows_per_second = 2 job.timeout = 19600 execution.timeout = 19600 client.request.timeout = 9600 execution.checkpoint.interval = 180000 } source { LocalFile { schema { fields { no = string answer = string } } path = "/config/2data44.csv" file_format_type = "csv" field_delimiter = "\t" skip_header_row_number = 1 } } transform { LLM { model_provider = OPENAI inference_columns = ["answer"] model = gpt-4o-mini error_handling = "skip" timeout = 6000 retry_times = 5 batch_size = 2 delay_between_requests = 1000 normalize_input = true min_message_length = 5 api_key = XXXXXX prompt = "XXXXXX" api_path = "https://XXXXX"; } } sink { LocalFile { path = "/config/2data_out.csv" file_format_type = "text" encoding = "UTF-8" batch_size = 700 data_save_mode = "APPEND_DATA" field_delimiter = "\t" tmp_path = "/config/tmp/sea" enable_checkpoint = true checkpoint_interval = 1000 } } ``` ### Running Command ```shell podman run -d --name sea --memory=4g -v ./config:/config apache/seatunnel:2.3.9 ./bin/seatunnel.sh -m local -c /config/002-1.conf ``` ### Error Exception ```log 2025-02-04 17:57:39,688 ERROR [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-7] - Task TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=50000} Failed in Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. 2025-02-04 17:57:39,686 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=50000}] - [localhost]:5801 [seatunnel-679918] [5.1] task 70000 error with exception: [org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-08], ErrorDescription:[File read failed] - Read data from this file [default.default.default_file:/config/2data44.csv] failed], cancel other task in taskGroup TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=50000}. �2025-02-04 17:57:39,689 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-4] - log event: WriterCloseEvent(createdTime=1738691859689, jobId=939216780256083969, eventType=LIFECYCLE_WRITER_CLOSE) �2025-02-04 17:57:39,689 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)] turned from state RUNNING to FAILING. �2025-02-04 17:57:39,689 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-2] - release the task group resource TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=50000} �2025-02-04 17:57:39,689 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)] state process is start �2025-02-04 17:57:39,689 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-6] - received slot release request, jobID: 939216780256083969, slot: SlotProfile{worker=[localhost]:5801, slotID=12, ownerJobID=939216780256083969, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='6467ef4f-4295-4880-8a16-76e0a99bf827'} 2025-02-04 17:57:39,690 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)] turned from state RUNNING to CANCELING. 2025-02-04 17:57:39,691 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Send cancel Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)] operator to member [localhost]:5801 �2025-02-04 17:57:39,691 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-7] - [localhost]:5801 [seatunnel-679918] [5.1] Task (TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1}) need cancel. 2025-02-04 17:57:39,694 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-LocalFile-MultiTableSink]-AggregatedCommitterTask (1/1)] state process is start 2025-02-04 17:57:39,694 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-679918] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1} 2025-02-04 17:57:39,694 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-679918] [5.1] Interrupted task 20000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@5c0fa1fa 2025-02-04 17:57:39,695 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-679918] [5.1] taskGroup TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1} complete with CANCELED �2025-02-04 17:57:39,695 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-5] - log event: EnumeratorCloseEvent(createdTime=1738691859695, jobId=939216780256083969, eventType=LIFECYCLE_ENUMERATOR_CLOSE) �2025-02-04 17:57:39,695 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-679918] [5.1] Task TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1} complete with state CANCELED 2025-02-04 17:57:39,695 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-679918] [5.1] Received task end from execution TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=1}, state CANCELED 2025-02-04 17:57:39,696 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-2] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)] turned from state CANCELING to CANCELED. �2025-02-04 17:57:39,696 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-2] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)] state process is stopped 2025-02-04 17:57:39,696 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SplitEnumerator (1/1)] future complete with state CANCELED 2025-02-04 17:57:39,697 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-LocalFile-MultiTableSink]-AggregatedCommitterTask (1/1)] turned from state RUNNING to CANCELING. 2025-02-04 17:57:39,697 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Send cancel Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-LocalFile-MultiTableSink]-AggregatedCommitterTask (1/1)] operator to member [localhost]:5801 �2025-02-04 17:57:39,697 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-7] - [localhost]:5801 [seatunnel-679918] [5.1] Task (TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3}) need cancel. �2025-02-04 17:57:39,698 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-LocalFile]-SourceTask (1/1)] state process is start 2025-02-04 17:57:39,698 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-679918] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SinkAggregatedCommitterTask@39328a3e 2025-02-04 17:57:39,698 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-679918] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3} 2025-02-04 17:57:39,699 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-679918] [5.1] taskGroup TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3} complete with CANCELED �2025-02-04 17:57:39,699 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-679918] [5.1] Task TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3} complete with state CANCELED 2025-02-04 17:57:39,699 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-679918] [5.1] Received task end from execution TaskGroupLocation{jobId=939216780256083969, pipelineId=1, taskGroupId=3}, state CANCELED 2025-02-04 17:57:39,700 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-2] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-LocalFile-MultiTableSink]-AggregatedCommitterTask (1/1)] turned from state CANCELING to CANCELED. 2025-02-04 17:57:39,700 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-2] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-LocalFile-MultiTableSink]-AggregatedCommitterTask (1/1)] state process is stopped 2025-02-04 17:57:39,700 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-LocalFile-MultiTableSink]-AggregatedCommitterTask (1/1)] future complete with state CANCELED �2025-02-04 17:57:39,701 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-7] - start clean pending checkpoint cause Pipeline turn to end state. �2025-02-04 17:57:39,701 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-7] - Turn checkpoint_state_939216780256083969_1 state from RUNNING to CANCELED �2025-02-04 17:57:39,701 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)] will end with state FAILED �2025-02-04 17:57:39,702 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)] turned from state FAILING to FAILED. �2025-02-04 17:57:39,721 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-7] - release the pipeline Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)] resource �2025-02-04 17:57:39,721 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-10] - received slot release request, jobID: 939216780256083969, slot: SlotProfile{worker=[localhost]:5801, slotID=10, ownerJobID=939216780256083969, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='6467ef4f-4295-4880-8a16-76e0a99bf827'} �2025-02-04 17:57:39,722 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-13] - received slot release request, jobID: 939216780256083969, slot: SlotProfile{worker=[localhost]:5801, slotID=11, ownerJobID=939216780256083969, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='6467ef4f-4295-4880-8a16-76e0a99bf827'} �2025-02-04 17:57:39,723 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-7] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)] state process is stop �2025-02-04 17:57:39,723 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (939216780256083969), Pipeline: [(1/1)] future complete with state FAILED �2025-02-04 17:57:39,724 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-8] - cancel job Job SeaTunnel_Job (939216780256083969) because makeJobEndWhenPipelineEnded is true �2025-02-04 17:57:39,725 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (939216780256083969) turned from state RUNNING to FAILING. �2025-02-04 17:57:39,728 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (939216780256083969) turned from state FAILING to FAILED. �2025-02-04 17:57:39,728 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (939216780256083969) state process is stop 2025-02-04 17:57:39,771 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Job (939216780256083969) end with state FAILED �2025-02-04 17:57:39,771 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-679918] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2025-02-04 17:57:39,774 INFO [c.h.i.s.t.TcpServerConnection ] [hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-679918] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:37009, qualifier=null, endpoint=[127.0.0.1]:37009, remoteUuid=e5d344fa-bbd5-4461-b4aa-bc653437c58e, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side �2025-02-04 17:57:39,775 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-679918] [5.1] Removed connection to endpoint: [localhost]:5801:82b754b5-1766-47cf-ae16-516d890dc839, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:37009->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2025-02-04 17:57:39.770, lastWriteTime=2025-02-04 17:57:35.180, closedTime=2025-02-04 17:57:39.772, connected server version=5.1} �2025-02-04 17:57:39,778 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-679918] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED �2025-02-04 17:57:39,783 INFO [c.h.c.i.ClientEndpointManager ] [hz.main.event-5] - [localhost]:5801 [seatunnel-679918] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:37009, qualifier=null, endpoint=[127.0.0.1]:37009, remoteUuid=e5d344fa-bbd5-4461-b4aa-bc653437c58e, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=e5d344fa-bbd5-4461-b4aa-bc653437c58e, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1738691530092, latest clientAttributes=lastStatisticsCollectionTime=1738691855177,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1738691530071,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=4315480064,os.freePhysicalMemorySize=600920064,os.freeSwapSpaceSize=1023406080,os.maxFileDescriptorCount=1048576,os.openFileDescriptorCount=93,os.processCpuTime=28300000000,os.systemLoadAverage=1.18,os.totalPhysicalMemorySize=16424837 120,os.totalSwapSpaceSize=1023406080,runtime.availableProcessors=4,runtime.freeMemory=258834968,runtime.maxMemory=477626368,runtime.totalMemory=404750336,runtime.uptime=329109,runtime.usedMemory=145915368, labels=[]} �2025-02-04 17:57:39,786 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-679918] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2025-02-04 17:57:39,786 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... �2025-02-04 17:57:39,787 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-679918] [5.1] [localhost]:5801 is SHUTTING_DOWN 2025-02-04 17:57:39,791 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-17] - [localhost]:5801 [seatunnel-679918] [5.1] Shutdown request of Member [localhost]:5801 - 82b754b5-1766-47cf-ae16-516d890dc839 [master node] [active master] this is handled �2025-02-04 17:57:39,799 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-679918] [5.1] Shutting down connection manager... �2025-02-04 17:57:39,808 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-679918] [5.1] Shutting down node engine... �2025-02-04 17:57:39,836 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Stopped ServerConnector@71f1cc02{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} 2025-02-04 17:57:39,837 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Stopped scavenging �2025-02-04 17:57:39,838 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Stopped o.a.s.s.o.e.j.s.ServletContextHandler@3b83459e{/,null,STOPPED} 2025-02-04 17:57:39,845 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2025-02-04 17:57:39,848 INFO [o.a.s.e.s.EventService ] [event-forwarder-0] - Event forward thread interrupted �2025-02-04 17:57:42,870 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5801 [seatunnel-679918] [5.1] Destroying node NodeExtension. �2025-02-04 17:57:42,871 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-679918] [5.1] Hazelcast Shutdown is completed in 3080 ms. �2025-02-04 17:57:42,871 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-679918] [5.1] [localhost]:5801 is SHUTDOWN 2025-02-04 17:57:42,871 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2025-02-04 17:57:42,872 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed metrics executor service ...... 2025-02-04 17:57:42,872 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2025-02-04 17:57:42,872 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, �2025-02-04 17:57:42,872 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2025-02-04 17:57:42,872 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed �2025-02-04 17:57:42,875 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-08], ErrorDescription:[File read failed] - Read data from this file [default.default.default_file:/config/2data44.csv] failed � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.MultipleTableFileSourceReader.pollNext(MultipleTableFileSourceReader.java:85) at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: java.lang.RuntimeException: Failed to inference model with row SeaTunnelRow{tableId=, kind=+I, fields=[2088667, ?]} at org.apache.seatunnel.transform.nlpmodel.llm.LLMTransform.getOutputFieldValue(LLMTransform.java:160) at org.apache.seatunnel.transform.common.SingleFieldOutputTransform.transformRow(SingleFieldOutputTransform.java:47) at org.apache.seatunnel.transform.common.SingleFieldOutputTransform.transformRow(SingleFieldOutputTransform.java:35) at org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform.transform(AbstractSeaTunnelTransform.java:80) at org.apache.seatunnel.transform.common.AbstractCatalogSupportMapTransform.map(AbstractCatalogSupportMapTransform.java:42) at org.apache.seatunnel.transform.common.AbstractCatalogSupportMapTransform.map(AbstractCatalogSupportMapTransform.java:27) at org.apache.seatunnel.transform.common.AbstractMultiCatalogMapTransform.map(AbstractMultiCatalogMapTransform.java:40) at org.apache.seatunnel.transform.common.AbstractMultiCatalogMapTransform.map(AbstractMultiCatalogMapTransform.java:28) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.transform(TransformFlowLifeCycle.java:160) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.received(TransformFlowLifeCycle.java:122) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.received(TransformFlowLifeCycle.java:43) at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:195) at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:112) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.lambda$readProcess$0(TextReadStrategy.java:133) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.SliceOps$1$1.accept(SliceOps.java:204) at java.util.Iterator.forEachRemaining(Iterator.java:116) at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.readProcess(TextReadStrategy.java:104) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.AbstractReadStrategy.resolveArchiveCompressedInputStream(AbstractReadStrategy.java:268) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.read(TextReadStrategy.java:71) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.MultipleTableFileSourceReader.pollNext(MultipleTableFileSourceReader.java:81) ... 12 more Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0 at java.util.ArrayList.rangeCheck(ArrayList.java:659) at java.util.ArrayList.get(ArrayList.java:435) at org.apache.seatunnel.transform.nlpmodel.llm.LLMTransform.getOutputFieldValue(LLMTransform.java:145) ... 39 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ... 2 more 2025-02-04 17:57:42,875 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: org.apache.seatunnel.connectors.seatunnel.file.exception.FileConnectorException: ErrorCode:[FILE-08], ErrorDescription:[File read failed] - Read data from this file [default.default.default_file:/config/2data44.csv] failed � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.MultipleTableFileSourceReader.pollNext(MultipleTableFileSourceReader.java:85) at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: java.lang.RuntimeException: Failed to inference model with row SeaTunnelRow{tableId=, kind=+I, fields=[2088667, ?]} at org.apache.seatunnel.transform.nlpmodel.llm.LLMTransform.getOutputFieldValue(LLMTransform.java:160) at org.apache.seatunnel.transform.common.SingleFieldOutputTransform.transformRow(SingleFieldOutputTransform.java:47) at org.apache.seatunnel.transform.common.SingleFieldOutputTransform.transformRow(SingleFieldOutputTransform.java:35) at org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform.transform(AbstractSeaTunnelTransform.java:80) at org.apache.seatunnel.transform.common.AbstractCatalogSupportMapTransform.map(AbstractCatalogSupportMapTransform.java:42) at org.apache.seatunnel.transform.common.AbstractCatalogSupportMapTransform.map(AbstractCatalogSupportMapTransform.java:27) at org.apache.seatunnel.transform.common.AbstractMultiCatalogMapTransform.map(AbstractMultiCatalogMapTransform.java:40) at org.apache.seatunnel.transform.common.AbstractMultiCatalogMapTransform.map(AbstractMultiCatalogMapTransform.java:28) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.transform(TransformFlowLifeCycle.java:160) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.received(TransformFlowLifeCycle.java:122) at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.received(TransformFlowLifeCycle.java:43) at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:195) at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:112) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.lambda$readProcess$0(TextReadStrategy.java:133) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.SliceOps$1$1.accept(SliceOps.java:204) at java.util.Iterator.forEachRemaining(Iterator.java:116) at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.readProcess(TextReadStrategy.java:104) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.AbstractReadStrategy.resolveArchiveCompressedInputStream(AbstractReadStrategy.java:268) at org.apache.seatunnel.connectors.seatunnel.file.source.reader.TextReadStrategy.read(TextReadStrategy.java:71) � at org.apache.seatunnel.connectors.seatunnel.file.source.reader.MultipleTableFileSourceReader.pollNext(MultipleTableFileSourceReader.java:81) ... 12 more Caused by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0 at java.util.ArrayList.rangeCheck(ArrayList.java:659) at java.util.ArrayList.get(ArrayList.java:435) at org.apache.seatunnel.transform.nlpmodel.llm.LLMTransform.getOutputFieldValue(LLMTransform.java:145) ... 39 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ... 2 more �2025-02-04 17:57:42,878 INFO [s.c.s.s.c.ClientExecuteCommand] [SeaTunnel-CompletableFuture-Thread-2] - run shutdown hook because get close signal ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots  ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
