毛毛虫雨_个人页

2021年12月

• 12.07 20:35:14
  回答了问题 2021-12-07 20:35:14

  KeyedCoProcessFunction中的状态数据是否存在资源竞争呢？

  赞0 踩0 评论0
• 12.07 20:34:41
  回答了问题 2021-12-07 20:34:41

  JDBC connector 写入 mysql 每秒大约只有 200KB 是正常的吗？

  赞0 踩0 评论0
• 12.07 20:34:20
  回答了问题 2021-12-07 20:34:20

  hive仅作为元数据管理，具体数据不存储在hdfs上

  赞0 踩0 评论0
• 12.07 20:33:41
  回答了问题 2021-12-07 20:33:41

  flink1.11启动后报这个错，然后任务就自己挂了是怎么回事？

  赞0 踩0 评论0
• 12.07 20:33:20
  回答了问题 2021-12-07 20:33:20

  flink 的-yt命令是不支持多个目录吗，而且只能上传到集群.jar文件吗？？？

  赞0 踩0 评论0
• 12.07 20:32:59
  回答了问题 2021-12-07 20:32:59

  flink orc与hive2.1.1版本冲突怎么解决？

  赞0 踩0 评论0
• 12.07 20:32:37
  回答了问题 2021-12-07 20:32:37

  如果声明为接口类型，如ListState<List<String>>,

  赞0 踩0 评论0
• 12.07 20:32:17
  回答了问题 2021-12-07 20:32:17

  taskmanager引用通用jdbc连接池，最大连接数是多少？

  赞0 踩0 评论0
• 12.07 20:31:57
  回答了问题 2021-12-07 20:31:57

  sql执行的这种模式，是否可以考虑添加job名称的设置呢？

  赞0 踩0 评论0
• 12.07 20:31:34
  回答了问题 2021-12-07 20:31:34

  通过表环境执行insert into语句提交作业，我该如何设置我的job名称呢？

  赞0 踩0 评论0
• 12.07 20:31:15
  回答了问题 2021-12-07 20:31:15

  flink 1.11.1 与HDP3.0.1中的hive集成，查询不出hive表数据怎么办？

  赞0 踩0 评论0
• 12.07 20:30:52
  回答了问题 2021-12-07 20:30:52

  关于flink 读取 jdbc报错详情，序列化报错怎么办？

  赞0 踩0 评论0
• 12.07 20:30:32
  回答了问题 2021-12-07 20:30:32

  开启了增量checkpoint，同时checkpoint的个数设置为只保留2个

  赞0 踩0 评论0
• 12.07 20:30:11
  回答了问题 2021-12-07 20:30:11

  SQL提交会出现这种问题？？？

  赞0 踩0 评论0
• 12.07 20:29:02
  回答了问题 2021-12-07 20:29:02

  debezium是通过jdbc查询源表的数据来加载全量的历史数据吗？

  赞0 踩0 评论0
• 12.07 20:28:38
  回答了问题 2021-12-07 20:28:38

  在*默认设置*下，能观察到本地flink使用的G1，但on yarn运行时出问题

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

  flink 1.10 如何监控 Managed memory 使用量？

  赞0 踩0 评论0
• 12.07 20:28:01
  回答了问题 2021-12-07 20:28:01

  hive-exec依赖导致hadoop冲突怎么解决？

  赞0 踩0 评论0
• 12.07 20:26:50
  回答了问题 2021-12-07 20:26:50

  请问flink的webui前端实现的源码在哪呀？

  赞0 踩0 评论0
• 12.07 20:26:27
  回答了问题 2021-12-07 20:26:27

  各位有知道怎样手动卸载么或者有使用HikariDataSource没问题的么

  赞0 踩0 评论0
• 12.07 20:26:07
  回答了问题 2021-12-07 20:26:07

  flink1.10中hive module 没有plus，greaterThan等函数是什么原因？

  赞0 踩0 评论0
• 12.07 20:25:49
  回答了问题 2021-12-07 20:25:49

  flink1.11单机执行slot出错怎么解决？

  赞0 踩0 评论0
• 12.07 20:25:27
  回答了问题 2021-12-07 20:25:27

  有没有可能使用tikv作为flink 分布式的backend？

  赞0 踩0 评论0
• 12.07 20:25:05
  回答了问题 2021-12-07 20:25:05

  Flink-1.11.1 Application-Mode提交测试报异常怎么解决？

  赞0 踩0 评论0
• 12.07 20:24:41
  回答了问题 2021-12-07 20:24:41

  我在使用flink sql-client链接hive metastore的时候，出问题

  赞0 踩0 评论0
• 12.07 20:24:24
  回答了问题 2021-12-07 20:24:24

  flink on yarn 的application模式怎么提交多个job组成应用程序呢？

  赞0 踩0 评论1
• 12.07 20:24:03
  回答了问题 2021-12-07 20:24:03

  flink on yarn经常报错怎么解决？

  赞0 踩0 评论0
• 12.07 20:23:41
  回答了问题 2021-12-07 20:23:41

  默认情况下offset会不会提交到kafka分区？

  赞0 踩0 评论0
• 12.07 20:23:19
  回答了问题 2021-12-07 20:23:19

  直接使用ddl定义kafka数据源出现了问题怎么办？

  赞0 踩0 评论0
• 12.07 20:22:57
  回答了问题 2021-12-07 20:22:57

  DDL中声明主键会报类型不匹配怎么解决？

  赞0 踩0 评论0
• 12.07 20:22:31
  回答了问题 2021-12-07 20:22:31

  在SQL中取值时能否能做到大小写不敏感呢？

  赞0 踩0 评论0
• 12.07 20:22:12
  回答了问题 2021-12-07 20:22:12

  流处理任务中checkpoint失败如何解决？

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

  sink失败 不消费kafka消息怎么办？

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

  Flink Kafka作业异常重启，从Checkpoint恢复后重复推送数据部分数据如何处理？

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

  ProcessWindowFunction为何在clear方法中无法清理状态呢？

  赞0 踩0 评论1
• 12.07 20:20:53
  回答了问题 2021-12-07 20:20:53

  Flink 维表延迟join是什么回事呢？

  赞0 踩0 评论0
• 12.07 20:20:25
  回答了问题 2021-12-07 20:20:25

  Source 定时执行sql，只执行一次就close了source怎么解决？

  赞0 踩0 评论0
• 12.07 20:20:08
  回答了问题 2021-12-07 20:20:08

  在单机的Linux下运行，过程是读取kafka，然后写入到mysql库中，出问题

  赞0 踩0 评论0
• 12.07 20:19:51
  回答了问题 2021-12-07 20:19:51

  如何tidb Binlog 整库同步到 hive？

  赞0 踩0 评论0
• 12.07 20:19:27
  回答了问题 2021-12-07 20:19:27

  我用idea本地运行的jdbc sink没有问题。但是在服务器上运行报错，怎么解决？

  赞2 踩0 评论0
• 12.07 20:19:09
  回答了问题 2021-12-07 20:19:09

  我有一个接kafka 写入tidb的任务 为什么会启动2个yarn任务去运行呢？

  赞0 踩0 评论0
• 12.07 20:18:45
  回答了问题 2021-12-07 20:18:45

  flink sql 计算列不支持comment怎么办？

  赞0 踩0 评论1
• 12.07 20:18:26
  回答了问题 2021-12-07 20:18:26

  实时计算累计UV时为什么使用MapState和BloomFilter,在checkpoint时出问题

  赞0 踩0 评论0
• 12.07 20:18:04
  回答了问题 2021-12-07 20:18:04

  flink1.11 流式读取hive怎么设置 process_time 和event_time?

  赞0 踩0 评论0
• 12.07 20:17:44
  回答了问题 2021-12-07 20:17:44

  关于flink任务的日志收集到kafka，可以在logback配置文件中

  赞0 踩0 评论0
• 12.07 20:17:22
  回答了问题 2021-12-07 20:17:22

  如何设置FlinkSQL并行度？

  赞0 踩0 评论0
• 12.07 20:17:03
  回答了问题 2021-12-07 20:17:03

  Flink任务写入kafka 开启了EOS，statebackend为rocksdb

  赞0 踩0 评论0
• 12.07 20:16:38
  回答了问题 2021-12-07 20:16:38

  flink连接mysql，在过了一定时间后，就断开连接了

  赞0 踩0 评论0
• 12.07 20:16:10
  回答了问题 2021-12-07 20:16:10

  Session Window使用event time延迟特别高是怎么回事？

  赞0 踩0 评论0
• 12.07 20:15:51
  回答了问题 2021-12-07 20:15:51

  我发现写入hive只能根据checkpoint去提交分区？可以按照文件大小或者间隔时间来生成吗？

  赞0 踩0 评论0