deadwind4 opened a new issue #2071:
URL: https://github.com/apache/iceberg/issues/2071
following is POM and error message.
` <flink.version>1.11.3</flink.version>
<scala.version>2.12</scala.version>
<hive.version>2.3.6</hive.version>
<iceberg.version>0.10.0</iceberg.version>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-sql-connector-hive-${hive.version}_${scala.version}</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.iceberg</groupId>
<artifactId>iceberg-flink</artifactId>
<version>${iceberg.version}</version>
</dependency>`
`java.lang.NoSuchMethodError:
org.apache.parquet.schema.Types$PrimitiveBuilder.as(Lorg/apache/parquet/schema/LogicalTypeAnnotation;)Lorg/apache/parquet/schema/Types$Builder;
at
org.apache.iceberg.parquet.TypeToMessageType.primitive(TypeToMessageType.java:145)
~[iceberg-parquet-0.10.0.jar:na]
at
org.apache.iceberg.parquet.TypeToMessageType.field(TypeToMessageType.java:88)
~[iceberg-parquet-0.10.0.jar:na]
at
org.apache.iceberg.parquet.TypeToMessageType.convert(TypeToMessageType.java:65)
~[iceberg-parquet-0.10.0.jar:na]
at
org.apache.iceberg.parquet.ParquetSchemaUtil.convert(ParquetSchemaUtil.java:43)
~[iceberg-parquet-0.10.0.jar:na]
at
org.apache.iceberg.parquet.Parquet$WriteBuilder.build(Parquet.java:228)
~[iceberg-parquet-0.10.0.jar:na]
at
org.apache.iceberg.flink.sink.RowDataTaskWriterFactory$FlinkFileAppenderFactory.newAppender(RowDataTaskWriterFactory.java:161)
~[iceberg-flink-0.10.0.jar:na]
at
org.apache.iceberg.io.BaseTaskWriter$RollingFileWriter.openCurrent(BaseTaskWriter.java:103)
~[iceberg-core-0.10.0.jar:na]
at
org.apache.iceberg.io.BaseTaskWriter$RollingFileWriter.<init>(BaseTaskWriter.java:82)
~[iceberg-core-0.10.0.jar:na]
at
org.apache.iceberg.io.UnpartitionedWriter.<init>(UnpartitionedWriter.java:33)
~[iceberg-core-0.10.0.jar:na]
at
org.apache.iceberg.flink.sink.RowDataTaskWriterFactory.create(RowDataTaskWriterFactory.java:95)
~[iceberg-flink-0.10.0.jar:na]
at
org.apache.iceberg.flink.sink.IcebergStreamWriter.open(IcebergStreamWriter.java:59)
~[iceberg-flink-0.10.0.jar:na]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:291)
~[flink-streaming-java_2.12-1.11.3.jar:1.11.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$1(StreamTask.java:506)
~[flink-streaming-java_2.12-1.11.3.jar:1.11.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
~[flink-streaming-java_2.12-1.11.3.jar:1.11.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:475)
~[flink-streaming-java_2.12-1.11.3.jar:1.11.3]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:526)
~[flink-streaming-java_2.12-1.11.3.jar:1.11.3]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
[flink-runtime_2.12-1.11.3.jar:1.11.3]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
[flink-runtime_2.12-1.11.3.jar:1.11.3]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_251]`
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
