[
https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-24883:
--------------------------------
Component/s: API / DataStream
> 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
> Components: API / DataStream
> Affects Versions: 1.14.0
> Reporter: aresyhzhang
> Priority: Critical
>
> version:
> flink verison:1.14.0 java version:1.8
> a simple example code:
> {code:java}
> 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());
> }
> {code}
> 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)
