kudu sink writemode参数没填写报NULLPointerException

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法

Apache License 2.0

2.02k stars 923 forks source link

Open jepsonzhang opened 2 years ago

jepsonzhang commented 2 years ago

根据文档中描述，kudu sink类型的插件中writeMode类型为非必须项，且带有默认值，但实际配置运行中，未配置该参数会抛出NULLPointerException异常，导致任务失败

jepsonzhang commented 2 years ago

kudusink插件中的KuduSinkParser.java的transWriteMode函数中writeMode变量没判空处理，导致switch时候会抛出NULLPointerException。