由于numpy而安装apache-flink时，错误
我正在尝试使用 python3 -m pip安装apache-flink 或 pip3 install apache-flink clang: error: the clang compiler does not support 'faltivec', ple…
Flink-可以将表转换为dataStream
我设法使用Pyflink表API连接到运动型并处理数据流。我现在试图将此表转换为数据流，因为我需要更多的低级处理。 我已经尝试在此处按照此示例 https://…
Flink Python DataStream API Kafka消费者-NoclassDeffoundError bytearrayDeserializer错误
我在pyflink的PY4J侧有一个错误。代码下面： env = StreamExecutionEnvironment.get_execution_environment() env.add_jars("file:/" + os.getcwd() +…
如何将包含时间段_ltz的表转换为pyflink 1.15.0中的dataStream？
我使用pyflink 1.15.0的Kinesis连接器读取事件使用源表。 An example of the sorts of data that are in this stream is 请注意，数据流包含许多不同…
如何设置Flink TaskManager总截flink内存？
我想在Kubernetes上运行很多Pyflink作业，那里处理的状态和事件数量很小，因此我想在群集中使用尽可能少的内存，以便我可以大部分包装包装。有效。我…
当打印表结果时，pyflink的OP列是什么意思
当我使用pyflink SQL进行加入查询并打印结果时，有一些重复的行，其中OP列显示如“附件”屏幕截图，任何了解那是什么，我该如何产生非删除结果？提前…
如何将Python 3.7或3.8安装到OpenJDK Docker容器中，而无需从源头构建？
我想在Docker Hub上使用官方的Flink Image（ https://hub.docker.com/_./_// Flink ）与Pyflink一起使用（特别是1.14.4版本）。该图像基于 OpenJDK：1…
Pyflink应用程序的格式日志，具有不同模式的Python部分
我有一个在Pyflink中运行的Python应用程序。 是否有一种方法可以说“将此模式应用于Python代码产生的日志，而将其他模式应用于其他所有日志？” 我想…
UDF地图功能返回带有未命名模式的表
代码： func = udf(log_parser, result_type=DataTypes.ROW( [DataTypes.FIELD("ts", DataTypes.TIMESTAMP(precision=3)), DataTypes.FIELD("clientip…
我在运行以下pyflink代码时会遇到此错误
这是使用Apache Flink（Pyflink）从KAFKA源中计算每个CH [X]平均值的代码 我想我已经导入了所有必要的库 ，并且在运行代码 from numpy import average…
是否有一个在独立的存储库中进行pyflink SQL单元测试的示例？
是否有一个独立存储库的示例，显示了如何执行pyflink的SQL单元测试（如果可能的话，特别是1.13.x）？ 有一个相关问题在这里，建议在其中使用Pyflink中…
从Python中的Tweets Kafka生产商创建Pyflink DataStream消费者
我想在Pyflink中创建我流kafka消费者，该kafka消费者可以在DeSerialization（JSON）后读取推文数据， 我有PYFLINK版本1.14.4（最后一个版本） 我可以…
在管道部署时，建议在AWS EMR群集上自动化Flink Job的推荐方法
我是Flink和EMR群集部署的新手。目前，我们有一个flink的作业，我们正在通过Flink CLI Stop/Start-Job命令在AWS EMR群集上手动部署它。 我想自动化此…
