You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Shammon (Jira)" <ji...@apache.org> on 2023/02/24 00:26:00 UTC

[jira] [Created] (FLINK-31204) HiveCatalogITCase fails due to avro conflict in table store

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)