回答情况：
提问时间：
问题标签：
我们有一个execute()方法，其中我们使用FlinkKafkaConsumer08作为我们的Flink CEP源，然后我们有CEP模式，并且alert再次进入另一个kafka主题。如何为这个execute()方法编写一个junit测试用例？有没有人能为我提供一个样例junit代码？ Pattern.
浏览 37修改于2019-01-03得票数 0
回答已采纳
我想创建一个用scala编写的flink项目。当我导入时'flink-streaming-scala_2.11'我可以运行如下代码：但我看到每一个都是这样：
fl
浏览 6提问于2017-07-23得票数 0
回答已采纳
我一直在使用Apache编写一个原型应用程序。在此过程中，我选择将org.apache.flink.streaming.api.functions.windowing.WindowFunction用于特定的用例。但是，在编写application ()函数的主体时，我遇到了这个错误(下面的代码不是来自我正在编写的应用程序--我的数据类型不同--它与Flink文档站点中提供的示例代码不同)：
import scala.collection.Iterableimport s
浏览 2修改于2016-09-09得票数 2
这个框架部分是用Scala编写的，在执行单词计数示例时，会抛出一个异常(还有许多其他的异常，我不会发布)：at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:173)
at org.apache.flink.api.java.LocalEnvironment.execute除了例外情况，Android设备似乎无法运行scala代码(如果我错了，请纠正我)。我已经找到了很多关于安卓和scala的帖子，但它们似乎更多
浏览 4修改于2017-05-23得票数 0
回答已采纳
我使用intellij、maven 3和flink 1.15.1编写有状态流作业。我正在尝试为我的自定义KeyedProcessFunction编写单元测试，并尝试遵循文档以及添加提到的的依赖项。Flink >= 1.15.0现在不需要scala相关库，因此对于1.15.1没有flink流-java_2.12。
我想要使用的类是移到其他地方还是故意被排除在外？我已经尝试过我所知道的所有google，并且我可以在flink回购中找到这个类，但在我迄今为止尝试过的任何一个fli
浏览 8提问于2022-08-01得票数 1
回答已采纳
我正在遵循这个指南https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/datastream/kafka/并编写代码 FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>(TOPIC_IN, new SimpleStrin
浏览 92提问于2021-08-28得票数 0
我希望在Flink中加载最新的检查点，但它不是。我已经编写了一个字数统计应用程序，它的目的是在重启后重新开始计数。我从我的IDE运行它，所以我不会启动一个Flink集群。这是我写的https://github.com/edu05/wordcount/tree/simple代码，它的灵感来自于Flink创建者提供的检查点示例……https://github.com/streaming-with-flink</e
浏览 15提问于2019-05-31得票数 0
您好，我正在编写flink介绍，但我无法正确导入 import org.apache.flink.streaming.api.datastream.DataStream;import org.apache.flink.walkthrough.common.sink.AlertSink;
import org.apache.flink
浏览 139提问于2020-08-31得票数 1
回答已采纳
我已经构建了一个非常小而直接的Flink应用程序，它使用来自Kafka (json)的事件，将它们反序列化为Java对象，然后创建两个Table，并使用Table API进行一些简单的操作，最后连接这两个表，并将结果写回Kafka(使用Flink 1.8.3)
浏览 12提问于2020-05-16得票数 1
使用Apache版本1.3.2和Cassandra 3.11，我编写了一个简单的代码，使用Apache连接器将数据写入Cassandra。.setHost("127.0.0.1") env.execute();import org.apache.flink.api.common.functions.MapFunction;
浏览 2修改于2018-03-24得票数 4
回答已采纳
我正在用Apache Flink编写一个流媒体服务。我基本上是使用org.apache.flink.table.sources.CsvTableSource.从CSV文件中挑选数据。下面是相同的代码： .getTableEnvironment>
<groupId>org.apache.flink<
浏览 4提问于2018-03-06得票数 3
我遵循()并编写了下面的代码片段，用一个简单的TextInputFormat在dir中处理.gz日志文件。它在我的本地测试目录上工作，扫描并自动打开.gz文件内容。库：
/opt/flink/lib/flink-csv-1.13.2.jar:/opt/flink/lib/flink-json-1.13.2.jar:/opt/flink/lib/
浏览 6提问于2021-12-21得票数 1
回答已采纳
当打包使用flink连接器和第三方库(用于处理)的flink作业时，哪些依赖项应该在jar中结束，这样就可以使用("flink run jarfile")在flink集群中启动它？如果用scala编写作业，是否在jar中包含scala默认库？
我没有找到任何有关如何打包flink的作业的文档。
浏览 1提问于2016-06-17得票数 0
回答已采纳
我正在编写一个从kafka消费的flink应用程序
FlinkKafkaConsumer<MyPojo> consumer = new FlinkKafkaConsumer(TOPIC, new MyPojoDesorg.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:577) at org.apache.flink.streaming.runti
浏览 2提问于2020-12-08得票数 0
试图把这个映射到Flink计数器。因此，应将flink计数器报告为StatsD的量值。还是Flink会重置计数器？
浏览 2提问于2020-01-23得票数 0
如何将PyFlink性能与Flink + Scala进行比较？因此，Apache是纯流的，而不是Spark的微批，我倾向于选择Apache。但我唯一关心的是PyFlink的性能。它比Scala编写的Flink代码慢吗？在什么情况下更慢？
提前谢谢你！
浏览 3提问于2021-11-05得票数 1
回答已采纳
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev这是我写的代码。我知道它不完整，但自从这个问题出现后，我无论如何都不能完成它。/flink-cep-scala
libraryDependencies += "org.apache.flink&
浏览 50提问于2020-01-14得票数 0
回答已采纳
我有一份Flink的工作，把数据写进卡夫卡。Kafka主题的最大消息大小设置为5MB，所以如果我尝试编写任何大于5MB的记录，它会抛出以下异常并将作业降低。(FlinkKafkaProducerBase.java:373)at org.apache.flink.streaming.api.operators.Abstra
浏览 1修改于2019-09-13得票数 1
回答已采纳
我和我的团队正在开发一个利用Flink的应用程序。数据将使用计算量大的数值算法进行处理。为了尽可能地优化它，我想用C/C++而不是用Java编写这个算法。问题是:在Flink中可以使用C/C++代码吗？或者把它封装到Java库中？
浏览 2修改于2016-12-01得票数 2
回答已采纳
我正在编写一个Java项目，使用Apache在Dockerized数据库中创建一个表。正如文档提供的那样，我编写了以下代码行以定义流环境： <groupId>org.apache.flink</groupId>
浏览 6修改于2021-12-24得票数 4
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号