FlinkSQL 是通FlinkSQL 是通过怎样的机制找到要执行的 Java 代码的呢?Flink

比如: CREATE TABLE my_table ( id BIGINT, first_name STRING, last_name STRING, email STRING ) WITH ( 'connector'='kafka', 'topic'='user_topic', 'properti...

flink建议用scala还是java开发?#Flink

flink建议用scala还是java开发?#Flink

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink1.11线上环境报错; java.lang.IllegalStateExce #Flink

Flink1.11线上环境报错; java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute. 代码有调用 tableEnv.execute(""), 并且idea本地跑着正常...

java.lang.ClassNotFoundException: org.apach#Flink

java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.ExecutorBase这是哪个jar啊? #Flink

Flink使用java的基础类型如int和string.和使用原生的IntValue #Flink

Flink使用java的基础类型如int和string.和使用原生的IntValue和StringValue序列化方式一样吗?效率相比如何? #Flink

大佬们请问在在运行程序的时候出现 Error:(25, 17) java: 程序 #Flink

大佬们请问在在运行程序的时候出现 Error:(25, 17) java: 程序包org.slf4j不存在 但是能找到啊!咋解决哦? #Flink

那位大神,给一个java版的flink1.7 读取kafka数据,做实时监控和统计的功能的代码案例。

那位大神,给一个java版的flink1.7 读取kafka数据,做实时监控和统计的功能的代码案例。网上的URL也行,谢谢! 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

请问一下各位大佬,java 写的flink程序提交到yarn集群,application name都

请问一下各位大佬,java 写的flink程序提交到yarn集群,application name都是flink session cluster,多个程序运行的话,难以分辨,如何在代码里指定application的名字呢?多谢多谢啦 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点...

用java api写的kafka consumer能消费到的消息,但是Flink消费不到,这是为啥?

用java api写的kafka consumer能消费到的消息,但是Flink消费不到,这是为啥? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

java能不能直接远程操作flink sql

转自钉钉群21789141:java能不能直接远程操作flink sql

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

产品推荐

热门帮助文档

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载