雪哥哥_个人页

2021年12月

• 12.06 21:47:50
  回答了问题 2021-12-06 21:47:50

  checkpoint是否可以转化为savepoint

  赞0 踩0 评论0
• 12.06 21:47:34
  回答了问题 2021-12-06 21:47:34

  flink 用这个命令申请的应该是 2个slot

  赞0 踩0 评论0
• 12.06 21:47:12
  回答了问题 2021-12-06 21:47:12

  UDF 怎么根据不同的参数返回不同的类型？

  赞0 踩0 评论0
• 12.06 21:46:52
  回答了问题 2021-12-06 21:46:52

  Flink State 增加字段后 state 还能识别吗？

  赞0 踩0 评论0
• 12.06 21:46:33
  回答了问题 2021-12-06 21:46:33

  请问 StreamingFileSink如何写数据到其它HA的Hadoop集群

  赞0 踩0 评论0
• 12.06 21:46:10
  回答了问题 2021-12-06 21:46:10

  Flink新出的OrcBulkWriterFactory有没有大佬给个详细的Demo？

  赞0 踩0 评论0
• 12.06 21:45:46
  回答了问题 2021-12-06 21:45:46

  请教个问题，流sql如果要group by 只能配合窗口吗？

  赞0 踩0 评论0
• 12.06 21:45:28
  回答了问题 2021-12-06 21:45:28

  FlinkSQL新增operatoer后基于savepoint重启报错怎么办？

  赞0 踩0 评论0
• 12.06 21:45:06
  回答了问题 2021-12-06 21:45:06

  flink如何传递全局变量？

  赞0 踩0 评论0
• 12.06 21:44:35
  回答了问题 2021-12-06 21:44:35

  TTL 支不支持自然日怎么办？

  赞0 踩0 评论0
• 12.06 21:44:12
  回答了问题 2021-12-06 21:44:12

  程序里面设置了状态失效最晚时间是空闲25分钟，但是运行了几天了还是不理想

  赞0 踩0 评论0
• 12.06 21:43:50
  回答了问题 2021-12-06 21:43:50

  数据流经过flatmap后并不是返回一个keyedstream ,请问是哪里有问题吗？

  赞0 踩0 评论0
• 12.06 21:43:22
  回答了问题 2021-12-06 21:43:22

  Flink SQL 作业, 开始运行正常, checkpoint也正常, 执行一段时间后,开始报错,

  赞0 踩0 评论0
• 12.06 21:42:58
  回答了问题 2021-12-06 21:42:58

  有没有啥办法，可以直接从table_ddl中取最新的kafka数据呢？

  赞0 踩0 评论0
• 12.06 21:42:37
  回答了问题 2021-12-06 21:42:37

  假设两个算子以相同的字段keyby，它们可以使用相同的StateDescriptor

  赞0 踩0 评论0
• 12.06 21:42:16
  回答了问题 2021-12-06 21:42:16

  flink分为jobmanger和taskmanager，我怎么区分哪些代码是运行

  赞0 踩0 评论0
• 12.06 21:41:53
  回答了问题 2021-12-06 21:41:53

  在使用flink sql ddl语句向hbase中写的时候出现报错怎么解决？

  赞0 踩0 评论0
• 12.06 21:41:30
  回答了问题 2021-12-06 21:41:30

  flink任务checkpoint无法完成snapshot，且报kafka异常怎么回事？

  赞0 踩0 评论0
• 12.06 21:40:58
  回答了问题 2021-12-06 21:40:58

  请问kafka connector ddl能不能像flinkKafkaConsumer.setSta

  赞0 踩0 评论0
• 12.06 21:40:07
  回答了问题 2021-12-06 21:40:07

  简单插数etl, 基本的过滤, 窗口. 请问还有没有什么定性定量的方式可以测量框架性能?

  赞0 踩0 评论0
• 12.06 21:39:47
  回答了问题 2021-12-06 21:39:47

  请问该如何使用DataStreamUtils.reinterpretasKeyedStream？

  赞0 踩0 评论0
• 12.06 21:39:05
  回答了问题 2021-12-06 21:39:05

  Flink希望开发者怎么处理程序的异常？

  赞0 踩0 评论0
• 12.06 21:38:43
  回答了问题 2021-12-06 21:38:43

  flink sql 怎样将从hbase中取出的BYTES类型转换成Int？

  赞0 踩0 评论0
• 12.06 21:38:20
  回答了问题 2021-12-06 21:38:20

  如何做Flink Stream的性能测试？

  赞0 踩0 评论0
• 12.06 21:37:59
  回答了问题 2021-12-06 21:37:59

  动态 Table 属性是指什么？

  赞0 踩0 评论0
• 12.06 21:30:04
  回答了问题 2021-12-06 21:30:04

  flink sql job 提交到yarn上报错怎么办？

  赞0 踩0 评论0
• 12.06 21:29:35
  回答了问题 2021-12-06 21:29:35

  目前我们在调研checkpoint 跨机房容灾的方案

  赞0 踩0 评论0
• 12.06 21:28:38
  回答了问题 2021-12-06 21:28:38

  采用异步io的方式从hbase获取信息，发现hbase上游背压很高。有没有什么建议或者好的方式？

  赞0 踩0 评论0
• 12.06 21:28:10
  回答了问题 2021-12-06 21:28:10

  维表被频繁更新，数据量1g左右，需要频繁同步，使用什么方案去关联比较好呢？

  赞0 踩0 评论0
• 12.06 21:27:45
  回答了问题 2021-12-06 21:27:45

  如何使用Kafka来传递状态？

  赞0 踩0 评论0
• 12.06 21:27:13
  回答了问题 2021-12-06 21:27:13

  flink sql 中怎么把ROW类型转换成INT？

  赞0 踩0 评论0
• 12.06 21:26:50
  回答了问题 2021-12-06 21:26:50

  flink sql sink mysql requires primary keys？

  赞0 踩0 评论0
• 12.06 21:26:11
  回答了问题 2021-12-06 21:26:11

  state backend不是根据配置选择对应的工厂创建出来的吗，这部分是如何限定的？

  赞0 踩0 评论0
• 12.06 21:25:44
  回答了问题 2021-12-06 21:25:44

  关于多个来源，如何保证数据对齐？

  赞0 踩0 评论0
• 12.06 21:25:22
  回答了问题 2021-12-06 21:25:22

  env.readFile 递归监控目录 如何清理状态（历史目录）？

  赞0 踩0 评论0
• 12.06 21:24:54
  回答了问题 2021-12-06 21:24:54

  flink sql 窗口有没有方式可以直接实时输出结果？

  赞0 踩0 评论0
• 12.06 21:24:30
  回答了问题 2021-12-06 21:24:30

  flink1.10.1 SQL 作业 netty报错如何解决？

  赞0 踩0 评论0
• 12.06 21:23:59
  回答了问题 2021-12-06 21:23:59

  flink1.7.2-JDBCAppendTableSink,如何按间隔时间写入数据？

  赞37 踩0 评论0
• 12.06 21:23:30
  回答了问题 2021-12-06 21:23:30

  sqlclient集成hiveCatalog查询kafka表报错如何解决？

  赞0 踩0 评论0
• 12.06 21:23:01
  回答了问题 2021-12-06 21:23:01

  flink 1.10 on yarn 内存超用，被kill怎么办？

  赞0 踩0 评论0
• 12.06 21:22:39
  回答了问题 2021-12-06 21:22:39

  目前Flink 提供了Tuple1 ~ Tuple25，在实际开发中不能满足我们的需求

  赞0 踩0 评论0
• 12.06 21:22:11
  回答了问题 2021-12-06 21:22:11

  Flink SQL 1.10.0窗口计算结果无法sink怎么办？

  赞0 踩0 评论0
• 12.06 21:21:49
  回答了问题 2021-12-06 21:21:49

  我的flink和zookeeper都是在K8s的容器中，但job启动却出现了问题，有谁能帮忙解决一下

  赞0 踩0 评论0
• 12.06 21:21:28
  回答了问题 2021-12-06 21:21:28

  大家的在线任务会在晚上重跑一次做校正吗？

  赞0 踩0 评论0
• 12.06 21:20:57
  回答了问题 2021-12-06 21:20:57

  pyflink的table api 能否根据 filed的值进行判断插入到不同的sink表中 ？

  赞0 踩0 评论0
• 12.06 21:20:32
  回答了问题 2021-12-06 21:20:32

  请教 yarn-session.sh启动任务指定的应用名和队列无效怎么办？

  赞0 踩0 评论0
• 12.06 21:20:07
  回答了问题 2021-12-06 21:20:07

  作业从savepoint启动，状态不一致是什么原因？

  赞0 踩0 评论0
• 12.06 21:19:24
  回答了问题 2021-12-06 21:19:24

  hdfs上 ha storage 目录还在，但里的文件没了是怎么回事？

  赞0 踩0 评论0
• 12.06 21:18:21
  回答了问题 2021-12-06 21:18:21

  维表join不支持事件时间窗口级联怎么解决？

  赞0 踩0 评论0