Flink Oracle连接
我正在使用支持 Flink 1.13 的AWS Kinesis Studio。我看到Flink 1.13不支持Oracle连接。 基于版本1.13的文档，它支持 mysql，Postgresql，derby。 我…
我有一个kafka dataStream，想使用pyflink对数据进行一些计算？
我想计算平均 电源[x] = ch [x]*（（60/5）*100/500）瓦特和 消耗的能量[X] = CH [X]/500KWH CH1-CH6是能量测量值，我将附加一个图像，即Kafka的数据…
当JSON模式变化时，如何在Pyflink SQL中引用嵌套的JSON？
我希望使用Pyflink进行一系列事件，其中这些事件是从AWS EventBridge中获取的。此流中的事件共享许多公共字段，但是它们的详细信息字段根据 source> s…
运行第一个 Flink python 代码时出现问题
我想运行第一个flink代码，因此我创建了一个虚拟环境，然后运行它：python tab.py 我发现： 我的pyflink设置有什么问题udfs抛出py4j例外吗？ 但这无效…
在接收非重要类型的数据流（使用PYFLINK）的数据流时，如何在Flink SQL中指定表格？
Flink SQL 应用程序从 AWS Kinesis Data Stream 接收数据，其中接收到的消息采用 JSON 格式，架构以 JSON Schema 表示，并且包含一个不是原始对象的属…
如何查找标识符“elasticsearch-7”的任何工厂实现“org.apache.flink.table.factories.DynamicTableFactory”；在类路径中
我正在尝试使用Table API和Elasticsearch作为水槽创建一个Pyflink应用程序。 from pyflink.table import TableEnvironment, EnvironmentSettings def …
使用REST API调用Flink有状态函数
我正在使用Python编写Apache Flink StateFun应用程序。我正在寻找帮助/指针，以通过REST帖子/获取电话调用现有的状态功能。 我提到 在这里，似乎已经…
我已经使用 PyFlink 配置了我的 Flink 应用程序，但我想更改作业名称
我已使用 PyFlink 配置 Amazon Kinesis Data Analytic，但我想将作业名称更改为我想要的任何名称。我该怎么做？ …
AWS Kinesis Data Analytics：具有嵌套 JSON 数据的 PyFlink
通过 Kinesis 分析 SQL 应用程序，我们可以选择配置输入架构。这样我们就可以将输入数据映射到平面结构。所以我正在寻找与 Kinesis Data Analytics Ap…
PyFlink 14.2 - 表 API DDL - 语义恰好一次
我曾经遇到过这样的场景：我定义了一个 kafka 源，UDF |用于处理并接收到 Kafka 接收器的 UDTF。无论我做什么，如果我运行该作业，输出都会充满单个输…
导入错误：无法导入名称“编码器”来自“pyflink.common”
从 pyflink.common 导入 WatermarkStrategy、编码器、类型 运行上面的代码出现以下错误： ImportError：无法从“pyflink.common”导入名称“Encoder”…
是否可以在 flink 中对动态表运行批处理
目前，我通过以下步骤在同一个表上运行多个变体结构化 ETL 作业： 将数据从 RDBMS 持续同步到数据仓库。 在不同时间运行多个ETL（数据仓库中相应时间…
