开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

Flink sql 主动使数据延时一段时间有什么方案?

Flink SQL 关键字 user

flink1.10 定义表时,把json数组声明成STRING类型的,查询出来是空?

Flink的shuffle mode,在应用里面可以设置么?

Flink job不定期就会重启,版本是1.9,怎么回事?

flink1.9读取阿里Mq问题?

table execution-options 能否通过 -yd 生效

flink1.10在通过TableFunction实现行转列时,Row一直是空?

rocksdb的block cache usage应该如何使用?

kafkaf To mysql 写入问题?

flink job 跑一段时间 watermark 不推进的问题

flink1.11 Application 模式下启动失败问题

flink sqlUpdate,如何获取里面的字段,字段类型,with 等3个属性

flink 1.11 executeSql查询kafka表print没有输出

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 sql 1.10 insert into tb select 复杂schema 失败

Flink1.10 flinksql 多表join状态ttl不成功的问题

TableEnvironment 里面无法执行 Hop等窗口函数

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

flink 双流join报错,java.lang.AssertionError

自定义的sql connector在sql-cli中运行问题

flink-1.11 DDL 设置chk目录问题

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

flink cep 如何处理超时事件?

flink 1.11运算结果存mysql出错

如何在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

flink 1.11 es未定义pk的sink问题

pyflink问题求助

flink使用debezium-json format报错

Flink es7 connector认证问题

flink sql 侧输出

flink 1.11 sql作业提交JM报错

flink 1.11 local execution oom问题

flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark

flink sql连接HBase报错

作业从flink1.9.0迁移到1.10.1

pyflink udf中发送rest api会导致udf被调用两次

flink1.10升级到flink1.11 提交到yarn失败

Flink DataStream 统计UV问题

flink时间窗口

kafka connector问题

ddl es 报错

DataStream统计uv问题

Flink SQL如何将多个表的查询结果(列不同)聚合成一张表

一个source多个sink的同步问题

Flink SQL复杂JSON解析

State里面用guava Cache

如何在Flink SQL中使用周期性水印?

flink 1.11 on kubernetes 构建失败

如何在窗口关闭的时候清除状态

flink 1.11 中cdc功能中,使用flink sql来操作一个kafka topic中的多张表,并保证有序?

flink 1.11 connector jdbc 依赖解析失败

求助:FLINKSQL1.10实时统计累计UV

flink 1.11 作业执行异常

FlinkKafkaProducer没有写入多个topic的功能

flink 1.10.1 入 hive 格式为parquet

作业升级到flink1.11,idea运行失败

嵌套 json 中string 数组的解析异常

【Flink的shuffle mode】

Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常……

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

DataStream的state问题

关于jdbc connector扩展问题

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

Flink状态调试

Flink sql 主动使数据延时一段时间有什么方案

Flink SQL 关键字 user?

flink1.10 定义表时,把json数组声明成STRING类型的,查询出来是空

flink1.10在通过TableFunction实现行转列时,Row一直是空

作业因为异常restart后,频繁OOM

Flink job不定期就会重启,版本是1.9

flink1.9读取阿里Mq问题

flink 1.10 kafka collector topic 配置pattern

kafkaf To mysql 写入问题

rocksdb的block cache usage应该如何使用

flink对task分配slot问题

做实时数仓,sql怎么保证分topic区有序

flink任务提交方式

flink的state过期设置

UDTAGGs sql的查询怎么写

想请教下MaxDirectMemorySize的大小有必要设置这么大吗?

StreamTableEnvironment.registerDatastream()

‘=-yD Kerberos 认证问题

slot询问

Flink1.9批任务yn和ys对任务的影响

source并行度不同导致任务没有数据落地

Flink 1.9 SQL Kafka Connector,Json format,how to deal with not json message?

Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题

Rewind offset to a previous position and ensure certainty.

关于 FLink historyserver没有completed-jobs的问题

展开
收起
开发者小助理 2021-12-27 17:30:03 3259 0
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载