腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
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.Driver") .setDBUrl("jdbc:
mysql
:
浏览 72
提问于2017-02-22
得票数 2
1
回答
如何使用
flink
streamtable api从jdbc中读取流数据
apache-flink
、
flink-streaming
我问的是在写
flink
app jar.if时如何从jdbc数据源读取流数据。如果数据源中的数据发生了变化,流是否会更新。
浏览 86
提问于2020-06-23
得票数 1
1
回答
Flink
mysql
和
mysql
连接器的区别?
apache-flink
、
flink-streaming
、
cdc
、
flink-sql
、
flink-table-api
为了丰富数据流,我们计划将
MySQL
(MemSQL)服务器连接到现有的
flink
流应用程序此外,我还发现了另一个名为
Flink
-CDC https:/
浏览 19
提问于2022-02-07
得票数 0
回答已采纳
1
回答
是否可以在
Flink
应用程序中访问FlatMapFunction中的
数据库
?
apache-flink
、
flink-streaming
处理包括用更多的数据来丰富来自流的实例,而get从
数据库
中执行
查询
以收集输出,但它认为这不是最好的方法。 阅读文档时,我知道我可以从
数据库
查询
创建DataSet,但我只看到了批处理的示例。我可以使用DataSet而不是直接访问
数据库
来提高性能吗?
浏览 4
提问于2017-07-14
得票数 1
回答已采纳
1
回答
flink
-如何使用状态作为缓存
apache-flink
我想读一读州政府的历史。如果状态为null,则读取hbase并更新状态,并使用onTimer设置状态ttl。问题是如何批量读取hbase,因为从hbase读取单个记录的效率不高。
浏览 19
提问于2018-08-27
得票数 0
1
回答
如何定期安排
flink
批处理
java
、
apache-flink
、
flink-streaming
我有一个java应用程序,它通过从
数据库
查询
表并将其输入kafka主题来对批处理进行
flink
批处理。我该如何定期安排这件事。有
flink
调度程序吗?例如,我的java应用程序应该在后台继续运行,
flink
调度程序应该定期
查询
数据库
中的表,
flink
批处理处理它并输入kafka(
flink
批处理和输入kafka已经完成了我的应用程序的一部分)。
浏览 2
提问于2016-11-29
得票数 4
回答已采纳
1
回答
完全是一次为端到端
apache-flink
、
kafka-consumer-api
、
flink-streaming
我想知道是否有可能同时使用
Flink
实现端到端的精确语义?来源: kafka进程:
flink
接收器:
数据库
(
mysql
或redis)谢谢。
浏览 2
提问于2022-09-26
得票数 -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中。: ports: - "3306:3306"
浏览 14
提问于2020-10-08
得票数 1
1
回答
RHEL5 rSync
Mysql
服务器
mysql
、
linux
、
rsync
目的:实现2Linux服务器的实时
同步
。 rsync -avc /var/lib/
mysql
/ root@10.1.99.XXX:/var/lib/
mysql
/
同
浏览 4
提问于2012-07-03
得票数 2
2
回答
Apache和RxJava的使用
rx-java
、
apache-flink
、
flink-streaming
因为我的
flink
操作总是映射函数,并且在其中我更多地使用Rx,比如从
flink
获取元组并对它们进行异步操作(转到DB、写入队列等等),但是我最终没有使用
flink
向我公开的大多数方法,当Rxjava随着处理结束时你能告诉我,这是一个正确的使用
flink
,或如果有aa更好的方式做我需要做的。(喜欢使用它,但在
flink
步骤之间传递可观测值或类似的东西)。 谢谢。
浏览 4
提问于2016-06-10
得票数 1
回答已采纳
2
回答
如何使用Windows服务从主
数据库
中自动重新生成从
数据库
中的从
数据库
?
mysql
、
database
、
windows-services
、
master-slave
、
mysqlbinlog
我正在编写一个Windows程序来不断地将本地从
数据库
同步
到主
数据库
。我有一个名为nsbm_syncdb的主
数据库
。如果我想
同步
从
数据库
,我必须编写以下
查询
。MASTER TOMASTER_USER='nsbm_root',MASTER_LOG_FILE='
mysql
-bin.0
浏览 0
提问于2018-02-13
得票数 0
回答已采纳
1
回答
flink
检查点由于jdbc写背压而失败
apache-flink
、
flink-streaming
我有一个
flink
应用程序,它每30分钟
查询
一次
数据库
,进行一些转换并持久化到
数据库
中。我试图处理100 k记录,因为来自jdbc写任务、
数据库
查询
任务和转换任务之一的背压没有得到检查点和超时。使用
flink
版本1.14.5,并行性15。另一个
flink
应用程序具有作为输入源的慰藉和相同的jdbc写任务。即使禁用了未对齐的检查点和相同的
flink
配置,也可以正常工作。 谢谢你的帮助。
浏览 6
提问于2022-11-03
得票数 0
2
回答
当我在locall pc上的
Mysql
查询
浏览器中添加新记录时,如何更新服务器上的表?
mysql
、
browser
我在我的电脑上使用
Mysql
查询
浏览器输入数据,感谢我在
Mysql
查询
浏览器中输入新记录后如何在服务器上更新我的表?有没有什么方法可以
同步
到表(在服务器和客户端)并将新记录发送到服务器? 谢谢
浏览 0
提问于2011-01-23
得票数 0
回答已采纳
1
回答
Flink
数据库
连接
mysql
、
connection-pooling
、
apache-flink
Flink
数据库
连接问题当我想用
Flink
sinkFunction to
MySQL
.The写或读一些数据时,每次操作的数据量都很小。但可能会同时调用多个sinkFuction。
浏览 2
提问于2017-10-16
得票数 0
1
回答
Flink
sql不向es集群写入数据?
java
、
elasticsearch
、
apache-flink
、
flink-sql
问题描述:我想通过sql
查询
mysql
中的数据,或者通过sql将其写入es集群。该程序可以成功运行,但es没有数据。version:
flink
: 1.11es: 6.2.2组: 1.2.1
mysql
: 5.7Below是我的代码<code>G 217</code> " 'connector' = 'jdbc'
浏览 1
提问于2020-12-09
得票数 0
2
回答
性能:
查询
外部
MYSQL
或HTTP到服务器上的PHP文件?
php
、
android
、
mysql
、
performance
、
external
我正在开发一个Android应用程序,它需要
查询
到外部
MYSQL
数据库
。要做到这一点,这是获得最佳性能和避免
数据库
收费过高的最佳方法: 将HTTP发送到PHP文件,并对
MYSQL
数据库
执行本地
查询
(请注意,使用这种方式,我可以在执行
查询
之前控制输入并播放
浏览 4
提问于2012-08-20
得票数 0
回答已采纳
2
回答
如何从
Mysql
数据库
创建DataStreamSource?
java
、
mysql
、
apache-flink
、
flink-streaming
、
flink-table-api
我在运行
flink
作业时遇到了问题,
flink
作业基本上是对
mysql
数据库
运行
查询
,然后尝试创建一个必须从不同作业访问的临时视图。select * from ***"; String sourceDb = "***"; String dbUrl = "jdbc:
mysql
resultStream = tableEnv.toDataStream(res
浏览 36
提问于2022-02-14
得票数 0
回答已采纳
1
回答
在推送Firebase
数据库
中的新值之前,如何检查是否存在相同的数据?
javascript
、
mysql
、
node.js
、
firebase
、
firebase-realtime-database
时间表应用程序有一个
mysql
后端,但我的应用程序有一个防火墙后端。到目前为止,我能够从
mysql
表中获取数据并将它们推入firebase
数据库
。// Connection to
MySql
sever.con =
mysql
.createConnection({ host: "localhost
浏览 0
提问于2018-01-31
得票数 1
回答已采纳
1
回答
Flink
的JDBC接收器失败,出现不可序列化错误
scala
、
apache-flink
我跟随使用
mysql
数据库
作为
Flink
的接收器。org.apache.
flink
.api.java.ClosureCleaner.clean(ClosureCleaner.java:151) org.
浏览 2
提问于2020-09-23
得票数 2
2
回答
一台机器上的
Mysql
同步
数据库
mysql
、
linux
我有
MySQL
数据库
。Database A和Database B.运行在
MySQL
5.5和Ubuntu12.04上。进入
数据库
A,我正在做INSERTs,UPDATEs每分钟(cron) (整个
数据库
有超过1500万行并在增长)。
浏览 0
提问于2013-01-12
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
MySQL数据库的查询操作
mysql数据库:查询,删除,插入
关系型数据库MySQL主从同步,读写分离
多表组合查询——Python操作Mysql数据库
基于MySQL和Otter实现生产环境安全的数据同步及查询
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券