xushiyan commented on issue #3971: URL: https://github.com/apache/hudi/issues/3971#issuecomment-967314049
>2.The method org.apache.hudi.util.StreamerUtil#getSourceSchema(org.apache.flink.configuration.Configuration) says --source-avro-schema-path must be null. I think what you meant is you need to set schema-path to null so the method will read schema instead, right? Because `--source-avro-schema-path` defaults to `""`. I agree it should never need people to manually set something to null. Also I think in `FlinkStreamerConfig` it should check `if (!StringUtils.isNullOrEmpty(config.sourceAvroSchemaPath))`. @0x574C would you mind opening a PR to fix this? thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
