好嘞~那我直接粘一下
1. FlinkSQL代码
CREATE TEMPORARY VIEW IF NOT EXISTS rt_view AS
SELECT user_id
, run_duration_3km_prediction
, run_duration_5km_prediction
, run_duration_10km_prediction
, run_duration_21km_prediction
, run_duration_42km_prediction
, LEAST(run_duration_3km_prediction/ 3,
邮件里无法加载图片
guifeng huang 于2023年8月21日周一 11:08写道：
>
> 因为是在流里, 我不太清楚如何给您复现的用例比较合适, 因为把数据单独拿出来, 返回结果又是正常的...
> 以下我把我的FlinkSQL代码和输出结果贴图一下(您看下是否OK)
> *FlinkSQL代码*
> 视图tmp_view是我从日志里过滤的数据, 整体业务逻辑比较简单就是lactate_threshold_pace这个是从下面5个指标里取一个最小值
> (
>
Hi,
方便提供一下复现的用例吗?
Best,
Jiabao
On 2023/08/21 02:19:53 guifeng huang wrote:
> (Flink1.15版本)
> 咨询求助: Least函数输入参数(Double类型)正常, 在Flink shell里测试函数无问题, 结果符合预期.
> 但是实际生产流里进行使用的时候发现返回结果有异, 以下是3种case
> - 返回结果正确, 符合预期
> - 返回0, 不符合预期, 未知原因
> - 返回结果和理论正确值有微小的gap, 找了几个case都是1位数值里的差距.
> 看看有没有其他的老师遇到过同样的问题
> 在 2021年1月31日，20:15，Appleyuchi 写道：
>
> 一点小小的建议哈，
> 目前flink社区讨论主要还是java/scala为主，
> 如果执意使用pyflink的话，后续极有可能会遇到较大的阻力．
我理解这种较大阻力应该不存在的，社区里pyflink的投入还挺大的，蛮多开发者的，我也cc两位在这块做贡献的社区开发者，从JIRA上看pyflink相关的开发进度都挺快的。
如果有机器学习，python相关的经验，用pyflink我觉得挺合适的。
祝好，
Leonard
一点小小的建议哈，
目前flink社区讨论主要还是java/scala为主，
如果执意使用pyflink的话，后续极有可能会遇到较大的阻力．
在 2021-01-31 14:26:55，"瞿叶奇" <389243...@qq.com> 写道：
>您好，我是国网陕西采集系统开发人员，我们在架构改造中，准备使用pyflink
>解决实时Kafka数据写HDFS的问题，我的Kafka集群存在kerberos安全认证，导致我现在还没连接上，能不能给一个样例呢？
hi,
根据文档[1][2]， 你可以通过在with参数内填相应的内容来通过认证, e.g
'properties.sasl.kerberos.service.name' = 'xyz'
[1]
https://kafka.apache.org/documentation/#brokerconfigs_sasl.kerberos.service.name
[2]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html#properties
瞿叶奇
