FrommyMind commented on issue #8909:
URL: https://github.com/apache/seatunnel/issues/8909#issuecomment-2739437897

   
   > 
   > Caused by: 
org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: 
java.lang.RuntimeException: java.lang.RuntimeException: table seatunnel_test 
sink throw error
   >    at 
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:302)
   >    at 
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70)
   >    at 
org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39)
   >    at 
org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27)
   >    at 
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:75)
   >    at 
org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:50)
   >    at 
org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51)
   >    at 
org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72)
   >    at 
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169)
   >    at 
org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77)
   >    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.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
   >    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
   >    at 
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
   >    at 
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
   >    at java.base/java.lang.Thread.run(Thread.java:840)
   > Caused by: java.lang.RuntimeException: table seatunnel_test sink throw 
error
   >    at 
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:140)
   >    at 
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:184)
   >    at 
org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47)
   >    at 
org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:268)
   >    ... 17 more
   > Caused by: java.lang.NoSuchFieldError: NULL_VALUE
   >    at 
org.apache.parquet.avro.AvroSchemaConverter.convertFields(AvroSchemaConverter.java:295)
   >    at 
org.apache.parquet.avro.AvroSchemaConverter.convert(AvroSchemaConverter.java:279)
   >    at 
org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.buildAvroSchemaWithRowType(ParquetWriteStrategy.java:426)
   >    at 
org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.getOrCreateOutputStream(ParquetWriteStrategy.java:161)
   >    at 
org.apache.seatunnel.connectors.seatunnel.file.sink.writer.ParquetWriteStrategy.write(ParquetWriteStrategy.java:122)
   >    at 
org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:157)
   >    at 
org.apache.seatunnel.connectors.seatunnel.file.sink.BaseFileSinkWriter.write(BaseFileSinkWriter.java:50)
   >    at 
org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67)
   >    ... 6 more
   > At the source code: 
`org/apache/parquet/parquet-avro/1.12.3/parquet-avro-1.12.3-sources.jar!/org/apache/parquet/avro/AvroSchemaConverter.java:295`
   > 
   > fields.add(new Schema.Field(
   >             parquetType.getName(), optional(fieldSchema), null, 
NULL_VALUE));
   
   This is beacause I lost the dependency 
   ```
           <dependency>
               <groupId>org.apache.avro</groupId>
               <artifactId>avro</artifactId>
               <version>1.11.4</version>
           </dependency>
   ```


-- 
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: commits-unsubscr...@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to