腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Flink
1.2.0
jdbc
从
Mysql
读取
流
数据
java
、
mysql
、
jdbc
、
apache-flink
、
flink-streaming
我正在尝试使用
Flink
2.1.0
从
mysql
日志表中
读取
流
数据
,但是,它只
读取
一次,然后它将停止该过程。我希望它继续
读取
,如果有传入的
数据
,并打印它。env.createInput( .setDrivername("com.
mysql
.
jdbc
.
浏览 72
提问于2017-02-22
得票数 2
1
回答
Flink
mysql
和
mysql
连接器的区别?
apache-flink
、
flink-streaming
、
cdc
、
flink-sql
、
flink-table-api
为了丰富
数据
流
,我们计划将
MySQL
(MemSQL)服务器连接到现有的
flink
流
应用程序此外,
浏览 19
提问于2022-02-07
得票数 0
回答已采纳
1
回答
如何使用
flink
streamtable api
从
jdbc
中
读取
流
数据
apache-flink
、
flink-streaming
我发现在
jdbc
连接器的部分只有DDL和yaml格式的配置,我不知道如何使用them.so。我问的是在写
flink
app jar.if时如何
从
jdbc
数据
源
读取
流
数据
。如果
数据
源中的
数据
发生了变化,
流
是否会更新。
浏览 86
提问于2020-06-23
得票数 1
2
回答
如何在
Flink
转换中更新配置?
java
、
configuration
、
apache-flink
、
flink-streaming
、
distributed-system
给定一个
Flink
流
作业,该作业将map()操作应用于
流
。在没有重新部署的情况下,在
Flink
中编程吗?万一有关系 checkpoints.The I目前正在使用<
浏览 13
提问于2022-10-11
得票数 0
1
回答
使用
Flink
1.2
从
Avro文件中
读取
数据
java
、
apache-flink
几个小时以来,我一直试图弄清楚如何使用
Flink
1.2.0
(必须是这个特定的版本)
从
Avro文件中
读取
数据
,而我只发现了相互矛盾的信息。首先,
flink
的提到我们应该使用一个AvroInputFormat,但是这个类是找不到的(至少它不包含在maven依赖项中:
flink
-java、
flink
- For java_2.10和
flink
-client我的具体问题是: Avro支持是否在
1.2.0
版本中删除,而文档
浏览 0
提问于2017-03-22
得票数 0
回答已采纳
1
回答
在DataStream
Flink
中
读取
JDBC
源
数据
的问题
java
、
jdbc
、
apache-kafka
、
apache-flink
、
flink-streaming
我正在启动一个新的
Flink
应用程序,以允许我的公司执行大量的报告。我们有一个现有的遗留系统,所需的大部分
数据
都保存在Server
数据
库中。在开始使用新部署的Kafka
流
的更多
数据
之前,我们首先需要使用这些
数据
库中的
数据
。 我花了很多时间阅读
Flink
书籍和网页,但我有一些简单的问题和假设,我希望你能帮助我,这样我才能进步。现在我正在尝试针对我们的生产
数据
库编写代码,我需要能够使用SQL查询在“
流
”中
读取</
浏览 1
提问于2021-08-10
得票数 2
回答已采纳
2
回答
如何使用
Flink
读取
Postgresql中的表
postgresql
、
apache-flink
我想使用
Flink
对Postgresql中的
数据
进行一些分析。我应该如何和在哪里给出端口地址,用户名和密码。我正在尝试使用链接:中提到的表源。
浏览 0
提问于2018-06-21
得票数 1
回答已采纳
2
回答
如何
从
Mysql
数据
库创建DataStreamSource?
java
、
mysql
、
apache-flink
、
flink-streaming
、
flink-table-api
我在运行
flink
作业时遇到了问题,
flink
作业基本上是对
mysql
数据
库运行查询,然后尝试创建一个必须从不同作业访问的临时视图。select * from ***"; String sourceDb = "***"; String dbUrl = "
jdbc
:
mysql
://mySqlDatabase:3306/&qu
浏览 36
提问于2022-02-14
得票数 0
回答已采纳
1
回答
Flink
JDBCInputFormat找不到方法“setRowTypeInfo”
jdbc
、
apache-flink
我想使用
flink
-
jdbc
从
mysql
获取
数据
。import org.apache.
flink
.api.java.io.
jdbc
.JDBCInputFormat JDBCInputFormat.buildJDBCInputFormat .setDrivername("
浏览 14
提问于2017-07-09
得票数 0
1
回答
流在Hadoop中的应用
hadoop
、
spark-streaming
、
apache-flink
、
flink-streaming
、
flink-cep
在这个例子中,我确实看到他们创建了一个单独的应用程序(类似于
流
应用程序),该应用程序生成和消费
数据
,并在
数据
上应用模式匹配。他们现在还没有在.Till(如卡夫卡)之间放置一个
流
层,单应用程序就足以满足这一目的,这使得它非常优化。现在,我知道,如果我使用Kafka,那么我需要两个应用程序;一个用于将
数据
摄取到Kafka主题中,另一个用于消费Kafka主题的
数据
。我有几个问题我没有得到回答: 什么时候?
浏览 2
提问于2016-06-13
得票数 0
1
回答
为什么
Flink
不能保证
JDBC
连接器在
JDBC
事务中的精确一次?
apache-flink
、
flink-streaming
由于旧系统的原因,我需要将
数据
从
Flink
输出到
MySQL
。但我在
flink
找到了这样的文档: 创建的
JDBC
接收器至少提供了一次保证。我想知道为什么
Flink
不能保证
JDBC
连接器在
JDBC
事务中的确切一次?谢谢。
浏览 3
提问于2021-02-20
得票数 1
1
回答
通过
JDBC
在受约束的环境上流或批处理整个SQL表
apache-spark
、
jdbc
、
apache-flink
、
spark-streaming
、
flink-streaming
为什么在
读取
过程中需要将整个分区同时加载到内存中? .setDrivername("com.
mysql
.
jdbc
.Driver") .setDBUrl("
jdbc
:
mysql
://localhost
浏览 4
提问于2021-08-13
得票数 0
1
回答
在
Flink
中的范式之间移动
数据
apache-flink
我在一个关系
数据
库中有一些批处理的
数据
,我想使用
Flink
将它们推送到消息总线上。由于
Flink
同时支持批处理和
流
模式,因此它看起来非常适合。
浏览 25
提问于2021-04-28
得票数 0
回答已采纳
1
回答
在
Flink
SQL作业中查询SQL Server
数据
库表时,为什么
Flink
SQL作业
从
正在运行变为已完成?
apache-flink
、
flink-sql
当我们在作为SQL Server
数据
库表的源的
Flink
SQL CLI中选择任何表时,为什么
Flink
作业在从
数据
库表中获取所有记录后“完成”?有没有可能让它“运行”,这样它就可以
从
数据
库表中获取最新的
数据
?
浏览 4
提问于2020-12-25
得票数 1
2
回答
将
flink
与
mysql
数据
库连接时所需的上下文属性不匹配
mysql
、
sql
、
apache-flink
、
create-table
、
pyflink
我正在使用
flink
最新版本(1.11.2)来处理一个
mysql
数据
库示例,该
数据
库运行良好。此外,我还将
FLINK
-连接器-
jdbc
_2.11-1.11.2、
mysql
-连接器-java-8.0.21.jar、PostgreSQL42.2.17.jar添加到{
FLINK
}/lib中。:
mysql
://localhost:3306/inventory The fol
浏览 14
提问于2020-10-08
得票数 1
1
回答
在Apache
Flink
中是否可以直接
从
数据
库表中
读取
数据
以进行批处理,而不是
从
csv文件中
读取
数据
?
postgresql
、
spring-boot
、
dataset
、
apache-flink
、
batch-processing
我需要我的
Flink
批处理作业
从
我的Spring Boot项目的postgres
数据
库中
读取
数据
。我在
Flink
中看到的选项仅用于
读取
csv文件。在这种情况下,我需要从我的表创建一个csv文件。
浏览 36
提问于2020-07-23
得票数 2
回答已采纳
1
回答
FLink
应用程序-
MySql
和MongoDb接口
mysql
、
scala
、
intellij-idea
我有一个小的
flink
应用程序,它从一个卡夫卡主题中
读取
,在处理它之前,需要询问来自主题(x)的输入是否存在于
MySql
数据
库的一个列中(这并不理想,但它符合当前的要求)来自
Flink
服务器的错误java.lang.ClassNotFoundException: com.
mysql
.
jdbc
.Driver--
浏览 0
提问于2018-04-10
得票数 0
1
回答
Flink
- Postgres CDC连接器-自定义查询
apache-flink
、
flink-streaming
、
debezium
我正在使用Postgres作为源的
Flink
应用程序来
读取
某些配置
数据
,将其转换为
数据
流
,然后将其与传入的实时
数据
流连接起来。我尝试过使用,并且能够
读取
单个表并将其反序列化为POJO并进一步使用它。 但是,我的要求是使用CDC源本身中的联接条件
从
多个表中
读取
数据
,然后将其转换为
数据
流
。我们可以在源中编写自定义查询吗?我还没有找到这种可能性,我能想到的唯一解决方案就是分别创建多个源,
浏览 1
提问于2022-04-07
得票数 0
1
回答
Flink
MySQL
连接器极限连接
apache-flink
com.
mysql
.
jdbc
.MysqlIO.at com.
mysql
.
jdbc
.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2220) at com.
mysql
.
jdbc
.
JDBC
4Connec
浏览 17
提问于2022-01-17
得票数 0
2
回答
如何处理(Apache )高IO瓶颈?
apache-spark
、
apache-flink
、
google-cloud-dataflow
、
apache-beam
、
dataflow
让我们举一个简单的例子,我有一个非常简单的波束管道,它只是从一个文件中
读取
数据
并将
数据
转储到一个输出文件中。现在,让我们考虑输入文件是巨大的(一些GB的大小,您通常无法在文本编辑器中打开的文件类型)。由于直接运行程序实现非常简单(它将整个输入集读入内存),它将无法
读取
和输出这些大型文件(除非您为java vm进程分配了不太实际的大量内存);因此,我的问题是:“像
flink
/spark/云
数据
流
这样的生产运行程序如何处理这个‘巨大的
数据</em
浏览 2
提问于2021-07-01
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Pandas从MySQL中读取和保存数据
基于Flink+ClickHouse打造轻量级点击流实时数仓
当 TiDB 与 Flink 相结合:高效、易用的实时数仓
如何构建智能湖仓架构?亚马逊工程师的代码实践
MySQL JDBC StreamResult通信原理浅析
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券