百岁

今天试验了一下，可以重现这个错误 ``` shell 2022-07-15 17:40:17 java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer at org.apache.flink.table.data.GenericRowData.getInt(GenericRowData.java:149) at org.apache.flink.table.data.RowData.lambda$createFieldGetter$245ca7d1$6(RowData.java:245) at org.apache.flink.table.runtime.typeutils.RowDataSerializer.copyRowData(RowDataSerializer.java:170) at org.apache.flink.table.runtime.typeutils.RowDataSerializer.copy(RowDataSerializer.java:131) at org.apache.flink.table.runtime.typeutils.RowDataSerializer.copy(RowDataSerializer.java:48) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:69) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26) at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)...

修改： 问题定位到是因为`id` 使用了unsigned修饰符，导致debezium在接收到数据使用long类型就行封装，而metadata解析结果却是int，导致该异常产生。解决办法是是在meta解析之后判断data_type中是否有unsigned修饰符，如果有则将数据类型改成bigint类型即可：[MySQLDataSourceFactory.java#L94](https://github.com/qlangtech/plugins/blob/e5ae5cb01298f2c2964709bde85ce4ce4d9a5c35/tis-datax/tis-ds-mysql-plugin/src/main/java/com/qlangtech/tis/plugin/ds/mysql/MySQLDataSourceFactory.java#L94)

收到

AddAppAction.isAppNameValid() 方法中修改一下使用 ```java return Validator.identity.validate(msgHandler, context, fieldKey, form.getProjectName()); ```

不能放开这个限制，否则在增量脚本编译过程中会，由于会由名称映射成java类名导致编译不通过

这属于扩展功能，后续会加

兄弟 把日志贴一下呗

收到，这个会优化的

当服务端开启kerberos认证之后，客户端如果没有提交kerberos认证需要的相关信息，会报以下错误 ``` Caused by: java.lang.RuntimeException: link faild:hdfs://xxxxx:8020/ at com.qlangtech.tis.hdfs.impl.HdfsFileSystemFactory$HdfsUtils.getFileSystem(HdfsFileSystemFactory.java:231) at com.qlangtech.tis.hdfs.impl.HdfsFileSystemFactory.getFileSystem(HdfsFileSystemFactory.java:93) at com.qlangtech.tis.plugin.datax.hudi.DataXHudiWriter.getFileSystem(DataXHudiWriter.java:95) at com.qlangtech.tis.plugins.incr.flink.connector.hudi.streamscript.StreamAPIStyleFlinkStreamScriptCreator$HudiStreamTemplateData.createStreamerConfig(StreamAPIStyleFlinkStreamScriptCreator.java:99) at com.qlangtech.tis.plugins.incr.flink.connector.hudi.streamscript.StreamAPIStyleFlinkStreamScriptCreator$HudiStreamTemplateData.getFlinkStreamerConfig(StreamAPIStyleFlinkStreamScriptCreator.java:85) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.velocity.util.introspection.UberspectImpl$VelMethodImpl.doInvoke(UberspectImpl.java:571) at org.apache.velocity.util.introspection.UberspectImpl$VelMethodImpl.invoke(UberspectImpl.java:554)...

使用nodeport的方式 https://blog.csdn.net/u011943534/article/details/100072981