- 全部
- 关注
- 有问必答
- 等你来答
排行榜
- 用户榜
- 标签榜
- 冲榜分奖金
频道
- 编程语言
- 前端
- 大数据
- 人工智能
- 运维
- 服务器
- 嵌入式
- 开发工具
- 数据结构与算法
- 其他
- 网络
- 后端
- Java
- 微软技术
- 移动开发
- 游戏
- 学习和成长
- 硬件开发
- 吐槽问答
- 小程序
- 测试
- 安全
- Python
- 云计算
- 设计
- 软件工程
- 开放平台
- PHP
- 多彩生活
- 区块链
- 搜索
- HarmonyOS
- 产品/运营
- 设计模式
- 亚马逊云开发者
- 0
回答
问题遇到的现象和发生背景 在测试flink-CDC 同步oracle 遇到报错，不知道是什么原因报错如下 用代码块功能插入代码，请勿粘贴截图 Exception in thread "main" or
- flink
- 2
- 2022-09-26 13:23
- 2
回答
在flink工程，pom.xml文件引入如下2个包的时候告警，会有影响吗？ 用代码块功能插入代码，请勿粘贴截图 dependency> groupId>org.apache.flink
- 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 数据
- 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
- 1
回答
问题遇到的现象和发生背景 flink提交cdc任务失败，本地idea环境可以正常运行 运行结果及报错内容 2022-08-17 17:08:36,915 WARN org.apache.flink.
- 1
回答
- 1
问题遇到的现象和发生背景 这几天使用Flink SQL客户端遇到一个窒息的问题，没查到解决方案，有没有懂Flink的朋友帮忙看一下只要加 FOR SYSTEM_TIME AS OF 就给我报错，去掉就
- 1
回答
代码 object ReduceAgg { def main(args: Array[String]) { val env: StreamExecutionEnvironment = S
- 2
回答
最近写flink遇到个问题，代码逻辑很简单，就是flink从clickhouse读取数据，然后简单转换存入es，但是并行度遇到个问题，我在提交时候指定并行度为12，然后souce端的并行度也成为了12
- 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
- 1
回答
flink sql client 连接mysql报错异常：[ERROR] Could not execute SQL statement. Reason:java.lang.ClassNotFound
- 1
回答
flinksql client 连接kafkaselect * from table没有数据报错：[ERROR] Could not execute SQL statement. Reason:org
- 1
回答
问题遇到的现象和发生背景 用Code Sever调试Maven工程代码时，打包正常，运行单个java文件的时候就一直卡住了。 问题相关代码，请勿粘贴截图 import com.alibaba.fas
- 3
flinksql读取kafka数据报错flinksql创建kafka的表成功了，但是在查询的时候报错报错信息如下： 网络是通的，kafka版本：kafka_2.12-3.1.0flink版本：flin
- 3
回答
flink sql client 读取oracle数据到es中，报错 网上都说没加cdc依赖，可是我已经加了
- 1
回答
idea 本地跑Flink代码，debug断点不生效（红点，但没有对勾），是否需要加一些插件？
- flink
- intellij-idea
- 18
- 2022-06-26 00:29
- 1
回答
https://blog.csdn.net/weixin_43704599/article/details/106593602您好 我用您的方式集成flink到cm上，但是parcle 中已分配激活，
- 1
问题遇到的现象和发生背景 问题相关代码，请勿粘贴截图 package cn.itcast.hello.source; import org.apache.flink.api.common.Runti
- flink
- 46
- 2022-06-05 15:31
- 1
现在需要使用Flink处理一批乱序数据，设置了一个十分钟的窗口从10:14:50-10:24:50，但是为什么10:14:51的数据会输出到侧输出流中？ val aggStream = dataStr
- 2
回答
- 2
public class FlinkSqlTemplateJob{ static { try { Class.forName("com.mysql.cj.jdbc.Driver
- 1
回答