Commit 73bb8668 authored by wenmo's avatar wenmo

[Fix-424][common]Modify the default value of the sqlSeparator to ';\r\n|;\n'

parent 9521bf62
package com.dlink.model; package com.dlink.model;
import com.dlink.assertion.Asserts;
import com.fasterxml.jackson.databind.JsonNode;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import com.dlink.assertion.Asserts;
import com.fasterxml.jackson.databind.JsonNode;
/** /**
* SystemConfiguration * SystemConfiguration
* *
...@@ -30,39 +30,39 @@ public class SystemConfiguration { ...@@ -30,39 +30,39 @@ public class SystemConfiguration {
}}; }};
private Configuration sqlSubmitJarPath = new Configuration( private Configuration sqlSubmitJarPath = new Configuration(
"sqlSubmitJarPath", "sqlSubmitJarPath",
"FlinkSQL提交Jar路径", "FlinkSQL提交Jar路径",
ValueType.STRING, ValueType.STRING,
"hdfs:///dlink/jar/dlink-app.jar", "hdfs:///dlink/jar/dlink-app.jar",
"用于指定Applcation模式提交FlinkSQL的Jar的路径" "用于指定Applcation模式提交FlinkSQL的Jar的路径"
); );
private Configuration sqlSubmitJarParas = new Configuration( private Configuration sqlSubmitJarParas = new Configuration(
"sqlSubmitJarParas", "sqlSubmitJarParas",
"FlinkSQL提交Jar参数", "FlinkSQL提交Jar参数",
ValueType.STRING, ValueType.STRING,
"", "",
"用于指定Applcation模式提交FlinkSQL的Jar的参数" "用于指定Applcation模式提交FlinkSQL的Jar的参数"
); );
private Configuration sqlSubmitJarMainAppClass = new Configuration( private Configuration sqlSubmitJarMainAppClass = new Configuration(
"sqlSubmitJarMainAppClass", "sqlSubmitJarMainAppClass",
"FlinkSQL提交Jar主类", "FlinkSQL提交Jar主类",
ValueType.STRING, ValueType.STRING,
"com.dlink.app.MainApp", "com.dlink.app.MainApp",
"用于指定Applcation模式提交FlinkSQL的Jar的主类" "用于指定Applcation模式提交FlinkSQL的Jar的主类"
); );
private Configuration useRestAPI = new Configuration( private Configuration useRestAPI = new Configuration(
"useRestAPI", "useRestAPI",
"使用 RestAPI", "使用 RestAPI",
ValueType.BOOLEAN, ValueType.BOOLEAN,
true, true,
"在运维 Flink 任务时是否使用 RestAPI" "在运维 Flink 任务时是否使用 RestAPI"
); );
private Configuration sqlSeparator = new Configuration( private Configuration sqlSeparator = new Configuration(
"sqlSeparator", "sqlSeparator",
"FlinkSQL语句分割符", "FlinkSQL语句分割符",
ValueType.STRING, ValueType.STRING,
";\r\n", ";\r\n|;\n",
"Flink SQL 的语句分割符" "Flink SQL 的语句分割符"
); );
public void setConfiguration(JsonNode jsonNode) { public void setConfiguration(JsonNode jsonNode) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment