FLINK插件写入通过nginx代理的be节点时提示空指针

千千千千千 · 2023年03月9日 06:13

【详述】flink插件flink-connector-starrocks版本1.2.5_flink-1.13_2.12，写入数据时提示空指针。
【代码】 EnvironmentSettings settings = EnvironmentSettings.newInstance().build();
TableEnvironment env = TableEnvironment.create(settings);
env.executeSql(
“CREATE TABLE ass_monitoring_test(” +
“digest STRING not null,” +
“exec_time STRING not null,” +
"user STRING," +
// “ts STRING,” +
// “tag STRING,” +
// "database STRING," +
// “sqltext STRING,” +
“primary key(digest, exec_time) not enforced” +
") WITH ( " +
“‘connector’ = ‘starrocks’,” +
“‘jdbc-url’=‘jdbc:mysql://xxxx:9033’,” +
“‘load-url’=‘xxxxx:8033’,” +
“‘database-name’ = ‘hdop’,” +
“‘table-name’ = ‘ass_monitoring_test’,” +
“‘username’ = ‘hdop’,” +
“‘password’ = ‘123456’,” +
“‘sink.buffer-flush.max-rows’ = ‘1000000’,” +
“‘sink.buffer-flush.max-bytes’ = ‘300000000’,” +
“‘sink.buffer-flush.interval-ms’ = ‘5000’,” +
// 自 2.4 版本，支持更新主键模型中的部分列。您可以通过以下两个属性指定需要更新的列，需要在’sink.properties.columns’的最后显示添加’__op’列。
// “‘sink.properties.partial_update’ = ‘true’,” +
“‘sink.properties.columns’ = ‘digest,exec_time,user’,” +
“‘sink.properties.column_separator’ = ‘\x01’,” +
“‘sink.properties.row_delimiter’ = ‘\x02’,” +
“‘sink.max-retries’ = ‘3’” +
“)”
);
env.executeSql(
“INSERT INTO ass_monitoring_test SELECT ‘6’, ‘2021-03-01 12:00:00’, cast(null as varchar) union all SELECT ‘6’, ‘2021-03-02 13:00:00’, ‘6’”);
【问题】Caused by: java.lang.NullPointerException: null
at com.starrocks.data.load.stream.DefaultStreamLoader.send(DefaultStreamLoader.java:257)
at com.starrocks.data.load.stream.DefaultStreamLoader.lambda$send$2(DefaultStreamLoader.java:113)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
… 1 common frames omitted
【问题分析】
我直接将load-url改成be的8040端口是可以执行成功的，用以前的flink-connector-doris插件也是没有问题的，好像是httpclient请求nginx的时候返回307重定向，但是为啥以前的插件是正常返回200，请帮忙定位下原因，谢谢啦