【百问百答】flink全知道系列4-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

【百问百答】flink全知道系列4

2021-12-24 16:08:12 1425 0

flink 相关问题整理如下。可以Ctrl+F检索关键词进行查找,本合集持续更新中,记得关注、收藏哦

【百问百答】flink全知道系列1

【百问百答】flink全知道系列2

【百问百答】flink全知道系列3

flink 1.11 rest api saveppoint接口 异常

flink消费kafka提交偏移量

StatementSet 里添加多个insertsql执行

关于window过程中barrier的问题

flink1.11 可以使用processtime开窗,但是无法使用eventtime开窗

flink1.11 sql 发布到yarn session时找不到hbase相关的类

flink on yarn 读取 hbase数据时 ,Task失败,具体描述如下

flink-1.11 hive-1.2.1 ddl 无法写入数据

Flink SQL 解析复杂(嵌套)JSON的问题 以及写入到hive类型映射问题

flink1.11.0 执行sqlQuery时报NullPointException

kafka-connect json格式适配问题?

Blink的Batch模式的并行度问题

Could not find any factory for identifier 'kafka'

flink 聚合 job 重启问题

【flink sql】flink sql insert into插入语句的问题

Flink CPU利用率低

flink sql 读取mysql

flink解析kafka json数据

自定义metr自定义metrics reporter 如何不通过flink conf来注册并生效ics reporter 如何不通过flink conf来注册并生效

flink1.11查询结果每秒入库到mysql数量很少

flink 1.11 cdc相关问题

flink 1.11 ddl 写mysql的问题

flink row 类型

flink sql 1.11 kafka source with子句使用新参数,下游消费不到数据

flink1.11 tablefunction

flink1.11 web ui没有DAG

flink stream如何为每条数据生成自增主键

flink 1.9.2 升级 1.10.0 任务失败不能从checkpoint恢复

flink 1.11 使用sql写入hdfs无法自动提交分区

flink1.11 sql

flink 1.11 on kubernetes 构建失败…

flinksql1.11中主键声明的问题

flink1.11启动问题

关于1.11Flink SQL 全新API设计的一些问题,请指教

关于1.11Flink SQL 全新API设计的一些问题

Flink catalog的几个疑问

flink-1.11 ddl kafka-to-hive问题

FlinkKafkaConsumer API 维表关联

Flink sql中可以使用自定义窗口触发器吗

flink 1.11 cdc: kafka中存了canal-json格式的多张表信息,需要按表解析做处理,sink至不同的下游,要怎么支持?

SQL 报错只有 flink runtime 的 NPE

[sql-client] 如何绕过交互式模式去做ddl

flink table同时作为写出及输入时下游无数据

flink 1.11 on k8s native session cluster模式报找不到configmap

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

flink 1.11 sql类型问题

connector hive依赖冲突

flink1.11 pyflink stream job 退出

官方pyflink 例子的执行问题

Flink整合hive之后,通过flink创建的表,hive beeline可见表,不可见字段?

Flink Cli 部署问题

flink1.11 run

Re: pyflink1.11.0window

flink1.11写hive

Flink on k8s 中,Jar 任务 avatica-core 依赖和 flink-table jar 冲突问题

flink-1.11 KafkaDynamicTableSouce groupBy 结果怎样发送到 kafka

FlinkSQL 任务提交后 任务名称问题

state无法从checkpoint中恢复

sql 内嵌josn数组解析报 类型转换报错

flink不带参数的udf始终返回第一次调用的结果

flink-1.11 ddl 写入json 格式数据到hdfs问题

flink 1.11 checkpoint使用

flink 1.11任务提交的问题

flink1.9写权限认证的es6,哪位大佬帮忙解答一下

flink state问题,这是为什么啊

[sql-client] 通过sql-client提交sql怎么设置checkpointing.interval

flink1.11 set yarn slots failed?

Flink-1.11内置connector测试问题求解!

flink 1.11 upsert结果出错,怎么回事?

flink1.11 sql kafka 抽取事件时间,有没有好的方式

滑动窗口数据存储多份问题?

flink 双流join报错

自定义的sql connector在sql-cli中运行问题,如何结局?

flink-1.11 DDL 设置chk目录问题,怎么回事?

flink1.11.0读取mysql数据decimal类型会强转成decimal(38,18)的问题?

不能实时读取实时写入到 Hive 的数据,如何结局?

flink cep 如何处理超时事件

flink 1.11运算结果存mysql出错,怎么解决啊

flink on yarn日志问题

[flink-sql] 如何在sql运行时动态修改kafka的scan.startup.mode

flink-1.11使用executeSql()执行DDL语句问题,请大佬赐教

flink-benchmarks使用求助?

代码中如何取消正在运行的Flink Streaming作业?

State 0点清除的问题?

flink1.9状态及作业迁移,还有哪些其他需要注意的问题?

Flink SQL处理Array型的JSON?

flink 同时sink hbase和hive,hbase少记录,怎么回事?

Flink Join内存问题

flink 1.11 createTemporaryTable 指定 rowtime 字段报 Field null does not exist 错误?

单流的一条数据,需要先sink 至mysql,再sink至kafka,并保证两sink的原子性以及sink顺序,是否可以做到

flink sql报错 Could not find any factory for identifier 'kafka'

使用Flink Array Field Type,请问这是Flink1.10的bug吗?

flink 1.11 es未定义pk的sink问题?

Table options do not contain an option key 'connector' for discovering a connector.

flink使用debezium-json format报错,大佬帮忙看下

flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark,怎么解决

flink sql 侧输出,api中要怎么操作比较合理一点?或者有没有其他处理延迟数据的方式?

flink 1.11 sql作业提交JM报错,是不是不推荐在作业里同时使用executeSQL和statementset.execute?

flink 1.11 local execution oom问题,求指教

flink1.10.1在yarn上无法写入kafka的问题

一个source多个sink的同步问题,怎么回事?

Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常,大佬帮忙指教下

flink-state问题

flink kafka connector中获取kafka元数据

flink sql 读写写kafka表的时候可以指定消息的key吗?

DataStream的state问题,怎么回事

关于jdbc connector扩展问题,该怎么弄?

Flink从SavePoint启动任务,修改的代码不生效?

flink sql子查询状态清理不掉

Flink状态调试,求支招

取消 提交回答
全部回答(0)
相关问答

5

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 129557浏览量 回答数 5

38

回答

阿里官方Java代码规范标准《阿里巴巴Java开发手册》下载

管理贝贝 2017-02-10 15:14:36 79490浏览量 回答数 38

2

回答

Blink计算引擎 【精品问答集锦】

管理贝贝 2016-07-21 17:03:19 29356浏览量 回答数 2

3

回答

Kafka、ActiveMQ、RabbitMQ、RocketMQ的区别?【Java问答学堂】19期

剑曼红尘 2020-05-15 11:24:19 37196浏览量 回答数 3

1

回答

在flink集群模式下,能不能指定某个节点的solt来执行一个task?

孙goku 2019-07-01 15:19:09 116630浏览量 回答数 1

8

回答

flink sql 支持checkpoints吗?

游客izljdlkgbdwfc 2019-07-10 17:46:37 125738浏览量 回答数 8

2

回答

云效平台——基于jmeter的轻量级性能测试平台

云效平台 2016-06-08 11:27:28 29809浏览量 回答数 2

10

回答

【6.27更新】你不能错过的:阿里中间件性能挑战赛重要学习资料

凝岚 2016-04-16 15:26:05 33289浏览量 回答数 10

2

回答

Apache Flink常见问题汇总【精品问答】

黄一刀 2020-05-19 17:51:47 51088浏览量 回答数 2

56

回答

Flink Forward Asia 2021 有奖问答

阿里云实时计算Flink 2021-12-29 17:30:44 468904浏览量 回答数 56
1482
文章
343
问答
问答排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载