1. 云栖社区>
  2. 全部标签>
  3. #flink#
flink

#flink#

已有49人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

1.5.1的flink on yarn的部署模式下,使用eventtime做处理时间,flink的jobmanger界面里为啥看不见wartermark的值

转自钉钉群21789141:1.5.1的flink on yarn的部署模式下,使用eventtime做处理时间,flink的jobmanger界面里为啥看不见wartermark的值。但是之前在用1.3.0flink ,搭的standal…

大数据 集群 钉钉 flink 实时计算

请问一下本地可以通过blink连接远程的hive吗?

转自钉钉群21789141:请问一下本地可以通过blink连接远程的hive吗?

大数据 钉钉 Hive Blink flink 实时计算

连接hive,hive执行引擎是 MR 还是 Flink ?

转自钉钉群21789141:连接hive,hive执行引擎是 MR 还是 Flink ?

大数据 钉钉 Hive flink 实时计算

用 RocksDBStateBackend 时出现了这个错误

转自钉钉群21789141:用 RocksDBStateBackend 时出现了这个错误

大数据 钉钉 流计算 flink 实时计算

taskmanager.numberOfTaskSlots 大小配置,flink默认3,blink默认1。实际配置中依据并发度和服务器内存吗?一个Slots一般多大内存较合适?

转自钉钉群21789141:taskmanager.numberOfTaskSlots 大小配置,flink默认3,blink默认1。实际配置中依据并发度和服务器内存吗?一个Slots一般多大内存较合适?

大数据 服务器 配置 钉钉 flink 实时计算

Blink streaming 不支持print(), 那为什么又有这样的api呢 val sql1 = "SELECT a, c FROM sourceTable" tEnv.sqlQuery(sql1).print() // org.apache.flink.table.api.TableException: collect is not supported.

转自钉钉群21789141:Blink streaming 不支持print(), 那为什么又有这样的api呢 val sql1 = "SELECT a, c FROM sourceTable" tEnv.sqlQuery(sql1).p…

大数据 Apache 钉钉 API Blink flink 实时计算

flink 1.8-SNAPSHOT 是在 阿里的 blink 上出的版本吗?

转自钉钉群21789141:flink 1.8-SNAPSHOT 是在 阿里的 blink 上出的版本吗?

钉钉 Blink flink 实时计算

flink中文的maillist有归档页面吗

转自钉钉群21789141:flink中文的maillist有归档页面吗

大数据 钉钉 流计算 flink 实时计算

各位flink是用java还是scala开发的?

转自钉钉群21789141:各位flink是用java还是scala开发的?

大数据 java 钉钉 scala 流计算 flink 实时计算

yarn运行yarn-session报错,有大神知道吗

转自钉钉群21789141:yarn运行yarn-session报错,有大神知道吗

大数据 钉钉 流计算 flink 实时计算

在自己的linux虚拟机下编译blink源码,在 [INFO] Running 'npm install --cache-max=0 --no-save' in /opt/gitrepo/flink-runtime-web/web-dashboard 后就没有反应了,ctrl+c 才退出来

转自钉钉群21789141:在自己的linux虚拟机下编译blink源码,在[INFO] Running 'npm install --cache-max=0 --no-save' in /opt/gitrepo/flink-runtime…

linux 大数据 源码 钉钉 流计算 flink 实时计算

如图,ture ? false? 是什么意思?

转自钉钉群21789141:ture ? false? 是什么意思?我需要判断是true和false,才输出?

大数据 钉钉 DB 流计算 flink 实时计算

请教一下,我想让两个流join, 但是希望每条数据触发join的时候就进行计算,不用等到窗口结束,怎么做啊?

转自钉钉群21789141:请教一下,我想让两个流join, 但是希望每条数据触发join的时候就进行计算,不用等到窗口结束,怎么做啊?

大数据 钉钉 流计算 flink 实时计算

flink社区大群的入群方式有哪些?

转自钉钉群21789141:flink社区大群的入群方式有哪些?

大数据 钉钉 流计算 flink 实时计算

blink开源这次 支持的是MicroBatch 还是 MiniBatch

转自钉钉群21789141:blink开源这次 支持的是MicroBatch 还是 MiniBatch

大数据 钉钉 流计算 flink 实时计算

请问在Flink里面,UDAF不能返回null值吗? 在自定义的UDAF latest_value_long_test里面,如果返回了null值,会在checkpoint的时候报序列化的错误 select DRAFT_ORDER_ID, latest_value_long_test(LAST_UPDATE_TIME) from CRD5_DRAFT_ORDER group by DRAFT_ORDER_ID

转自钉钉群21789141:请问在Flink里面,UDAF不能返回null值吗? 在自定义的UDAF latest_value_long_test里面,如果返回了null值,会在checkpoint的时候报序列化的错误select …

大数据 钉钉 BY Group flink 实时计算

UDAF实际调用时传入int类型,定义时是long类型,运行时报参数不匹配,int不能转成long类型吗?发现Flink-SQL在编写的时候需要写很多的CAST

转自钉钉群21789141:UDAF实际调用时传入int类型,定义时是long类型,运行时报参数不匹配,int不能转成long类型吗?发现Flink-SQL在编写的时候需要写很多的CAST

大数据 钉钉 flink 实时计算

flink 有timewindow 还有 countwindow 是否可以自定义实现 countTimeWindow 如果先满足count 就出发 不然就出发时间window

转自钉钉群21789141:flink 有timewindow 还有 countwindow 是否可以自定义实现 countTimeWindow 如果先满足count 就出发 不然就出发时间window

大数据 钉钉 flink 实时计算

flink 入库hbase,请问有查阅的文档吗?

转自钉钉群21789141:flink 入库hbase,请问有查阅的文档吗?

大数据 hbase 钉钉 flink 实时计算

请教老师,flink job已经用flink cancel命令取消了。但是代码里创建的子线程仍在运行,这个要怎么解决呢?谢谢。

转自钉钉群21789141:请教老师,flink job已经用flink cancel命令取消了。但是代码里创建的子线程仍在运行,这个要怎么解决呢?谢谢。

大数据 线程 钉钉 flink 实时计算

上一页 1 ... 2 3 4 5 6 ... 30 下一页
30
GO