我已经用Flink编写了一个小测试用例代码来对数据流进行排序。env.setParallelism(2); DataStreamsortOutput.p
浏览 38提问于2021-05-17得票数 0
回答已采纳
我是Apache的新手，我尝试过滤以字母"N“开头的单词，并得到输出，但是我如何获得不以单词"N”开头的单词，这是我正在使用的代码import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.tu
浏览 1提问于2020-05-12得票数 0
回答已采纳
我正在使用Flink DataStream API中的DataStream类来实现像用例这样的超时。场景如下:我有一个输入kafka主题和一个输出Kafka主题，一个服务从输入主题读取它(在可变的时间内)，然后在输出kafka主题中发布响应。现在要实现超时(必须使用Flink datastream )，我有一个从kafka输入主题读取的FlinkKafkaConsumer，以及从kafka输出主题读取的另一个FlinkKafkaConsumer我正在连
浏览 1提问于2020-09-15得票数 0
回答已采纳
我正在遵循Flink官方文档中的示例，试图了解connectedStreams是如何工作的。下面是示例：https://ci.apache.org/projects/flink/flink-docs-master/learn-flink/etl.html#connected-streams publicException {
StreamExecutionEnvironment env = StreamExecutionEnvironment.g
浏览 45提问于2020-07-24得票数 0
回答已采纳
DataStream<String> sourceStream = streamEnv.fromElements("key_a", "key_b", "key_c", "key_d")在使用更大的生产数据集之前，我想了解如何使用Flink API在玩具数据集上实现这一点。有关表连接的文档显示了如何连接两个表并取回另一个表，这不是我想要的： https://ci.apache.org/projects/flink
浏览 66提问于2021-04-25得票数 0
回答已采纳
我希望使用架构信息将DataStream转换为DataStream参数DataStreamargs1模式 optional binary country (UTF8);}{"country":"china", "city&
浏览 19提问于2020-03-07得票数 0
我正在尝试实现一个简单的闪光作业，使用org.apache.flink.streaming.connectors，将一个卡夫卡主题作为输入源和输出到一个卡夫卡接收器。我正在遵循这个指南https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafkaTOPIC_TEST, new SimpleStr
浏览 92提问于2021-08-28得票数 0
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;import or
浏览 3提问于2017-07-11得票数 1
回答已采纳
例如，我的问题是如何从DataStream转换为List，以便能够遍历它。package flinkoracle;
//....RowTypeInfo rowTypeInfo = new RowTypeInfo(fieldTypes); DataStream
浏览 7提问于2018-04-25得票数 2
0回答
我对flink非常陌生，并尝试了flink文档中给出的一些代码。flink文档中的代码： public long count;
this.word = word; }
DataStreamWordWithCount(&quo
浏览 5提问于2016-07-12得票数 3
在使用Flink 1.55及其表API的流式应用程序中，我需要检测和处理延迟元素。我找不到替代DataStream应用编程接口.sideOutputLateData(...)的功能。我试着在Flink文档、https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/table/tableApi.html和谷歌中搜索了很多次
浏览 36提问于2019-06-19得票数 2
2回答
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSource(dataPacket => new String(dataPacket.getC
浏览 0提问于2017-07-17得票数 0
回答已采纳
如果我使用DataStream<Insert>，我会得到一个令人困惑的RuntimeException。预期输出(使用DataStream<Statement>)：Exception in thre
浏览 9提问于2017-01-17得票数 0
回答已采纳
我发现在Stackoverflow和其他网站上有关这个问题的很多问题都有相当长的历史，或者是关于不推荐的API，或者没有完全回答这个问题。Flink有两个APIs - DataStream和Table --它们可以在batch或streaming执行模式下运行。不建议使用DataSet API。flink如何处理大型数据?它是否溢出到磁盘？
DataStream API -我没有找到任何显式的API来进行排序。减值函数将输出排序分区。但是为了得到一个全局排序
浏览 17提问于2022-04-27得票数 0
回答已采纳
我从官方的flink存储库使用以下docker-compose.yml启动了flink。我只添加了到外部hadoop网络的连接。version: "2.1"
hadoop: name: flink_hadoop
jobmanager:image: flink:1.7.1-hadoop27-scala_2.11 do
浏览 1293提问于2019-01-04得票数 2
回答已采纳
该程序没有抛出任何错误，也没有提供所需的输出。根据代码，程序应该创建一个新的文本文件，但在执行时没有生成任何文件。请帮助，我的代码附在下面。from flink.plan.Constants import WriteModefrom flink.functions.FlatMapFunctionimport FlatMapFunction
from flink.functions.GroupReduce
浏览 2提问于2022-01-12得票数 0
我是Flink的新手。我正在尝试使用Flink 1.3.2来读取我们的Kinesis流，并将输出写入Cassandra表。该程序能够从Kinesis流式传输数据。问题是，当我执行“CassandraSink.addSink(CountsStreaming)”时，它给出“类型不匹配。预期: DataStreamNotInferredIN，实际: DataStream(String，Long)”。我已经阅读了文档和源代码，并注意到addSink使用DataStreamIN。env.addSource(new
浏览 0提问于2017-12-01得票数 0
为什么我不能看到作业在仪表板()上运行，但是如果我看到日志文件(尾-f日志/flink-客户机-*-T430.log)，我可以看到正在处理的东西？此外，print()方法正在将输出溢出到控制台。/bin/flink run examples/explore-flink.jar -c启动我的应用程序import org.apache.flink.streaming.api.datastream.<e
浏览 0提问于2019-02-01得票数 0
回答已采纳
'flink-core', version: '1.9.0' myConsumer.setStartFromEarliest(); // start from the earliest record possible
浏览 4提问于2020-03-09得票数 0
回答已采纳
1回答
我正在尝试制作一些scala函数，这些函数可以帮助flink、map和filter操作将错误重定向到死信队列。 val mapped = source.map[R])org.apache.flink.stre
浏览 8提问于2021-12-16得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号