apache-flink 相关问题

在Flink中检查事件时间水印

我们正在接受一个号码的活动。独立数据源，因此，到达我们的Flink拓扑（通过Kafka）的数据将是无序的。我们正在创建1分钟的活动时间窗...

为什么Flink使用Yarn？

我正在深入研究Flink，看看我如何在项目中使用它并对创建者/高级思考者提出问题...为什么Flink使用Yarn作为默认资源管理器？是......

FLINK：如何使用相同的StreamExecutionEnvironment从多个kafka集群中读取

我想从FLINK中的多个KAFKA集群中读取数据。但结果是kafkaMessageStream只从第一个Kafka读取。只有我有2个才能从两个Kafka集群中读取...

如何从Apache Flink写入Elasticsearch

我正在尝试将Flink连接到Elasticsearch，当我运行Maven项目时，我有这个错误：或者另一种方法，我使用这个例子：https：//github.com/keiraqz/KafkaFlinkElastic

Apache Flink：如何删除选择查询中的重复项？

如何使用Apache fFlink删除SELECT查询中的重复项？我的表是：我想删除ID中的重复项以保持最大范围

在Flink中广播HashMap

我正在使用Flink v.1.4.0。我正在使用DataSet API，我想尝试的一件事与Apache Spark中广播变量的使用方式非常相似。实际上，我想申请......

java.lang.NoSuchMethodError在flink进程中使用Java反射的异常

我正在尝试使用谷歌反射库扩展flink过程的业务逻辑。我在运行时遇到了这个异常。有人试验过同样的问题。我怀疑是maven冲突......

如何连接到flink elasticsearch版本6.2.2到flink 1.4.1

我使用elasticsearch 6.2.2作为flink中的接收器，但是在阅读apache flink文档时，我可以看到elasticserver版本5.x的连接器，但没有提到6.x的连接器。眨眼......

HTTP内容长度超过10485760字节 - Flink 1.5-SNAPSHOT

当我尝试向Flink 1.5-SNAPSHOT提交作业时，它会抛出异常org.apache.flink.shaded.netty4.io.netty.handler.codec.TooLongFrameException：HTTP内容长度超过10485760字节。一世 ...

无法在flink应用程序中的主节点和工作节点之间进行通信

我试图在多节点群集上运行flink应用程序。我发现slave节点找不到/root/miniconda2/bin/python2.7：无法打开文件'/ root / ranjan / logs / flink-dist-cache-3fc26a73 -...

Flink是否以有效的方式创建渠道？

我正在检查如何创建连接客户端的apache Flink代码：https：//github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/io/network /网状/ ...

尝试升级到flink 1.3.1时出现异常

我尝试将我的群集中的flink版本升级到1.3.1（以及1.3.2）并且我的任务管理器中出现以下异常：2018-02-28 12：57：27,120 ERROR org.apache.flink。 streaming.runtime ....

Flink：在Flink集群上执行Jar文件

我在2个不同的物理节点上使用flink集群和9个任务管理器。当我将罐子提交给Flink的Jobmanager（Master）时，罐子究竟发生了什么。我的意思是，罐子得到了......

如何使用flink流式传输json？

我实际上正在处理一个流，收到一堆字符串，需要计算所有字符串。总和是加重的，这意味着第二个记录的总和被添加到前一天...

Flink BucketingSink与NoClassDefFoundError崩溃：Lorg / apache / hadoop / fs / FileSystem

尝试使用flink的版本：1.4.0,1.4.1,1.4.2当我尝试使用这个简单的flink应用程序时，我需要使用val env：StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment env ....

无法让cURL命令在Postman中工作

我无法让我的cURL命令在Postman中工作。我迷失了Expect标头的工作原理。删除expect标头时，我的cURL命令中断。我甚至没有提供该标题的值？...

为Yarn Cluster中的Flink Job设置Flink Checkpoint的路径动态

我正在使用Yarn来运行Flink作业。对于每个Flink工作，我正在创建一个检查点。我提交了一个在我的Yarn集群中运行的Flink作业。我有一个民意调查工作，检查工作是否在纱线上失败...

如何使用Apache Flink阅读Cassandra？

我的flink程序应该对每个输入记录进行Cassandra查找，并根据结果进行一些进一步的处理。但我目前仍在阅读Cassandra的数据。这是......

任务不可序列化Flink

我试图在flink中进行pagerank基本示例，只需稍加修改（仅在读取输入文件时，其他一切都是相同的）我得到错误，因为任务不可序列化和...

Flink如何处理不适合内存的窗口和分区？

在阅读了Flink如何管理内存之后，传递给DataSet＃mapPartitions或KeyedWindowedStream #process的输入是否是一个惰性集合仍然不明显。有......