[
https://issues.apache.org/jira/browse/HUDI-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Mercer updated HUDI-2760:
------------------------------
Description:
When use org.apache.hudi.streamer.HoodieFlinkStreamer, I can't get
*--source-avro-schema* value because the method
{{*org.apache.hudi.util.StreamerUtil#getSourceSchema(org.apache.flink.configuration.Configuration)*
}}always read schema from {*}{{--source-avro-schema-path}}{*}{{{}.{}}}
A parameter check is required in
org/apache/hudi/streamer/FlinkStreamerConfig.java:368
was:
1.When use org.apache.hudi.streamer.HoodieFlinkStreamer, set avro schema with
{*}{{--source-avro-schema}}{*}.
2.The method
{{{}org.apache.hudi.util.StreamerUtil#getSourceSchema(org.apache.flink.configuration.Configuration){}}}says
*{{--source-avro-schema-path}}* must be null.
3.If I set *{{--source-avro-schema-path}}* to null,
org/apache/hudi/streamer/FlinkStreamerConfig.java:368 throw a
NullPointerException.
> HoodieFlinkStreamer parameter bug
> ---------------------------------
>
> Key: HUDI-2760
> URL: https://issues.apache.org/jira/browse/HUDI-2760
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Alex Mercer
> Priority: Minor
> Fix For: 0.10.0
>
>
> When use org.apache.hudi.streamer.HoodieFlinkStreamer, I can't get
> *--source-avro-schema* value because the method
> {{*org.apache.hudi.util.StreamerUtil#getSourceSchema(org.apache.flink.configuration.Configuration)*
> }}always read schema from {*}{{--source-avro-schema-path}}{*}{{{}.{}}}
> A parameter check is required in
> org/apache/hudi/streamer/FlinkStreamerConfig.java:368
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
