[Bug] fix scala/java udf compiler, add error messages, clear cached classes before publish #4049
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(cherry picked from commit ac8bc5630b934904db702c8d1d52ecc985f642c7)
…d classes before publish or offline
github-actions
bot
requested review from
aiwenmo,
gaoyan1998,
zackyoungh and
Zzm0809
|
Thank you very much for your contribution. Since there are many features in this PR, it is difficult to review. You can keep this PR and then open a new PR for each small feature. This is beneficial for review and code merging. Looking forward to your PR. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
UDF
1.1 UDF编译无法找到org.apache.flink.table.functions.ScalarFunction类型
1.2 启动多个DINKY服务，在其它服务中已发或已下线UDF存在BUG。启动编译报错后服务停止，应该修改静默打印错误日志即可
1.3 前端发布应该可以查看UDF编译错误原因，而非查看服务日志
fink 1.20 scala 依赖冲突
修复taskId 为 null，ClearJobHistoryHandler BUG
增加metadata ：达梦dm, 金仓kingbase, trino
增加ltpa token校验
增加 任务返回列的列信息
优化org.dinky.cdc.convert.DataTypeConverter#getLogicalType，使用column.getJavaType() 会出现与自动生成flink类型不匹配