shaolei7788

binlog同步到别的mysql数据库时，当table内容为[ "*"]时，会报database.*没权限 解决办法：修改 BinlogUtil#checkTablesPrivilege 方法 if (CollectionUtils.isNotEmpty(tables)) 改为 if (CollectionUtils.isNotEmpty(tables) && !"*".equals(tables.get(0)))

读取ftp数据的时候会报错

4

读取ftp数据的时候，FtpSourceFactory#createSource，ftpConfig.setColumn 每个FieldConf的index为null，会导致FtpInputFormat#nextRecordInternal 里的分支永远不会执行， 需要修改一下 将图1的图片改为 ftpConfig.setColumn(syncConf.getReader().getFieldList());

读取mysql数据写到hbase时报异常

3

mysql表字段是int类型 在jdbc阶段转为BigDecimalColumn ，但是在hbase写入阶段又没有对应的类型，就会抛异常

自定义flink jobId

2

为了防止重复提交作业，如果提交任务传如果提入了jobId并且长度为32位那么就使用该jobId作为flink任务运行的jobId。 如果没传入jobId，那么就使用flink自己生成的jobId 关联的issue是 758

写入数据到sftp的时候，报错了

6

写入数据到sftp的时候，FtpColumnConverter#toExternal 方法，List columnData = new ArrayList(ftpConfig.getColumn().size()); 当RowData 第一个元素为null时，再去调用columnData.set方法会报错 解决办法： List columnData = new ArrayList(ftpConfig.getColumn().size()); 改成 List columnData = Arrays.asList(new String[ftpConfig.getColumn().size()]); 然后修改 FtpColumnConverter#createExternalConverter方法 将list.add改成 list.set

自定义flink jobId，如果传了jobId 就用指定的jobId,如果没传就使用flink自动生成的jobId

1

自定义flink jobId，如果传了jobId 就用指定的jobId,如果没传就使用flink自动生成的jobId

Unable to display complete file directory When mounting OBS

3

**Alluxio Version:** What version of Alluxio are you using? 2.9.0 **Describe the bug** A clear and concise description of what the bug is. Unable to display complete file directory ...

Finish proxy s3 authorize

3

### What changes are proposed in this pull request? Proxy server doesn't support authentication, it may cause security issues. I implement Authenticator Interface to check accessKey, it will improve proxy...