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

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

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

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状态调试,求支招

展开
收起
开发者小助手 2021-12-24 16:08:12 2511 0
0 条回答
写回答
取消 提交回答

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

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