退订
dear all ：
有朋友遇到过编译flink 1.15 master 出现这个异常吗？
[ERROR] Failed to execute goal
org.apache.maven.plugins:maven-surefire-plugin:3.0.0-M5:test (default-test) on
project flink-runtime: There are test failures.
[ERROR]
[ERROR] Please refer to
Hi，Flink您好
我在集成Hive时，通过sql-client连接Hive成功，但在查询hive表时，总是提示以下错误，请问我该怎么办？
我的环境是CDH6.3.1，Flink1.13.2和1.14.2均尝试，按照官方指导一步步配置，均报相同错误。您的指导对我至关重要，期待您的回复，谢谢
2021-12-28 20:33:42,999 WARN
org.apache.flink.client.program.rest.RestClusterClient [] - Attempt to
submit job 'collect'
希望统计flink sql作业延迟，包括以下三个指标：
1. kafka消息延迟 (消息进到kafka时间 - 消息事件本身发生时间）
2. flink作业本身延迟 （消息处理完时间 - 消息开始处理时间）
3. 端到端延迟 （消息处理完时间 - 消息事件本身发生时间）
目前Flink 1.13.2是不是只能通过LatencyMarker获取到flink作业本身延迟? 开启的话会有性能影响吗？
据说Flink 1.14 新的source/sink api能够暴露一些metrics，但不清楚要具体怎么使用？谢谢！
@all
大家好：
关于Flink1.13中，TableEnvironment 和StreamTableEnvironment有一些疑惑：
1.TableEnvironment支持streaming和batch 模式，Flink1.13中TableEnvironment是否支持UDF和UDTF呢？
2.StreamTableEnvironment
目前只支持streaming模式？支持UDF和UDTF？能否在StreamTableEnvironment中以流的方式写批数据，批数据跑完进程就不存在了吧？
3.现在不是特别清楚真正的流批一体化体现在那个入口TableEnvironment
https://nightlies.apache.org/flink/flink-docs-release-1.8/dev/libs/ml/
Ada Wong 于2021年12月28日周二 13:52写道：
>
> 以前Flink官方有个机器学习库的文档，新版文档我发现已经没了
> https://github.com/apache/flink-ml
