lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Check --source-avro-schema-path parameter (#3987)

Browse Source 
Co-authored-by: 0x3E6 <dragon1996>
This commit is contained in:
0x574C
2021-11-17 14:45:43 +08:00
committed by GitHub
parent ce7d233307
commit aec5d11da2
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
View File

@@ -365,7 +365,9 @@ public class FlinkStreamerConfig extends Configuration {
conf.setDouble(FlinkOptions.INDEX_STATE_TTL, config.indexStateTtl);
conf.setBoolean(FlinkOptions.INDEX_GLOBAL_ENABLED, config.indexGlobalEnabled);
conf.setString(FlinkOptions.INDEX_PARTITION_REGEX, config.indexPartitionRegex);
conf.setString(FlinkOptions.SOURCE_AVRO_SCHEMA_PATH, config.sourceAvroSchemaPath);
if (!StringUtils.isNullOrEmpty(config.sourceAvroSchemaPath)) {
conf.setString(FlinkOptions.SOURCE_AVRO_SCHEMA_PATH, config.sourceAvroSchemaPath);
}
conf.setString(FlinkOptions.SOURCE_AVRO_SCHEMA, config.sourceAvroSchema);
conf.setBoolean(FlinkOptions.UTC_TIMEZONE, config.utcTimezone);
conf.setBoolean(FlinkOptions.URL_ENCODE_PARTITIONING, config.writePartitionUrlEncode);