我有几个工作要合并。因为它们的数据源是相同的。所以我想把它们合并起来，就像下面的图片一样。 ? 我非常确定它们的源码使用了相同的表对象。我已经检查了flink的源代码，但没有帮助。
浏览 24提问于2019-09-27得票数 0
我想知道，Apache (v1.11)是否可以通过使用Table/SQL end-to-end-exactly-once 实现内置连接器 (Kafka，JDBC，)
我在文档里找不到任何关于这个的东西。
浏览 2提问于2020-12-02得票数 1
回答已采纳
我有两个源，一个是Kafka源，一个是自定义源，我需要一个小时的睡眠自定义源，但我正在低于中断。com.hulu.hiveIngestion.HiveAddPartitionThread.run(HiveAddPartitionThread.java:48) at org
浏览 66提问于2020-07-29得票数 0
1回答
我是Flink的新手，我需要从Kafka读取数据，通过使用一些API并写入S3，有条件地丰富这些数据(如果记录属于X类的话)。我用上面的逻辑制作了一个hello world Flink应用程序，它工作起来很有魅力。(选项1)进行指数重试，直到从API获得响应为止，但是这会阻塞队列，
浏览 1提问于2020-03-05得票数 0
回答已采纳
我正在尝试实现一个pyflink作业(通过表API)，它在源数据转换为标准格式之后，从多个源进行一些基本处理。我能够将每个源的数据转换为所需的格式(具有指定列的“表模式”)，但不能将数据设置为“处理表”以供进一步实现。这就是我想要的：
要将不同的源模式转换为标准的处理表方案(然后可以加窗)，可以实现一个<em
浏览 18提问于2021-12-06得票数 1
然后插入Sink选择field1，.从源表)如何使用Table . flink-table-common-1.15.2.jar) 对远程Flink服务器执行上述SQL，应用程序将显示缺少jars的错误，这些jars已在flink的/lib文件夹中可用(flink-连接器-1.15.2.jar，kafka-
浏览 3提问于2022-10-14得票数 0
当我们在作为SQL Server数据库表的源的Flink SQL CLI中选择任何表时，为什么Flink作业在从数据库表中获取所有记录后“完成”？有没有可能让它“运行”，这样它就可以从数据库表中获取最新的数据？
浏览 4提问于2020-12-25得票数 1
1回答
我的目标是建立一个高吞吐量集群，使用Kafka作为源，使用Flink作为流处理引擎。这就是我所做的。<WORKER_IP_ADDR>两个节点上的flink设置位于同名文件夹中。中的Flink依赖项。Kafka主题中时，我能够仅在主节点上解释来自我的<em
浏览 7提问于2015-08-28得票数 9
回答已采纳
我们希望在读取来自kafka的消息时实现并行性。因此，我们希望在flinkkafkaconsumer中指定分区编号。它将读取kafka中所有分区的消息，而不是特定的分区号。kafkaConsumer = new FlinkKafkaConsumer<String>("EventLog", new SimpleStringSchema(), properties); 请建议任何更好的选项来获得并行性
浏览 139提问于2020-07-09得票数 1
1回答
流在Hadoop中的应用
、、、、
我正在尝试学习的例子。在这个例子中，我确实看到他们创建了一个单独的应用程序(类似于流应用程序)，该应用程序生成和消费数据，并在数据上应用模式匹配。现在，我知道，如果我使用Kafka，那么我需要两个应用程序；一个用于将数据摄取到Kafka主题中，另一个用于消费Kafka主题的数据。我有几个问题我没有得到回答：
什么时候?在哪里需要流？？参考
浏览 2提问于2016-06-13得票数 0
我试图用Flink的KafkaSource运行一个简单的测试程序。我使用的方法如下：
import org.apache.flink.streaming.
浏览 3提问于2015-07-15得票数 5
我正在使用集群、Schema服务，并试图在Flink作业中处理Debezium消息。作业被配置为使用Table & SQL连接器和Confluent格式。(ConfluentSchemaRegistryCoder.java:74)我通过以下方法成功地测试了到Schema注册表的连接：
curl -u <SR_API_KEY>:<SR_API_SECRET> https://<SR_ENDPOINT
浏览 3提问于2021-02-08得票数 3
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。我翻阅了所有的文件，但没有找到详细的报告。
浏览 0提问于2018-06-21得票数 1
回答已采纳
我正在尝试连接到本地机器上的Kafka (2.1)，并在随Flink (1.7.2)附带的shell中阅读。我正在做的事情是：:require flink-connector-kafka-base_2.11-1.7.1.jar
import org.apache.flink.streaming.conne
浏览 0提问于2019-03-11得票数 1
回答已采纳
我正在为Flink 1.14.4编写一个简单的连接器(源/接收器)，它主要封装官方的Kafka连接器，并自动设置ups自定义序列化程序/反序列化器。我对和中引入的新源代码/接收器接口的当前状态有点困惑。目前是否可以编写统一的连接器，真的(也就是说，跨不同API(如DataStream/Table)的连接器)？通过查看当前Kafka连接器的代码
浏览 10提问于2022-04-13得票数 1
回答已采纳
我被困在这样的场景中，我需要使用来自2个或更多kafka主题的数据流(在应用过滤器之后)并对数据进行比较。由于数据量很大，请提出现有的最佳选择。弗林克有可能吗？
浏览 4提问于2020-02-04得票数 0
回答已采纳
1回答
我只看过Pyflink表API中不包含连接建立()中的身份验证细节的kafka连接示例，即源表连接： CREATE TABLE source_table/lib_py/kafka-clients-2.4.1.jar")
env.add_jars("file:///
浏览 4提问于2021-11-12得票数 0
回答已采纳
我正在使用flink从kafka流中读取数据，现在我想计算每秒事务处理量(TPS)。我观察到了一种通过在flink中使用窗口概念来实现这一点的方法，但目前还不能获得它。有人能帮我解决这个问题吗？提前感谢你的帮助！！。
浏览 7提问于2020-07-10得票数 0
我已经开发了一个Flink程序，可以读取Twitter上的推文，并将它们推送到Kafka上。然后，它从Kafka获取tweet并对其进行处理。"Tweets“转换从tweet的文本中提取标签和用户，并在默认输出中发出它们，并在副输出中发出它们的每一对。
附加的图像是从Flink Web UI中拾取的。我不明白为什么Kafka源和Tweets处理操作符<e
浏览 1提问于2018-06-30得票数 1
我有一个基于flink的流媒体应用程序，它使用apache kafka源和接收器。因为有时候我会在开发过程中的随机时间得到异常，我不知道它们是从哪里来的。我使用mainRunner类在IntelliJ中运行应用程序，并通过kafka向它提供消息。有时第一条消息会触发错误，有时只有在几条消息之后才会发生。.close(FlinkKafkaProducer011.java:662) [flink-connector-<e
浏览 111提问于2019-01-29得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号