chenminghua created FLINK-11965:
-----------------------------------
Summary: Provide a REST API for flink to submit plain SQL flink
jobs.
Key: FLINK-11965
URL: https://issues.apache.org/jira/browse/FLINK-11965
Project: Flink
Issue Type: Improvement
Components: SQL / Client
Reporter: chenminghua
SQL Client has been able to use Flink with SQL without the need to write Java
or Scala programs, avoiding tedious compilation and packaging work.However, SQL
Client is used in Command-Line Interface (CLI), which is not convenient for
remote application access. In addition, SQL Client must define sourceTable and
sinkTable in yaml file and submit a job to flink cluster for each SQL statement
processed.For a slightly more complex stream program is not easy to achieve
through SQL Client.Therefore, it is necessary to provide a REST API for flink
to submit plain SQL flink jobs.
The SQL jobs REST API
include:/job/submit、/job/list、/job/stop、/job/restart。Where "/job/submit" is
used to submit the SQL job, and its parameters are passed through the JSON
request.The JSON request looks like this: {color:#FF0000}{"name":"myJob",
"statements":"CREATE TABLE userTable (user BIGINT, message VARCHAR) WITH(type
source, update-mode append, connector.type kafka, connector.version 0.10,
connector.topic test-user, connector.startup-mode earliest-offset,
connector.properties.0.key zookeeper.connect, connector.properties.0.value
zkHost:2181/kafka_2_1_0, connector.properties.1.key bootstrap.servers,
connector.properties.1.value kafkaHost:9099, format.type json,
format.fail-on-missing-field true, format.derive-schema true); CREATE TABLE
targetUserTable (user BIGINT, message VARCHAR) WITH(type sink, ……); CREATE
APPEND VIEW appView SELECT user, message FROM userTable group by user, message;
INSERT into targetUserTable SELECT user, message FROM appView;”}{color}.name is
the name of the job. statements is the contents of a job, which contains
multiple SQL statements（Support create table…., create view….., create append
view….., insert into….. several types of SQL statements).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
