[
https://issues.apache.org/jira/browse/HUDI-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Xu updated HUDI-5020:
-----------------------------
Fix Version/s: (was: 0.12.0)
> java.lang.NoSuchMethodError:
> org.apache.hudi.table.format.cow.vector.reader.ParquetColumnarRowSplitReader.nextRecord()Lorg/apache/flink/table/data/ColumnarRowData
> ------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: HUDI-5020
> URL: https://issues.apache.org/jira/browse/HUDI-5020
> Project: Apache Hudi
> Issue Type: Bug
> Components: connectors
> Environment: Flink 1.15.1
> Hudi 0.12.0
> Reporter: JasonLee
> Priority: Major
>
> The flink task throws the following exception when I query the hudi table
>
> {code:java}
> java.lang.NoSuchMethodError:
> org.apache.hudi.table.format.cow.vector.reader.ParquetColumnarRowSplitReader.nextRecord()Lorg/apache/flink/table/data/ColumnarRowData;
> at
> org.apache.hudi.table.format.cow.CopyOnWriteInputFormat.nextRecord(CopyOnWriteInputFormat.java:279)
> at
> org.apache.hudi.table.format.cow.CopyOnWriteInputFormat.nextRecord(CopyOnWriteInputFormat.java:64)
> at
> org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:90)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332)
> {code}
> It looks like a jar conflict, but I have checked the relevant code and found
> nothing wrong. Besides, I have put flink-table-common-1.15.1.jar under
> flink/lib.
> The SQL statement is shown below:
> {code:java}
> CREATE TABLE hudi_test(
> name VARCHAR(20) PRIMARY KEY NOT ENFORCED,
> age INT,
> ts BIGINT,
> dt STRING
> )
> WITH (
> 'connector' = 'hudi',
> 'path' = 'hdfs://master:9000/flink/hudi/hudi_test/',
> 'table.type' = 'COPY_ON_WRITE' -- this creates a MERGE_ON_READ table, by
> default is COPY_ON_WRITE
> );
> select * from hudi_test; {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
