shaolei7788

json 内容如下： { "job":{ "content":[ { "reader":{ "parameter":{ "path":"/sftpuser/emp.txt", "protocol":"sftp", "port":22, "isFirstLineHeader":false, "host":"ip", "privateKeyPath": "/root/.ssh/id_rsa", "column": [ { "name": "comm", "type": "DOUBLE" }, { "name": "deptno", "type": "INT" }, {...

emp.txt内容如下 ,20,7369,SMITH,1980-12-17 300,30,7499,ALLEN,1981-02-20 500,30,7521,WARD,1981-02-22 ,20,7566,JONES,1981-04-02 1400,30,7654,MARTIN,1981-09-28 ,30,7698,BLAKE,1981-05-01 ,10,7782,CLARK,1981-06-09 ,20,7788,SCOTT,1987-07-13 ,10,7839,KING,1981-11-17 0,30,7844,TURNER,1981-09-08 ,20,7876,ADAMS,1987-07-13 ,30,7900,JAMES,1981-12-03 ,20,7902,FORD,1981-12-03 ,10,7934,MILLER,1982-01-23

mysql 表结构 create table emp ( EMPNO int primary key, ENAME varchar(10) , JOB varchar(9) , MGR double , HIREDATE date , SAL double , COMM double , DEPTNO int...

首先在Options类里加入jobId属性，然后在JobGraphUtil类的buildJobGraph方法修改调用 createJobGraph的方式 JobGraph jobGraph = null; if (StringUtils.isNullOrWhitespaceOnly(launcherOptions.getJobId())){ // use the jobId generated by flink when jobId is empty jobGraph = PackagedProgramUtils.createJobGraph( program, launcherOptions.loadFlinkConfiguration(), flinkConf.getInteger(DEFAULT_PARALLELISM), false); }else{ // use the...

protected ISerializationConverter

好的，我正在学习提pr，等我搞明白了 ，把之前所有遇到的bug或需求 都提下 ------------------ 原始邮件 ------------------ 发件人: "DTStack/chunjun" ***@***.***>; 发送时间: 2022年5月18日(星期三) 中午11:17 ***@***.***>; ***@***.******@***.***>; 主题: Re: [DTStack/chunjun] 写入数据到sftp的时候，报错了 (Issue #811) 可以提交一个pr，之后我们一起看下。 — Reply to this email directly, view it on GitHub, or unsubscribe. You...

好的 ------------------ 原始邮件 ------------------ 发件人: "DTStack/chunjun" ***@***.***>; 发送时间: 2022年5月18日(星期三) 中午11:37 ***@***.***>; ***@***.******@***.***>; 主题: Re: [DTStack/chunjun] 写入数据到sftp的时候，报错了 (Issue #811) 可以看下这份文档 https://dtstack.github.io/chunjun-web/docs/chunjunDocs/contribute-pr — Reply to this email directly, view it on GitHub, or unsubscribe. You are...