wenti_个人页

2023年01月

• 01.16 19:39:14
  提交了问题 2023-01-16 19:39:14

  Flinksink hdfs 压缩的时候会报这个错，你们遇见过嘛？

• 01.16 19:38:34
  提交了问题 2023-01-16 19:38:34

  Flink怎么把主子表变成es大宽表呢？

• 01.16 19:37:43
  提交了问题 2023-01-16 19:37:43

  Flink，如果keyby的里面id有重复的，会存在什么情况呢？

• 01.16 19:36:33
  提交了问题 2023-01-16 19:36:33

  flinksql如何进行持久化，只能flinksql on hive嘛？

• 01.16 19:36:14
  提交了问题 2023-01-16 19:36:14

  Flink能做文件采集吗？就是监控目录把放入的新的文件内容读取出来，然后读完的文件删除改名什么的

• 01.16 19:35:50
  提交了问题 2023-01-16 19:35:50

  Flink写hive，按分钟分区，在使用-s恢复数据时出现堆溢出的问题，有啥优化的办法吗？

• 01.16 19:34:39
  提交了问题 2023-01-16 19:34:39

  Flink这火焰图应该怎么优化性能？

• 01.16 19:33:39
  提交了问题 2023-01-16 19:33:39

  Flink请教大家一个问题： savepoint 和 checkpoint恢复有什么区别呀？

• 01.16 19:32:39
  提交了问题 2023-01-16 19:32:39

  Flink这里只能select *，不然就会报错，为什么？

• 01.16 19:30:33
  提交了问题 2023-01-16 19:30:33

  Flink这个单个最大核数 我设置的24 启动过几秒 就变成8了 这是怎么回事呢？

• 01.16 19:29:36
  提交了问题 2023-01-16 19:29:36

  Flink这个文件是yarn默认的吗 怎么覆盖呢 ？

• 01.16 19:28:12
  提交了问题 2023-01-16 19:28:12

  Flink oom 了是因为配置不够了吗？

• 01.16 19:26:32
  提交了问题 2023-01-16 19:26:32

  Flink yarn这个怎么调大点啊？

• 01.16 19:25:33
  提交了问题 2023-01-16 19:25:33

  Flink算倾斜嘛？

• 01.16 19:24:27
  提交了问题 2023-01-16 19:24:27

  Flink这是什么报错 ？varchar不能写到string?

• 01.16 19:22:48
  提交了问题 2023-01-16 19:22:48

  Flink目前测试环境。正在做数据处理后写入到Kafka的功能，出现报错，为什么？

• 01.16 19:21:35
  提交了问题 2023-01-16 19:21:35

  flink sink hdfs parquet 写3级目录，老是报错，加资源感觉不好使，为什么？

• 01.16 19:20:30
  提交了问题 2023-01-16 19:20:30

  Flink通过oracle 连接器得到的时间和数据库中存储的不一样，怎么才能 转化成一致的？

• 01.16 19:19:29
  提交了问题 2023-01-16 19:19:29

  flink 1.14 写hive ,使用flink stop --savepointPath 停止报

• 01.16 19:18:23
  提交了问题 2023-01-16 19:18:23

  pg库中的jsonb类型数据，在flink里用什么接呀？

• 01.16 19:17:14
  提交了问题 2023-01-16 19:17:14

  flink Regular join的时候，它保存的是左右表的原始数据吗?

• 01.16 19:16:44
  提交了问题 2023-01-16 19:16:44

  求个flink 部署到 k8s上面的文档

• 01.16 19:16:23
  提交了问题 2023-01-16 19:16:23

  flink通过java启动per-job模式的api在哪里能找到啊?

• 01.16 19:14:14
  提交了问题 2023-01-16 19:14:14

  Flink如果hive 的sink是一致性的话，那就得cp完成了数据才对下游可见吧?

• 01.16 19:13:42
  提交了问题 2023-01-16 19:13:42

  oracle 的sink connector ，必须要 flink 1.5 + 及以上才支持吗？

• 01.16 19:13:01
  提交了问题 2023-01-16 19:13:01

  Flink为啥chk会影响写入hive的啊，不应该是事件时间和水印在影响吗?

• 01.16 19:11:14
  提交了问题 2023-01-16 19:11:14

  flink任务，连接多个 kafka的 topic作为数据源，报类型转换异常。为什么？

• 01.16 19:10:05
  提交了问题 2023-01-16 19:10:05

  Flink像这种cp ，可以理解为两次cp 之间也会持久话状态信息吗？

• 01.16 18:57:11
  提交了问题 2023-01-16 18:57:11

  flinksql中的多行转一列咋弄的啊？

• 01.16 18:56:23
  提交了问题 2023-01-16 18:56:23

  目前用flink oracle cdc sql，任务无报错，但是没有数据输出，为什么？

• 01.16 18:54:58
  提交了问题 2023-01-16 18:54:58

  Flink时间窗口怎么确定上下线？

• 01.16 18:48:46
  提交了问题 2023-01-16 18:48:46

  flinksql使用内置函数 ，报错，这种要怎么排错呢?

• 01.16 18:44:51
  提交了问题 2023-01-16 18:44:51

  机器学习PAI能部署websockect的服务吗?

• 01.16 18:42:59
  提交了问题 2023-01-16 18:42:59

  机器学习pai部署模型在线服务时，容器内部是不是不能调用外网服务?

• 01.16 18:42:23
  提交了问题 2023-01-16 18:42:23

  机器学习中，如何查看资源使用率呢？

• 01.16 18:41:41
  提交了问题 2023-01-16 18:41:41

  机器学习这个参数如何设置，还有worker_processes参数?

• 01.16 18:40:38
  提交了问题 2023-01-16 18:40:38

  机器学习中，pai平台的训练job一直没启动起来，能帮忙看一下是啥原因么?

• 01.16 18:39:37
  提交了问题 2023-01-16 18:39:37

  机器学习中，EAS自定义python processor，部署到EAS后速度慢了好几倍，请问什么原因

• 01.16 16:07:09
  提交了问题 2023-01-16 16:07:09

  请问下阿里云opensearch可以 替代 solr 的 服务工具么？

• 01.16 16:05:30
  提交了问题 2023-01-16 16:05:30

  DataWorks独享数据集成资源组网络连通是什么？

• 01.16 16:05:03
  提交了问题 2023-01-16 16:05:03

  DataWorks分钟级(30mins)调度，每一层上都要设置调度开始时间和结束时间吗？

• 01.16 16:04:36
  提交了问题 2023-01-16 16:04:36

  dataworks上周周末是有更新吗？

• 01.16 16:02:03
  提交了问题 2023-01-16 16:02:03

  DataWorks通过pyodps 节点 往外发请求的时候一直报，是需要有什么白名单配置嘛？

• 01.16 16:01:35
  提交了问题 2023-01-16 16:01:35

  DataWorks这什么情况?

• 01.16 16:00:52
  提交了问题 2023-01-16 16:00:52

  DataWorks 循环节点内部节点不显示是什么鬼？

• 01.16 15:59:28
  提交了问题 2023-01-16 15:59:28

  DataWorks数据抽取是不是会导致很多蛮查询？

• 01.16 15:58:55
  提交了问题 2023-01-16 15:58:55

  DataWorks这是咋回事呢？

• 01.16 15:58:21
  提交了问题 2023-01-16 15:58:21

  DataWorks数据上生产了，需要修改字段类型如何操作？

• 01.16 15:57:07
  提交了问题 2023-01-16 15:57:07

  maxcompute支持封装api接口 实时增量数据的 增加和修改 吗？每天数据量很大