apache-flink 相关问题

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的输入是否是一个惰性集合仍然不明显。有......

Apache Flink - kafka生产者将消息传递给kafka主题，但在不同的分区上

现在我的flink代码正在处理一个文件并使用1分区将kafka主题上的数据下沉。现在我有一个带有2分区的主题，我希望flink代码在这两个分区上使用...

Flink：SocketWindowCount示例的结果不是我的预期

我是陌生人。我按照flink网站上的快速入门，在一台机器上部署flink。在我执行“./bin/flink run examples / streaming / SocketWindowWordCount.jar --port 9000”后输入...

我可以使用group by的自定义分区程序吗？

假设我知道我的数据集是不平衡的，我知道密钥的分布。我想利用它来编写自定义分区器以充分利用运算符实例。我知道 ...

Flink Twitter Streaming示例不适用于自定义端点

我正在扩展github上的flink连接器以获取自定义URL的twitter流，尽管我能够获得示例代码中给出的随机推文，但是当我给出自定义URL时，推文...