标签：apache-flink

  • Apache Flink:Python流API中的Kafka连接器，“无法加载用户类” - python

    时间：2020-8-12

    我正在尝试Flink的新Python流API，并尝试使用./flink-1.6.1/bin/pyflink-stream.sh examples/read_from_kafka.py运行我的脚本。 python脚本非常简单，我只是想从一个现有的主题中获取内容并将所有内容发送到stdout（或默认情况下output方法在其中发出输出数据的日志目录中的* .ou […]

    标签：, , , ,

  • kafka-> flink-性能问题 - java

    时间：2020-8-4

    我正在查看一些kafka主题，这些主题每秒产生约3万条消息。我有一个flink拓扑设置，可以读取其中之一，聚合一点（5秒的窗口），然后（最终）写入数据库。 当我运行拓扑并删除除读取->聚合步骤之外的所有内容时，我每分钟只能收到约3万条消息。没有任何地方会发生背压。 我究竟做错了什么？ 编辑： 我无法更改有关主题空间的任何内容。每个主题都有一个分区，并且 […]

    标签：, , ,

  • 如何在Apache Flink中加入两个流？ - java

    时间：2020-7-10

    我开始使用flink并查看one of the official tutorials。 据我了解，此练习的目标是将两个流加入time属性。 任务： 该练习的结果是Tuple2记录的数据流，每个不同的rideId一个。您应该忽略 END个活动，并且只能在每次骑行的START时加入该活动 其相应的票价数据。 生成的流应打印为标准输出。 问题：Enrichment […]

    标签：,