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

排行榜

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

频道

  • 编程语言
  • 前端
  • 大数据
  • 人工智能
  • 运维
  • 服务器
  • 嵌入式
  • 开发工具
  • 数据结构与算法
  • 其他
  • 网络
  • 后端
  • Java
  • 微软技术
  • 移动开发
  • 游戏
  • 学习和成长
  • 硬件开发
  • 吐槽问答
  • 小程序
  • 测试
  • 安全
  • Python
  • 云计算
  • 设计
  • 软件工程
  • 开放平台
  • PHP
  • 多彩生活
  • 区块链
  • 搜索
  • HarmonyOS
  • 产品/运营
  • 设计模式
  • 亚马逊云开发者
最新最热精华悬赏待回答 筛选
  • 0

    回答

问题遇到的现象和发生背景 在测试flink-CDC 同步oracle 遇到报错,不知道是什么原因报错如下 用代码块功能插入代码,请勿粘贴截图 Exception in thread "main" or

  • 2

    回答

在flink工程,pom.xml文件引入如下2个包的时候告警,会有影响吗? 用代码块功能插入代码,请勿粘贴截图 dependency> groupId>org.apache.flink

  • flink
  • 8
  • 2022-09-18 16:00
  • 1

启动flink独立集群错误,麻烦大家帮我看看这个是什么问题,怎么解决?

  • 1

    回答

问题遇到的现象和发生背景 [root@nodeone flink-1.13.0]# bin/flink run -m nodeone:8081 -c com.kgc.wc.StreamWordCoun

  • 1

    回答

我想要达到的结果 老哥有个问题想麻烦问一下,我在flink1.13.2,apache-flink1.13.2,pyflink1.0环境下,提交官方文档(网址:https://nightlies.apa

  • flink
  • 16
  • 2022-08-31 12:32
  • 1

问题遇到的现象和发生背景 : 软件版本:flink-1.15.1,kafka-2.12-2.81,OGG-19.1.0.0最终目的:创建 flink 的 kafka 源表,解析 ogg-json 数据

奇迹虎虎
采纳率100%
  • 1

    回答

pyflink 提交任务时报错,求解决 提交任务命令:flink run -py G:\E\flink\flink-1.14.3\examples\python\table\word_count.py

  • 1

    回答

flink的DataStream转成table时遇到一个问题: 从source采集的数据是DataStreamString,需要转成table,而且需要在转的时候指定字段(好像只能通过case cla

回答 aadzx
采纳率0%
  • 1

    回答

问题遇到的现象和发生背景 flink提交cdc任务失败,本地idea环境可以正常运行 运行结果及报错内容 2022-08-17 17:08:36,915 WARN org.apache.flink.

  • flink
  • 18
  • 2022-08-17 17:25
  • 1

    回答

使用flink消费kafka和使用springboot的消费有什么区别,为什么说流式计算快,他在哪些方面节省了时间

  • 1

问题遇到的现象和发生背景 这几天使用Flink SQL客户端遇到一个窒息的问题,没查到解决方案,有没有懂Flink的朋友帮忙看一下只要加 FOR SYSTEM_TIME AS OF 就给我报错,去掉就

swx7410852963
采纳率100%
  • 1

    回答

代码 object ReduceAgg { def main(args: Array[String]) { val env: StreamExecutionEnvironment = S

  • flink
  • 21
  • 2022-08-10 21:17
  • 2

    回答

最近写flink遇到个问题,代码逻辑很简单,就是flink从clickhouse读取数据,然后简单转换存入es,但是并行度遇到个问题,我在提交时候指定并行度为12,然后souce端的并行度也成为了12

回答 ikiler
采纳率0%
  • 1

    回答

flink可以直接读取sqlserver中的数据吗?(怎么还要凑三十个字,怎么这么简短的问题在这里不受待见吗)

  • 1

    回答

SpringBoot动态控制Flink把Flink当成一个组件来用可以吗,有没有什么比较好的解决方案,现在的情况是如果使用Flink集群的话功能太单一没办法结合业务使用,如果强行整合进SpringBo

  • flink
  • 13
  • 2022-07-21 16:00
  • 1

网上都说Flink卡槽配置最优是和CPU核心数一致就行,但是在服务器资源不够的情况下slot配置超过CPU核心数甚至比CPU核心多几倍会怎样,达到什么比例会影响任务执行的性能

  • flink
  • 16
  • 2022-07-20 17:02
  • 2

    回答

问题遇到的现象和发生背景 我现在做一个传统大数据的项目,架构师说用flink做批流一体,但我一头雾水,有啥例子没有,比如有项目实战的用Flink的,能加一下你不,谢谢! 问题相关代码,请勿粘贴截图 运

  • ¥10
  • flink
  • 42
  • 2022-07-19 19:59
zhouzeng1980
采纳率0%
  • 1

    回答

flink sql client 连接mysql报错异常:[ERROR] Could not execute SQL statement. Reason:java.lang.ClassNotFound

回答 guodu1223
采纳率66.7%
  • 1

    回答

flinksql client 连接kafkaselect * from table没有数据报错:[ERROR] Could not execute SQL statement. Reason:org

回答 guodu1223
采纳率66.7%
  • 1

    回答

问题遇到的现象和发生背景 用Code Sever调试Maven工程代码时,打包正常,运行单个java文件的时候就一直卡住了。 问题相关代码,请勿粘贴截图 import com.alibaba.fas

  • 3

flinksql读取kafka数据报错flinksql创建kafka的表成功了,但是在查询的时候报错报错信息如下: 网络是通的,kafka版本:kafka_2.12-3.1.0flink版本:flin

guodu1223
采纳率66.7%
  • 3

    回答

flink sql client 读取oracle数据到es中,报错 网上都说没加cdc依赖,可是我已经加了

  • ¥10
  • flink
  • 61
  • 2022-07-06 15:31
fids
采纳率40%
  • 1

    回答

idea 本地跑Flink代码,debug断点不生效(红点,但没有对勾),是否需要加一些插件?

  • 1

    回答

https://blog.csdn.net/weixin_43704599/article/details/106593602您好 我用您的方式集成flink到cm上,但是parcle 中已分配激活,

weixin_42121223
采纳率0%
  • 1

问题遇到的现象和发生背景 问题相关代码,请勿粘贴截图 package cn.itcast.hello.source; import org.apache.flink.api.common.Runti

  • flink
  • 46
  • 2022-06-05 15:31
Younger_50
采纳率100%
  • 1

现在需要使用Flink处理一批乱序数据,设置了一个十分钟的窗口从10:14:50-10:24:50,但是为什么10:14:51的数据会输出到侧输出流中? val aggStream = dataStr

吾忘
采纳率100%
  • 2

    回答

使用flinksql的ddl创建mysql维表,其中还用了lookup缓存,当程序运行一段时间后会报mysql链接失效问题,请问一下有知道怎么解决的吗,万分感谢,报错如下。1、com.mysql.cj

回答 弥生i
采纳率50%
  • 2

public class FlinkSqlTemplateJob{ static { try { Class.forName("com.mysql.cj.jdbc.Driver

  • flink
  • 18
  • 2022-05-08 20:54
至此y
采纳率100%
  • 1

    回答

一、问题 Filnk集群关闭时,bin/stop-cluster.sh 命令没有用 二、关闭时命令行的提示 No taskexecutor daemon to stop on host x.x.xNo

回答 zzk12
采纳率0%
  • 1

    回答

问题遇到的现象和发生背景 flink流写入oracle非常慢,因为流写入使用的是自定的sinkFunction,所以也是用的jdbc,但是效率还不如java效率高 问题相关代码,请勿粘贴截图 ps =