File tree Expand file tree Collapse file tree 1 file changed +18
-6
lines changed
Expand file tree Collapse file tree 1 file changed +18
-6
lines changed Original file line number Diff line number Diff line change 88> > * 扩展了输入和输出的性能指标到promethus
99
1010 ## 新特性:
11- 1.kafka源表支持not null语法,支持字符串类型的时间转换。
12- 2.rdb维表与DB建立连接时,周期进行连接,防止连接断开。rdbsink写入时,对连接进行检查。
13- 3.异步维表支持非等值连接,比如:<>,<,>。
11+ * 1.kafka源表支持not null语法,支持字符串类型的时间转换。
12+ * 2.rdb维表与DB建立连接时,周期进行连接,防止连接断开。rdbsink写入时,对连接进行检查。
13+ * 3.异步维表支持非等值连接,比如:<>,<,>。
14+ * 4.增加kafka数组解析
15+ * 5.增加kafka1.0以上版本的支持
16+ * 6.增加postgresql、kudu、clickhouse维表、结果表的支持
17+ * 7.支持插件的依赖方式,参考pluginLoadMode参数
18+ * 8.支持cep处理
19+ * 9.支持udaf
20+ * 10.支持谓词下移
1421
1522 ## BUG修复:
16- 1.修复不能解析sql中orderby,union语法。
17- 2.修复yarnPer模式提交失败的异常。
23+ * 1.修复不能解析sql中orderby,union语法。
24+ * 2.修复yarnPer模式提交失败的异常。
25+ * 3.一些bug的修复
1826
1927# 已支持
2028 * 源表:kafka 0.9、0.10、0.11、1.x版本
2331
2432# 后续开发计划
2533 * 维表快照
26- * sql优化(谓词下移等)
2734 * kafka avro格式
2835 * topN
2936
@@ -148,6 +155,11 @@ sh submit.sh -sql D:\sideSql.txt -name xctest -remoteSqlPluginPath /opt/dtstack
148155 * 必选:否
149156 * 默认值:false
150157
158+ * ** pluginLoadMode**
159+ * 描述:per_job 模式下的插件包加载方式。classpath:从每台机器加载插件包,shipfile:将需要插件从提交的节点上传到hdfs,不需要每台安装插件
160+ * 必选:否
161+ * 默认值:classpath
162+
151163* ** yarnSessionConf**
152164 * 描述:yarn session 模式下指定的运行的一些参数,[可参考](https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/cli.html),目前只支持指定yid
153165 * 必选:否
You can’t perform that action at this time.
0 commit comments