aresyhzhang created FLINK-24883:
-----------------------------------
Summary: Use flink web ui to submit the jar throw Job client must
be a CoordinationRequestGateway. This is a bug.
Key: FLINK-24883
URL: https://issues.apache.org/jira/browse/FLINK-24883
Project: Flink
Issue Type: Bug
Affects Versions: 1.14.0
Reporter: aresyhzhang
version:
flink verison:1.14.0 java version:1.8
a simple example code:
public static void main(String[] args) throws Exception {
EnvironmentSettings batchSettings = EnvironmentSettings
.newInstance()
.useBlinkPlanner()
.inBatchMode()
.build();
TableEnvironment batchTableEnv =
TableEnvironment.create(batchSettings);
Row rowData = Row.of(1, "test");
Table table =
batchTableEnv.fromValues(DataTypes.ROW(DataTypes.FIELD("id", DataTypes.INT()),
DataTypes.FIELD("name", DataTypes.STRING())),
rowData
);
CloseableIterator<org.apache.flink.types.Row> it =
table.execute().collect();
System.out.println(it.next());
}
describe:
My local idea can run normally and output:
+I[1, test]
But when I submit a batch sql job using flink web ui throws:
java.lang.IllegalArgumentException: Job client must be a
CoordinationRequestGateway. This is a bug.
I think this is caused by the "table.execute().collect()" code. Why can't I
submit the task through ui to execute, maybe this is a bug?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
