[ https://issues.apache.org/jira/browse/FLINK-31204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-31204. -------------------------------- Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 306a9ededbebc1d825cbb02c18338f5accf7faca > 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 > Assignee: Shammon > Priority: Major > Labels: pull-request-available > Fix For: table-store-0.4.0 > > > 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)