You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Alex Mercer (Jira)" <ji...@apache.org> on 2021/11/15 10:06:00 UTC
[jira] [Updated] (HUDI-2760) HoodieFlinkStreamer parameter bug
[ 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:
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
> 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)