SQL 报错只有 flink runtime 的 NPE

我有这么一个 SQL INSERT INTO es SELECT a, udf_xxx(b) FROM mongo_oplog -- 自定义 TableFactory Job 提交后 fail 了,从 Job 提交到 Fail 只有一处来自非业务代码的 NPE 如下,没有任何业务代码 Excepti...

请问flink sql实时计算分位数如何实现哈?

你好:     目前flink sql实时计算中没有percentile函数吗?如果没有,如何实现这一功能。     期待你的答复,谢谢!*来自志愿者整理的flink邮件归档

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

生产hive sql 迁移flink 11 引擎,碰到的问题

最近尝试把一个生产 hive sql 任务,执行引擎切换成 flink 1.11.2 ,发现flink 11 对hive SQL的支持有下列问题1、不支持 双引号 表示字符串 2、不支持 != 表示不等运算 3、不支持 类型隐式转换 4、不支持 split 函数 5、hive 不区分大小写,flin...

flink sql 如何实时计算百分比

flink1.10.1,应该如何计算error_1006_cnt_permillage sql如下: SELECT | DATE_FORMAT(TIMESTAMPADD(HOUR, 8, TUMBLE_START(proctime, INTERVAL '10' SECOND)), 'yyyy-MM-...

flink sql实时计算分位数如何实现

    目前flink sql实时计算中没有percentile函数吗?如果没有,如何实现这一功能。     期待你的答复,谢谢! *来自志愿者整理的flink邮件归档

./sql-client.sh embedded 这种方式提交的flink任务怎么设置state以及

./sql-client.sh embedded 这种方式提交的flink任务怎么设置state以及checkpoint? 如题 还是只能把sql放在java里边,通过tableEnvironment.sqlQuery执行?*来自志愿者整理的flink邮件归档

flink sql 这种实时计算结果如何与离线计算的结果做数据比对?

有没有大佬有思路可以参考下?*来自志愿者整理的flink邮件归档

用下面表方法能执行成功并生成新表 但是用上面注释的sql方式代码运行没报错 最后code#Flink

用下面表方法能执行成功并生成新表 但是用上面注释的sql方式代码运行没报错 最后code 0结束 但是没生成新表 请问这是什么原因造成的?#Flink

求问这句sql哪里错了啊?#Flink

求问这句sql哪里错了啊?#Flink // call registered function in SQL Table result3=tEnv.sqlQuery("SELECT name, WeightedAvg(value, weight) FROM MyTable GROUP BY name...

请问用flink-sql写kafka发送Avro类型数据怎么定义avro schema的#Flink

请问用flink-sql写kafka发送Avro类型数据怎么定义avro schema的name和namespace? 我这边用下面的配置写Kafka,发现写入的avro类型没有namespace,name=record。有没有办法自定义namespace和name? 'topic' 'avro-c...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

热门帮助文档

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
阿里云流计算 Flink SQL 核心功能解密
Flink Streaming SQL 2018
立即下载 立即下载 立即下载

实时计算 Flink版sql相关内容