[
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)
