我问的是在写flink app jar.if时如何从jdbc数据源读取流数据。如果数据源中的数据发生了变化，流是否会更新。
浏览 86提问于2020-06-23得票数 1
1回答
为了丰富数据流，我们计划将MySQL (MemSQL)服务器连接到现有的flink流应用程序此外，我还发现了另一个名为Flink-CDC https:&
浏览 19提问于2022-02-07得票数 0
回答已采纳
1回答
我想知道是否有可能同时使用Flink实现端到端的精确语义？来源: kafka进程: flink接收器:数据库(mysql或redis)谢谢。
浏览 2提问于2022-09-26得票数 -1
1回答
我正致力于从一个数据库加载数据到另一个数据库的各种方法。它可能/可能不是NoSQL、SQL或关系数据库管理系统。我在考虑Flink如何有效地执行接收器和源。与传统的数据加载方法相比，Flink能否将数据加载小于50%？
浏览 7提问于2022-08-14得票数 0
当我们在作为SQL Server数据库表的源的Flink SQL CLI中选择任何表时，为什么Flink作业在从数据库表中获取所有记录后“完成”？有没有可能让它“运行”，这样它就可以从数据库表中获取最新的数据？
浏览 4提问于2020-12-25得票数 1
1回答
Flink数据库连接问题当我想用Flink sinkFunction to MySQL.The写或读一些数据时，每次操作的数据量都很小。但可能会同时调用多个sinkFuction。
浏览 2提问于2017-10-16得票数 0
1回答
我正在尝试使用Flink 2.1.0从mysql日志表中读取流数据，但是，它只读取一次，然后它将停止该过程。我希望它继续读取，如果有传入的数据，并打印它。env.createInput( .setDrivername("com.mysql.jdbc.Driver")
.setDBUrl("jdbc
浏览 72提问于2017-02-22得票数 2
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。
浏览 0提问于2018-06-21得票数 1
回答已采纳
我正在使用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回答
我已经创建了一个应用程序，我从Kinesis streams读取数据，并将数据存入mysql表。 prop.setProperty("hibernate.connection.driver_class", "com.<em
浏览 1提问于2021-03-05得票数 0
Streaming non window left outer join是flink1.6中的一个新特性。当我在两个动态表之间执行此操作时。join结果顺序错误。如何正确使用此功能？NonWindowJoin左表的状态和右表的状态都使用flink托管状态MapState。当我查看flink的non window join代码时。因此，如果流事件来自mysql数据库的binlog，则MapState[Row, JTuple2[Long, Long]]将始终附加(而不是更新)。该MapState将记录
浏览 1提问于2018-10-12得票数 0
我有一个小的flink应用程序，它从一个卡夫卡主题中读取，在处理它之前，需要询问来自主题(x)的输入是否存在于MySql数据库的一个列中(这并不理想，但它符合当前的要求)来自Flink服务器的错误java.lang.ClassNotFoundException: com.mysql.jdbc.Driver------------------
d
浏览 0提问于2018-04-10得票数 0
你好，Flink社区， 按照解决Flink中动态加载类卸载问题的文档，我将数据库驱动程序库添加到运行在K8s上的Flink JobManager容器和TaskManager容器上的opt/flink/lib文件夹中(Flink Session Cluster，版本: 1.11)。现在，当我使用flink API (upload and run endpoints)向Flink集群提交作业时，由于以下错误，它不会接受
浏览 104提问于2021-02-05得票数 0
我有一个cron job，它调用以下codeigniter controller计算和操作更多的操作(平均需要5分钟)<?'; }没有两行第1行/第2行SQL Error: 2006: MySQL server has gone away我们面对Severity:
浏览 6提问于2017-01-04得票数 0
我跟随使用mysql数据库作为Flink的接收器。org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:151) org.
浏览 2提问于2020-09-23得票数 2
9091', 'format' = 'csv',)mysql_sink_ddltotal_download BIGINT, ) WITH (
'connector.type' = 'jd
浏览 48提问于2022-01-14得票数 0
回答已采纳
我正在尝试运行一个Flink客户端应用程序，在这里我从一个文件中读取数据。应该使用ProcessFunction操作符根据数据库中的记录验证文件中的每条记录。我已经配置了一个单吨设计模式的数据源。我有以下问题
在Open中创建处理器内的数据源连接，只使用一个作为最大连接池大小，这是一个好主意吗？
浏览 4提问于2021-06-09得票数 0
回答已采纳
如果在一定时间内没有从流接收数据，那么如何使用Flink的DataStream API实现运算符发送事件？
浏览 1提问于2017-11-01得票数 10
回答已采纳
3回答
我正在创建一个使用JDBC从数据库(MySQL)加载数据的应用程序。我的应用程序在一段时间内工作正常(大约50分钟)。这个程序使用了定时器，所以我可以刷新一些JFrame来显示数据库中的变化。问题是，一段时间后，它显示从数据库加载错误，它不显示错误加载特定的表，而是随机加载表。我使用这段代码从数据库加载，并且多次使用它来处理我的数据库中的许多表
package <
浏览 1提问于2013-03-17得票数 0
回答已采纳
我有一个使用Apache Flink (flink版本: 1.8.1)的作业流，使用scala。有如下流作业要求: Kafka ->写入Hbase ->再次发送到kafka使用不同的主题 在写入Hbase的过程中，需要从另一个表中检索数据。为了确保数据不为空(NULL)，作业必须(在一定时间内)重复检查数据是否为空。 Flink可以做到这一点吗？如果是，您能提供与我的需求类似的情况的示例吗？那么，是否可以在流式flink作业中创建批处理<e
浏览 46提问于2020-12-21得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
