1. 云栖社区>
  2. 全部标签>
  3. #流计算#
流计算

#流计算#

已有2人关注此标签

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

各路大神们,有没有玩过好用sql解析java工具类或封装类,能把复杂的SQL语句逻辑中的所要操作的表的表名给解析出来放到set集合中???

转自钉钉群21789141:各路大神们,有没有玩过好用sql解析java工具类或封装类,能把复杂的SQL语句逻辑中的所要操作的表的表名给解析出来放到set集合中???

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

flink1.4.2 使用kafka08jsontablesource,我们测试,kafka里没有数据的情况下,程序运行一段时间就会报这个exception

转自钉钉群21789141:flink1.4.2 使用kafka08jsontablesource,我们测试,kafka里没有数据的情况下,程序运行一段时间就会报这个exception, flink从1.4.2升级到1.5.3后,报找不…

大数据 测试 Image 钉钉 exception 流计算 flink 实时计算

如果在exactly-once 的checkpoint模式下,处理数据出现异常该怎么处理因为重启会一直在那个点重跑 岂不是一直fail

转自钉钉群21789141:如果在exactly-once 的checkpoint模式下,处理数据出现异常该怎么处理因为重启会一直在那个点重跑 岂不是一直fail个人觉得flink代码的成熟性还是蛮差的,相对于spark,很多逻辑都是因为源…

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

如果在exactly-once 的checkpoint模式下,处理数据出现异常该怎么处理

转自钉钉群21789141:如果在exactly-once 的checkpoint模式下,处理数据出现异常该怎么处理

大数据 流计算 flink 实时计算

请教个问题,tableEnvironment.registerDataStream(table)为什么和tableEnvironment.registerTable(table)一样也能接受一个table参数?

转自钉钉群21789141:请教个问题,tableEnvironment.registerDataStream(table)为什么和tableEnvironment.registerTable(table)一样也能接受一个table参数?下…

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

flink sink 如何做到数据准确性?

转自钉钉群21789141:flink sink 如何做到数据准确性?

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

我可以把retraction流 (例如SELECT DISTINCT ...的结果),用regiterDataStream()注册为表吗?我试了报以上错误。

转自钉钉群21789141:我可以把retraction流 (例如SELECT DISTINCT ...的结果),用regiterDataStream()注册为表吗?我试了报以上错误。

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

各位前辈,晚辈有个问题,为什么流式处理框架都是 java 写成的,JVM 是不是在流和批存在着特殊优势。还有分布式资源调度,感觉Mesos 的成长速度跟不上 Yarn。这是为什么?

转自钉钉群21789141:各位前辈,晚辈有个问题,为什么流式处理框架都是 java 写成的,JVM 是不是在流和批存在着特殊优势。还有分布式资源调度,感觉Mesos 的成长速度跟不上 Yarn。这是为什么?

云栖社区 分布式 大数据 java jvm 容器 钉钉 Mesos 流计算 flink 实时计算

请问一下给大侠,我这里怎样配置能外网访问的静态IP?

转自钉钉群21789141:请问一下给大侠,我这里怎样配置能外网访问的静态IP?IP_ADDR

大数据 配置 Image 钉钉 IP 流计算 flink 实时计算

对比flink和spark 代码提交记录,spark 算是非常频繁?

转自钉钉群21789141:对比flink和spark 代码提交记录,spark 算是非常频繁?

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

大神,请教一下阿里的Blink平台业务方使用是强制要求只能写sql和udf么?

转自钉钉群21789141:大神,请教一下阿里的Blink平台业务方使用是强制要求只能写sql和udf么?这么设计的出发点和目的是啥。我们公司也在研发基于Flink的流计算平台,从使用方的角度来说,会不会出现sql表达力不够和排错困难问题。…

python 大数据 程序员 SQL 钉钉 scala UDF 流计算 Blink flink 实时计算

第一季flink meetup视频出来了吗?有的话链接发一个

转自钉钉群21789141:第一季flink meetup视频出来了吗?有的话链接发一个

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

hi 我遇到一个奇怪的问题 有一个10个分区的kafka topic 我的并发度设置成9 有8个分区的数据不消费 并发度设置成8有6个分区数据没法消费 并发度设置成10时 所有分区数据都消费不到,但是从日志上来看 每个task 都分配到了一个partition. 并发度设置成2或者5时 数据消费正常

转自钉钉群21789141:hi 我遇到一个奇怪的问题 有一个10个分区的kafka topic 我的并发度设置成9 有8个分区的数据不消费 并发度设置成8有6个分区数据没法消费 并发度设置成10时 所有分区数据都消费不到…

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

请问大家我想用flink消费卡夫卡数据,可是kafka怎么创建消费组呢?

转自钉钉群21789141:请问大家我想用flink消费卡夫卡数据,可是kafka怎么创建消费组呢?

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

flink on yarn大家实际生产上,是用yarn session方式还是single yarn job?这两个方式如何选择

转自钉钉群21789141:flink on yarn大家实际生产上,是用yarn session方式还是single yarn job?这两个方式如何选择

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

想问一下 flink 有写orc hdfs 的BucketingSink吗? 或者还需StreamingFileSink 来写吗?貌似1.6没有orc writer哦

转自钉钉群21789141:想问一下 flink 有写orc hdfs 的BucketingSink吗?或者还需StreamingFileSink 来写吗?貌似1.6没有orc writer哦

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

请教下,阿里云上的流计算平台是基于blink的,集群资源管理是用的yarn吗

转自钉钉群21789141:请教下,阿里云上的流计算平台是基于blink的,集群资源管理是用的yarn吗

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

请问一下,有人用过flink monitor 的rest api吗?我cancel job每次都返回404 not found。flink 文档里写的是DELETE

转自钉钉群21789141:请问一下,有人用过flink monitor 的rest api吗?我cancel job每次都返回404 not found。flink 文档里写的是DELETE request to /jobs/:jobid…

大数据 request 钉钉 API url REST 流计算 flink 实时计算

如果不在第三方存储结果,服务重启,历史数据就丢了,要重新再全部计算一次?

转自钉钉群21789141:如果不在第三方存储结果,服务重启,历史数据就丢了,要重新再全部计算一次?

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

上一页 1 ... 3 4 5 6 7 ... 8 下一页
8
GO