塔塔塔塔塔塔_个人页

2021年12月

• 12.02 17:56:28
  提交了问题 2021-12-02 17:56:28

  Flink 1.10执行tpc-ds求助

• 12.02 17:56:07
  提交了问题 2021-12-02 17:56:07

  insert overwrite 问题

• 12.02 17:55:42
  提交了问题 2021-12-02 17:55:42

  【checkpoint】请问一下flink 支持把checkpoint 输出到外部的hdfs 吗？

• 12.02 17:55:20
  提交了问题 2021-12-02 17:55:20

  使用Flink 1.10 blink planner写ES的异常问题

• 12.02 17:54:57
  提交了问题 2021-12-02 17:54:57

  如何通过代码修改taskmanager.memory.network配置？

• 12.02 17:54:33
  提交了问题 2021-12-02 17:54:33

  flink1.10 yarn模式为什么无法提交作业？

• 12.02 17:54:02
  提交了问题 2021-12-02 17:54:02

  Flink Sql中Kafka-Source怎么获取Key值？

• 12.02 17:53:40
  提交了问题 2021-12-02 17:53:40

  Upload the Flink Python API 1.9.x to PyPI for user

• 12.02 17:53:08
  提交了问题 2021-12-02 17:53:08

  ProcessWindowFunction中如何有效清除state呢

• 12.02 17:52:24
  提交了问题 2021-12-02 17:52:24

  Question about the flink 1.6 memory config？

• 12.02 17:51:41
  提交了问题 2021-12-02 17:51:41

  kafka-per-partition 的watermark的分配，可以在keyby之后分配吗？

• 12.02 17:51:14
  提交了问题 2021-12-02 17:51:14

  Flink SQL中动态嵌套字段如何定义DDL

• 12.02 17:50:46
  提交了问题 2021-12-02 17:50:46

  如何实现 KafkaUpsertTableSink？

• 12.02 17:50:23
  提交了问题 2021-12-02 17:50:23

  flink savepoint问题

• 12.02 17:49:51
  提交了问题 2021-12-02 17:49:51

  Flink1.10执行sql超出内存限制被yarn杀掉怎么解决？

• 12.02 17:49:24
  提交了问题 2021-12-02 17:49:24

  RocksDBStateBackend In background 状态清理机制的问题

• 12.02 17:42:07
  回答了问题 2021-12-02 17:42:07

  flinksql如何控制结果输出的频率

  赞0 踩0 评论0
• 12.02 17:41:49
  回答了问题 2021-12-02 17:41:49

  flink 1.9 状态后端为FsStateBackend，修改checkpoint时出现警告

  赞0 踩0 评论0
• 12.02 17:41:05
  回答了问题 2021-12-02 17:41:05

  在Flink SQL的JDBC Connector中，Oracle的TIMESTAMP字段类型转换？

  赞0 踩0 评论0
• 12.02 17:40:48
  回答了问题 2021-12-02 17:40:48

  flink 安装包的几个 jar 是怎么 build 出来的？

  赞0 踩0 评论0
• 12.02 17:40:28
  回答了问题 2021-12-02 17:40:28

  Flink JDBC Driver是否支持创建流数据表

  赞0 踩0 评论0
• 12.02 17:39:10
  回答了问题 2021-12-02 17:39:10

  Flink 1.10 JSON 解析

  赞0 踩0 评论0
• 12.02 17:38:53
  回答了问题 2021-12-02 17:38:53

  关于flink sql 1.10 source并行度自动推断的疑问

  赞0 踩0 评论0
• 12.02 17:38:38
  回答了问题 2021-12-02 17:38:38

  关于 SQL DATE_FORMAT 的时区设置的构想

  赞0 踩0 评论0
• 12.02 17:38:12
  回答了问题 2021-12-02 17:38:12

  ddl es 报错怎么办？

  赞0 踩0 评论0
• 12.02 17:37:35
  回答了问题 2021-12-02 17:37:35

  flinksql创建源表添加水位线失败如何处理？

  赞0 踩0 评论0
• 12.02 17:37:08
  回答了问题 2021-12-02 17:37:08

  关于sql-gateway insert into 异常捕获的问题

  赞0 踩0 评论0
• 12.02 17:36:49
  回答了问题 2021-12-02 17:36:49

  如何提升任务cpu使用率

  赞0 踩0 评论0
• 12.02 17:36:30
  回答了问题 2021-12-02 17:36:30

  Flink on YARN 使用Kerboros认证失败

  赞0 踩0 评论0
• 12.02 15:34:44
  回答了问题 2021-12-02 15:34:44

  能否使用命令行的 -C 命令 加载 flink sql 的 connector?

  赞0 踩0 评论0
• 12.02 15:25:06
  提交了问题 2021-12-02 15:25:06

  flink系统配置中的io.tmp.dirs里的文件自动清理机制是什么？

• 12.02 15:24:49
  提交了问题 2021-12-02 15:24:49

  如何 Flink 通过不同的hive_catalog，访问离线和实时两套集群的hive？

• 12.02 15:24:27
  提交了问题 2021-12-02 15:24:27

  基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中？

• 12.02 15:19:23
  提交了问题 2021-12-02 15:19:23

  Flink 从checkpoint恢复时，部分状态没有正确恢复

• 12.02 15:19:05
  提交了问题 2021-12-02 15:19:05

  flink在keyby后，如何知道某个key落在下游的哪个task中？

• 12.02 15:18:39
  提交了问题 2021-12-02 15:18:39

  flink run -d -m yarn-cluster 提交任务到yarn集群不成功怎么办

• 12.02 15:18:19
  提交了问题 2021-12-02 15:18:19

  是否可以自定义trigger实现event time window的分散触发

• 12.02 15:18:01
  提交了问题 2021-12-02 15:18:01

  flink 版本视图不触发水印导致流阻塞怎么办？

• 12.02 15:17:32
  提交了问题 2021-12-02 15:17:32

  flink dataset api join报错怎么办？

• 12.02 15:17:15
  提交了问题 2021-12-02 15:17:15

  为什么flink1.13.1 webUI火焰图获取失败？

• 12.02 15:16:59
  提交了问题 2021-12-02 15:16:59

  flinksql 流维join 问题？

• 12.02 15:15:39
  提交了问题 2021-12-02 15:15:39

  Flink SQL MYSQL schema 特性问题？

• 12.02 15:15:19
  提交了问题 2021-12-02 15:15:19

  如何将canal json格式数据按操作类型过滤？

• 12.02 15:14:39
  提交了问题 2021-12-02 15:14:39

  关于任务运行一定时间后，physical内存超出，container被kill,导致任务重启怎么办？

• 12.02 15:14:21
  提交了问题 2021-12-02 15:14:21

  如何从复杂的kafka消息体定义 table？

• 12.02 15:14:05
  提交了问题 2021-12-02 15:14:05

  关于服务器参数设置请教

• 12.02 15:13:15
  提交了问题 2021-12-02 15:13:15

  flink批作业需要哪些配置？

• 12.02 15:13:01
  提交了问题 2021-12-02 15:13:01

  flink作业日志能否保存到oss？

• 12.02 15:12:38
  提交了问题 2021-12-02 15:12:38

  flink on native k8s要如何动态改变日志配置？

• 12.02 15:11:10
  回答了问题 2021-12-02 15:11:10

  Flink1.13.1自定义Catalog问题出错怎么解决？

  赞0 踩0 评论0