我发现在jdbc连接器的部分只有DDL和yaml格式的配置，我不知道如何使用them.so。我问的是在写flink app jar.if时如何从jdbc数据源读取流数据。如果数据源中的数据发生了变化，流是否会更新。
浏览 86提问于2020-06-23得票数 1
在开始使用新部署的Kafka流的更多数据之前，我们首先需要使用这些数据库中的数据。
我花了很多时间阅读Flink书籍和网页，但我有一些简单的问题和假设，我希望你能帮助我，这样我才能进步。首先，我想使用DataStream API，这样我们既可以使用历史数据，也可以使用实时数据。现在我正在尝试针对我们的生产数据库编写代码，我需要能
浏览 1提问于2021-08-10得票数 2
回答已采纳
是否可以在外部查询现有的StreamTable，而不上传.jar获取执行环境和检索表环境？由于Apache表1.4的动态(连续)表特性，我一直在等待它的发布。为了执行一些活动查询，而不是在数据流之上定义(连续的或仅附加的)数据库视图。我知道我可以将我的表导出到一些数据库中，并使用SQL动态查询这个数据库，但这是一种尴尬的行为。Flink的美妙之处在于，一切都是实时的，所有的东西都是流，那么是否可以从
浏览 5提问于2017-10-25得票数 2
回答已采纳
我的用例是
从AWS动态数据流中获取数据，使用flink数据流进行过滤/映射，使用StreamTable环境对数据进行分组和聚合，使用SQLTableEnvironment编写mysql，使用JDBC连接器编写我能够将我的数据存储结果写入mySQL表中，但是由于它在每一行后面都是流的
浏览 2提问于2021-05-04得票数 2
回答已采纳
2回答
如何在Flink转换中更新配置？
、、、、
给定一个Flink流作业，该作业将map()操作应用于流。因此，我正在寻找一种方式，让所有的Flink任务重新阅读一个新的配置在运行时。有没有可能
将KafkaSourcewait挂起，直
浏览 13提问于2022-10-11得票数 0
我在一个关系数据库中有一些批处理的数据，我想使用Flink将它们推送到消息总线上。由于Flink同时支持批处理和流模式，因此它看起来非常适合。话虽如此，我不知道这项任务是属于StreamingJob还是BatchJob，以及如何将两者联系起来。此任务是否更适合FlinkSQL环境？ 这个是可能的吗？我需要注意什么？
浏览 25提问于2021-04-28得票数 0
回答已采纳
2回答
使用Flink同步的进程2流
、、、、
我有两个流A和B。 我开始同时摄入A和B。 流A只在每分钟的59秒获得一条记录。 流B获取一分钟内的任何一秒的记录。 我希望处理两个流是同步的。示例:从流A在10:01:59之后，我将在10:02:59收到一条记录，直到10:02:59我也不想从流B读取任何内容。 这可以在Flink中实现吗？
浏览 49提问于2021-01-21得票数 0
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。
浏览 0提问于2018-06-21得票数 1
回答已采纳
1回答
流在Hadoop中的应用
、、、、
在这个例子中，我确实看到他们创建了一个单独的应用程序(类似于流应用程序)，该应用程序生成和消费数据，并在数据上应用模式匹配。他们现在还没有在.Till(如卡夫卡)之间放置一个流层，单应用程序就足以满足这一目的，这使得它非常优化。现在，我知道，如果我使用Kafka，那么我需要两个应用程序；一个用于将数据摄取到Kafka主题中，另一个用于消费Kafka主题的数据。我有几个问题我没有得到回答：
为什么在这个例子中他们没有使用</
浏览 2提问于2016-06-13得票数 0
我是Flink的新手，我使用的是Flink 1.3(旧版本，但我的公司已经使用了这个版本...)来编写流应用程序。这个应用程序涉及连接一个流(来自kafka)和两个静态Hive表(每天更改一次，两个表大约有1亿行)，此时，我想知道应该使用哪种
浏览 0提问于2019-09-23得票数 0
我想使用flink-jdbc从mysql获取数据。它是这样的import org.apache.flink.api.java.ExecutionEnvironmentimport org.apache.flink.api.java.io.jdbc.JDBCInput
浏览 14提问于2017-07-09得票数 0
2回答
让我们举一个简单的例子，我有一个非常简单的波束管道，它只是从一个文件中读取数据并将数据转储到一个输出文件中。现在，让我们考虑输入文件是巨大的(一些GB的大小，您通常无法在文本编辑器中打开的文件类型)。由于直接运行程序实现非常简单(它将整个输入集读入内存)，它将无法读取和输出这些大型文件(除非您为java vm进程分配了不太实际的大量内存)；因此，我的问题是：“像flink/spark/云数据流这样
浏览 2提问于2021-07-01得票数 0
回答已采纳
FLINK Stream接口socketTextStream(主机名，端口)方法作为客户端。也就是说，我们需要在端口上发送连续的流，“socketTextStream (hostname，port)”方法将读取传入的流。但我的要求是，我想使用FLINK作为服务器，并寻找一个可以从端口侦听的API。任何人都可以拥有FLINK stream API吗？这会解决我的问题。提前感谢！
//
浏览 2提问于2017-04-27得票数 2
我已经编写了flink作业来使用数据集和数据流api。我已经从相同的main()方法启动了这两个程序，但现在当我将作业提交到flink Dashboard时。只有dataset api程序正在运行，仪表板显示作业已完成，流未被触发，flink仪表板也未显示有关数据流执行的任何内容。但是，当我从eclipse运行时，数据集和<em
浏览 16提问于2017-07-12得票数 1
我已经修改了我的WordCount，以便从文本文件和csv文件中获取输入，并且它可以工作。
为什么Eclipse找不到导入？因为在jar flink-java-0.8.1.jar中没有io/jdbc目录。我在flink-0.9.0-bin-hadoop
浏览 2提问于2015-07-02得票数 1
回答已采纳
当我们在作为SQL Server数据库表的源的Flink SQL CLI中选择任何表时，为什么Flink作业在从数据库表中获取所有记录后“完成”？有没有可能让它“运行”，这样它就可以从数据库表中获取最新的数据？
浏览 4提问于2020-12-25得票数 1
1回答
我正在使用Flink流API，我希望继续从文件夹中读取CSV文件，忽略头文件并将CSV文件中的每一行转换为Java类(POJO)。在完成所有这些处理之后，我应该获得一个Java对象流(POJO)。从CSV文件中获取字符串流
String path = "/home/cosmin/Projects/
浏览 2提问于2017-08-02得票数 2
1回答
我正在尝试使用Flink 2.1.0从mysql日志表中读取流数据，但是，它只读取一次，然后它将停止该过程。我希望它继续读取，如果有传入的数据，并打印它。env.createInput( .setDrivername("com.mysql.jdbc.
浏览 72提问于2017-02-22得票数 2
我想知道，无论如何，Flink的数据流API是否可以用来从传入的记录中删除重复项(可能是在特定的时间窗口内)，就像Dataset API一样，它提供了一个称为"Distinct“的转换。或者，如果数据集被转换为数据流以便在Flink中进行内部处理，则无论如何都可以将该数据集转换为数据流。
在这方面请帮
浏览 1提问于2020-03-05得票数 0
我使用flink从文件中读取数据并将其转换为流，然后处理stream.But当我从文件中读取数据并将其转换为流时，这样形成的数据流中的内容与文件中的数据顺序不同。根据我的要求，数据在文件和流中的顺序很重要。有人能在这方面帮我吗？谢谢
浏览 3提问于2017-06-21得票数 1
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
