• 全部
  • 关注
  • 有问必答
  • 等你来答

排行榜

  • 用户榜
  • 标签榜
  • 冲榜分奖金

频道

  • 编程语言
  • 后端
  • Python
  • Java
  • 前端
最新最热精华悬赏待回答 筛选
  • 0

    回答

  • 4

    浏览

这是我的代码import org.apache.flink.streaming.api.scala._import org.apache.flink.api.java.utils.ParameterT

  • 1

    回答

  • 13

    浏览

Could not execute SQL statement. Reason:java.lang.NoSuchMethodError: com.google.common.base.Precondi

回答 tian_chenwei
采纳率0%
2021-12-03 11:35
  • 1

    回答

  • 10

    浏览

应用主要是分析kafka中的日志数据,统计各个接口的tps/qps。实现方式是根据日志中记载的时间戳已接口名为key统计1s中日志中该key(接口)的日志条数,现在由于某些key的日志数据较多,导致

howel_wang
采纳率0%
2021-11-29 14:27
  • 1

    回答

  • 10

    浏览

package com.xu.studyApp.watermarkTest import org.apache.flink.api.common.eventtime.{SerializableTim

LeiKe_
采纳率0%
2021-11-21 21:32
  • 1

    回答

  • 5

    浏览

如何使用flink并基于scala语言,实现数据泛化解决各种数据源格式,并最终入库elasticsearch?大致的框架为通过flinkx从关系型数据库、非关系型数据库、消息队列采集数据到kafka,

a$明天不想下暴雨$
采纳率0%
2021-11-17 10:53
  • 1

  • 13

    浏览

Flink架构项目改造成spring boot项目,或者改造后的flink项目的jar包能放在tomcat中运行,代替flink软件。

李潘杜若
采纳率66.7%
2021-11-16 11:15
  • 2

    回答

  • 47

    浏览

flink保证sink 端exactly-once有幂等写入和事务写入两种方式。事务写入的实现方式又有预写日志和两阶段提交。请问预写日志和两阶段提交的差别在哪里?两个好像都是先写入缓存,等checkp

bingcore
采纳率0%
2021-11-03 21:22
  • 1

  • 22

    浏览

3年工作经验,没接触过FlinkSql,这是什么,求一个文档看看,能知道他是什么,干什么用的。

LookOutThe
采纳率100%
2021-11-03 15:10
  • 1

    回答

  • 6

    浏览

Flink版本 1.13.1JDK 1.8集群部署 情况: 提交一个job之后JVM metaspace会变大,直到job执行完成.metasapce也不会变小.这样会导致运行了多个job之后met

weixin_44532334
采纳率0%
2021-11-03 11:52
  • 1

    回答

  • 3

    浏览

现在是在服务器端集群部署了flink,每个集群可能有多个task在跑,在不去生产环境的条件下,有没有办法远程通过脚本来操作单个task的启停呢?因为在命令行重启task都是先cancel再run的,需

翘之�
采纳率0%
2021-11-03 10:01
  • 2

    回答

  • 14

    浏览

错误提示: Caused by: java.io.InvalidClassException: org.apache.flink.streaming.api.scala.DataStream$$ano

回答 qq_42672426
采纳率0%
2021-10-27 16:58
  • 2

    回答

  • 75

    浏览

1单独运行两个流报错数据到es 没问题2为了确保数据没收到2.1kafka生产者我循环每30毫秒发一条 2.2 另外开一个消费者 看到了数据 3代码如下 3.1 sink的sql 3.2 创建

coffin_fe
采纳率25%
2021-10-20 11:44
  • 1

    回答

  • 19

    浏览

DataStream<ItemViewCount> windowAggStream = dataStream .filter(data -> "p

只是甲
采纳率0%
2021-10-15 09:03
  • 2

    回答

  • 22

    浏览

flink运行任务报错,Failed to construct kafka consumer,下面提示 Too many open files ,请问这个是什么原因,具体怎么排查或者解决,麻烦大佬指点

回答 键盘上的艺术^
采纳率0%
2021-10-12 14:34
  • 3

    回答

  • 31

    浏览

flink-1.13.2 ,每分钟1个分区,已经生成part文件,但似乎没有提交hive元数据,查不到? / user/ hive/ warehouse/ event_track2/ dt=2021-

回答 coolmasoft
采纳率0%
2021-09-28 00:27
  • 1

    回答

  • 11

    浏览

select * from person where age="23",age是Intger类型,报错,能不能做全局的统一处理,不要每次都是cast处理呢

我不做程序员
采纳率0%
2021-09-27 22:07
  • 1

    回答

  • 21

    浏览

flink基于k8s安装,hadoop原生安装集群,将任务放到flink上执行的时候,报错不能使用checkpoint,环境:k8s的flink1.13.0 原生安装的hadoop3.2.2 我能

_土豆不是豆
采纳率0%
2021-09-27 17:26
  • 2

    回答

  • 39

    浏览

初学spark,使用spark structred stream进行计算统计,2小时窗口时长,10秒钟触发一次计算,kafka里发送几条测试数据,内存就报OOM了,按理说不应该啊,请问问题是出在哪儿?

回答 ranwei0206
采纳率0%
2021-09-18 15:35
  • 1

    回答

  • 20

    浏览

我通过kafka命令查询消费组brokers下有哪些消费者时,是没有的 然后,我通过命令行启动一个消费组 再次查询,消费组下有一个消费者 但是,有个前提,就是我flink一直连接了kafka的,并

我想E得足够快
采纳率0%
2021-09-16 15:31
  • 1

    回答

  • 30

    浏览

按照flink的例子改了一下,从rabbitmq读取流数据,通过RichSinkFunction写入到clickhouse中。第一次运行是正常的,多次写入也没问题。但是cancel job之后,重新s

geniushht
采纳率0%
2021-09-03 11:07
  • 2

  • 148

    浏览

因本人要学习大数据,需要学习Linux、虚拟机,不清楚R7 5800H是否支持虚拟化操作,询问客服后,还是不清楚能否支持虚拟化,知乎,CSDN里对AMD是否支持虚拟化不认可,想了解下R7 5800H是

愤怒の滑铲
采纳率100%
2021-08-26 08:42
  • 3

    回答

  • 130

    浏览

求尚硅谷Flink实时数仓2.0 的课件、视频、资料,注意是2.0!

  • 1

    回答

  • 76

    浏览

最近在改造项目,全部切换到微服务,组件比较多,需要做熔断机制,在做熔断机制的时候,服务端做好,还是客户端做好?

回答 huxiao_123
采纳率0%
2021-08-24 22:36
  • 1

    回答

  • 18

    浏览

阿里云全托管的flink怎么读oss桶表数据,还有maxcomputer之类的,用Datastream

回答 乐正辉
采纳率0%
2021-08-24 15:14
  • 2

  • 55

    浏览

你好,为什么我这边把你的代码复制过来报错呢?麻烦帮忙看看,包和依赖都导入了

时来时去时不返
采纳率100%
2021-08-18 11:07
  • 1

  • 19

    浏览

关于flink接收kafka消息的代码能不能用python写

  • 1

    回答

  • 70

    浏览

您好,我跟您遇到了一样的问题,flink写orc文件,用hive加载orc文件的时候报错,请问您解决了么?

Billd_
采纳率0%
2021-08-10 10:18
  • 1

    回答

  • 179

    浏览

SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/hadoop/yarn/l

haoyuehong91
采纳率50%
2021-08-04 14:11
  • 1

    回答

  • 20

    浏览

刀侠,我按照这篇文章搭建还是报错,咋办? Bytecode: 0x0000000: 2a2b b700 c59a 0016 bb01 2c59 1301 2e04 0x0000010

回答 flh141
采纳率0%
2021-08-04 10:22