最新最热精华悬赏待回答 筛选
  • 18

    回答

flink 深度优先搜索

我的flink集群有3个taskmanager，每个taskmanager有一个slot，我从hdfs中读取英文数据流，flink进行深度优先搜索，slot 抽象为节点，我在flink中想实现一个小算

回答 Creocb
采纳率0%
  • 1

    回答

flink写hudi 产生大量日志

怎么解决 flink通过HoodiePipeline 写数据到hudi表 产生大量的日志是用的flink的yarn-session启的容器 里面只有这一个任务写入代码 日志截图 看日志感觉是写h

回答 杉杉锅锅
采纳率16.7%
  • 2

关于#Spark# #Flink#的问题，如何解决？

Spark 与 Flink 现在使用哪个更多？目前在大数据处理领域，Spark 和 Flink 哪个的使用频率更高？它们各自的优势和劣势是什么？

回答 武子康
采纳率66.7%
  • 1

    回答

如何使用flink计算分位数

请问使用flink如何计算实时数据流聚类后的的中位数、85%分位数等数据 我尝试使用OVER (PARTITION BY id, count_date, count_hour ORDER BY va

回答 matpython
采纳率0%
  • 1

Flink和Flink CDC报错flink-shaded-guava

我在使用 Flink CDC 迁移数据到 Oracle 和 SQL Server 时，使用的 Flink 版本是 1.16.0，使用的 Flink cdc 版本是 3.2.0。然后 flink-sha

  • flink
  • 3
  • 2024-09-18 15:02
开心比较堵
采纳率73.2%
  • 1

    回答

flinksql oracle如何使用wallet

#问题使用pyflink创建oracle flink jdbc connector的sql table时，需要使用wallet进行无密码访问，在JDBC URL中我指定了TNS_NAME和wallet

回答 Baron254
采纳率50%
  • 1

    回答

flink并行度问题

请问下面的这段代码在.keyBy(1)和.keyBy(0)时为啥在输出结果的并行度上很大的差异(这段代码没有太多的实际意义，只是对输出有疑惑) private static void countWin

回答 土肥宅娘口三三
采纳率0%
  • 18

    回答

flink-sql-connector-rabbitmq使用

数据湖部署，要使用flink流式从rabbitmq接收json数据，传输进入minion存储桶进行存储。构建flink提交的maven项目并打包成jar文件进行提交，报错大致意思是找不到flink-s

野生学鸠
采纳率33.3%
  • 1

    回答

求解这个问题，卡了一上午也不会解决

这个问题怎么解决呀，卡了一上午了，一直解决不出来，有没有遇到过这个问题的可以帮忙解决一下的呀😭😭

回答 bbbxxxqqq
采纳率33.3%
  • 1

    回答

Flink1.17 自定义sink ES8.10.4 问题

自定义Flink sink to ES8 func 本地可以运行 这是我的jar包依赖 但是提交到集群上面就会报错 查出来是依赖问题 冲突 但是不知道怎么解决 有没有能帮下忙的

  • flink
  • 2
  • 2024-09-03 17:49
回答 Cominggod
采纳率0%
  • 2

    回答

Flink sink es8

我用flink1.17发送到es8出现了像你说的同样的问题，缺少类 java.lang.NoSuchMethodError: com.fasterxml.jackson.core.JsonParser

回答 Cominggod
采纳率0%
  • 1

    回答

flink on yarn 启动报错，如何解决？

flink on yarn报错开启Hadoop集群，在yarn上以per job模式运行 执行命令 [root@master bin]# /opt/module/flink-1.14.0/bin/fl

2401_85582445
采纳率0%
  • 1

    回答

flink数据同步以及etl

现在想要通过flink-cdc去同步数据，将用户表与部门信息表进行合并，用户表会变，部门表也会变，这个怎么处理，并且还有点业务处理，这种通过一个job好处理吗？我看说用广播流进行处理

回答 此刻不是此刻
采纳率35.3%
  • 1

    回答

flink使用ES报错，如何解决？(语言-java)

flink中处理数据的时候，需要去ES里面获取一下数据，但是使用下面的代码报错client.performRequest(request)会报错，错误信息是thread waiting for the

回答 LittleEighteen
采纳率0%
  • 1

    回答

flinkcdc监控sqlserver，数据库的表中该字段是空值，而cdc中该字段的值是'N，不一致

版本 1.flinkcdc <dependency> <groupId>com.ververica</groupId>

回答 laijunlin_data
采纳率58.3%
  • 4

    回答

flinkcdc 3.0启动失败

使用flink cdc 但是启动的时候抛出了下面的异常。请问这是什么原因呢》我flink用的是1.18.1flink/lib添加了 mysql-connector-java-8.0.30.jar

  • flink
  • 25
  • 2024-07-23 14:18
回答 aayong123
采纳率0%
  • 4

    回答

flink postgre UUID

create table t(id String); id在postgresql中为uuid，读取数据时发生类型转换错误

回答 m0_54189167
采纳率0%
  • 2

    回答

flink和flink cdc实现数据同步

最近在做数据同步的东西，想用flink和flink cdc实现数据同步，并且想在数据同步的时候执行ETL操作，这个ETL同步操作可能需要用到同步完的数据进行计算，举个例子: 统计学生的学习时长，需要根

回答 此刻不是此刻
采纳率35.3%
  • 8

    回答

Flink如何写入Hbase

tableEnvironment.executeSql("SELECT \n" + " product_id, \n" + "

m0_74283221
采纳率0%
  • 1

    回答

flink使用ConcurrentSkipListMap自定义比较器会出现排序出错问题

我们在flink中使用了ConcurrentSkipListMap,自定义了比较器，但是运行发现比较器中途会失效，比如一开始按从大到小，中间打印出结果顺序会变化，比较器传入string，转为bigde

  • flink
  • 7
  • 2024-06-28 13:20
回答 xinghui_pan
采纳率0%
  • 2

    回答

Flinkcdcmysql实时同步pgsql报错，如何排查后面id

Flink mysql实时同步pgsql。为什么我吧数据同步到pgsql中id一直在DO UPDATE SET 后面这个应该怎么才能排除掉呢 StreamExecutionEnvironment en

  • flink
  • 14
  • 2024-06-20 19:14
回答 RanFps
采纳率0%
  • 2

    回答

Flink端到端的精确一次实验报错

操作步骤我这边的操作：生产者消费者没接收到;运行KafkaEOSDemo.java程序出现报错

回答 苏默曦
采纳率50%
  • 2

    回答

使用Flink AggregateFunction计算股票的平均值报错

使用Flink AggregateFunction计算股票的平均值股票： AggregateFunction计算idea运行出现报错如下;

回答 苏默曦
采纳率50%
  • 2

    回答

data source连接clickhouse失败后数据源问题

连接clickhouse失败后就变成这样了，host等文本框消失了，试了好久也恢复不了正常状态

  • flink
  • 4
  • 2024-06-07 19:52
回答 Simon_ice
采纳率0%
  • 18

    回答

寻找Flink CDC指导，有偿咨询

目前参加的互联网+项目涉及到医疗异构数据的同步问题，将不同血站中的血液信息集中到数据中心里面。目前面临着一些困难，我们希望在Flink CDC 3.0的基础上结合实际使用场景——异构血液信息同步，提出

以默无言
采纳率0%
  • 5

    回答

flink 15分钟滚动窗口触发问题，没有数据却触发了

有3个字段 id,pv,time根据id 分组开窗输出，现在有1,2两个id，id 1一直有数据过来,id 2一天只有一条数据，窗口开始十五分钟，id 2当天窗口一直没有数据输出，可是第二天早上一看i

丶远在咫尺丶
采纳率33.3%
  • 2

    回答

flink批处理shuffle后的并行度

图1： 图2： 为什么flink在idea测试默认并行度为1的情况shuffle，sum之后的并行度为max(默认并行度,job中算子最大并行度)，如图1打印出3行数据，但是在linux的环境中测试

  • flink
  • 3
  • 2024-05-16 15:57
回答 AloneZaa
采纳率0%
  • 2

    回答

docker 部署 flink on yarn 集群任务提交报错

docker 部署 flink on yarn 集群任务提交报错 flink配置文件 blob: server: port: '6124' taskmanager: memory:

回答 落花
采纳率0%
  • 5

    回答

flink on yarn - HA连接不到zookeeper报错如下，如何解决？

flink on yarn - HA连接不到zookeeper报错如下： 显示用 sasl 连接，我并没有配置，这是我的配置文件： blob: server: port: '6124' h

回答 落花
采纳率0%
  • 5

    回答

基于flink的音乐推荐系统

需要什么样的环境，选择什么样的数据库，可视化怎么做，没有思路，求各位指点迷津。

回答 mg_拉丁
采纳率0%