Shammon created FLINK-31204:
-------------------------------
Summary: HiveCatalogITCase fails due to avro conflict in table
store
Key: FLINK-31204
URL: https://issues.apache.org/jira/browse/FLINK-31204
Project: Flink
Issue Type: Bug
Components: Table Store
Affects Versions: table-store-0.4.0
Reporter: Shammon
Test fails in IDEA
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
... 4 more
Caused by: java.lang.NoSuchMethodError: org.apache.avro.Schema.isNullable()Z
at
org.apache.flink.table.store.format.avro.AvroSchemaConverter.nullableSchema(AvroSchemaConverter.java:203)
at
org.apache.flink.table.store.format.avro.AvroSchemaConverter.convertToSchema(AvroSchemaConverter.java:172)
at
org.apache.flink.table.store.format.avro.AvroSchemaConverter.convertToSchema(AvroSchemaConverter.java:147)
at
org.apache.flink.table.store.format.avro.AvroSchemaConverter.convertToSchema(AvroSchemaConverter.java:147)
at
org.apache.flink.table.store.format.avro.AvroSchemaConverter.convertToSchema(AvroSchemaConverter.java:55)
at
org.apache.flink.table.store.format.avro.AvroFileFormat$AvroGenericRecordBulkFormat.<init>(AvroFileFormat.java:95)
at
org.apache.flink.table.store.format.avro.AvroFileFormat.createReaderFactory(AvroFileFormat.java:80)
at
org.apache.flink.table.store.format.FileFormat.createReaderFactory(FileFormat.java:71)
at
org.apache.flink.table.store.format.FileFormat.createReaderFactory(FileFormat.java:67)
at
org.apache.flink.table.store.file.manifest.ManifestList$Factory.create(ManifestList.java:130)
at
org.apache.flink.table.store.file.operation.AbstractFileStoreScan.<init>(AbstractFileStoreScan.java:95)
at
org.apache.flink.table.store.file.operation.KeyValueFileStoreScan.<init>(KeyValueFileStoreScan.java:57)
at
org.apache.flink.table.store.file.KeyValueFileStore.newScan(KeyValueFileStore.java:118)
at
org.apache.flink.table.store.file.KeyValueFileStore.newScan(KeyValueFileStore.java:71)
at
org.apache.flink.table.store.file.KeyValueFileStore.newScan(KeyValueFileStore.java:38)
at
org.apache.flink.table.store.file.AbstractFileStore.newCommit(AbstractFileStore.java:116)
at
org.apache.flink.table.store.file.AbstractFileStore.newCommit(AbstractFileStore.java:43)
at
org.apache.flink.table.store.table.AbstractFileStoreTable.newCommit(AbstractFileStoreTable.java:121)
at
org.apache.flink.table.store.connector.sink.FileStoreSink.lambda$createCommitterFactory$63124b4e$1(FileStoreSink.java:69)
at
org.apache.flink.table.store.connector.sink.CommitterOperator.initializeState(CommitterOperator.java:104)
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.initializeOperatorState(StreamOperatorStateHandler.java:122)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:283)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:726)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:702)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:669)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
at java.lang.Thread.run(Thread.java:750)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
