1回答
我已经构建了一个非常小而直接的Flink应用程序，它使用来自Kafka (json)的事件，将它们反序列化为Java对象，然后创建两个Table，并使用Table API进行一些简单的操作，最后连接这两个表如何编写集成测试来验证用Table API编写的代码是否产生了正确的结果？
(使用Flink 1.8.3)
浏览 12提问于2020-05-16得票数 1
1回答
我正在尝试将Flink与Kafka集成，并读取Kafka producer的数据。我尝试按照flink-docs-release-1.11文档中的代码运行以下代码 import java.util.Properties;import org.apache.flink.streaming.api.datastream.DataStre
浏览 23提问于2021-02-11得票数 0
/libs/cep.html教程中所示的CEP.pattern(input,pattern)来创建一个PatternStream时，集成开发环境说它“无法解析重载方法”，它指的是pattern方法。package FlinkCEPClasses
import org.apache.flink.api.common.serialization.SimpleStringSchemaimport org.apache.flink.streaming.
浏览 50提问于2020-01-14得票数 0
回答已采纳
我使用的是Flink 1.15.1和JUnit5。我想知道从中改编的下面的集成测试是如何工作的，而不包含flink-test-utils依赖项和MiniClusterWithClientResource静态实例。;import java.util.List;import org.apach
浏览 38提问于2022-08-09得票数 0
回答已采纳
我有以下代码来测试flink和hive集成。我通过flink run -m yarn-cluster ....提交申请。hiveConfDir是一个本地目录，驻留在我提交应用程序的机器上，我想问一下，当主类在集群中运行时，flink如何能够读取这个本地目录？谢谢!package org.example.app
import org.apache.flink.table.
浏览 48提问于2021-01-05得票数 0
我想分析一下Flink对RocksDB进行的每个应用程序接口调用所用的时间。但是，我找不到这些函数。我尝试在IDE中设置Flink的完整源代码，将我的流式示例集成到源代码中，启动调试器并执行许多调用，但都是徒劳的。示例如下： package org.apache.flink.streaming.examples.spendreport;
import org.apa
浏览 21提问于2020-07-27得票数 0
回答已采纳
1回答
我正在尝试将Apache Kafka 2.11-0.10.0.0与Apache Flink 1.1.2集成。我正在使用scala-shell对其进行测试，并得到以下错误。找不到类org.apache.flink.streaming.api.checkpoint.CheckpointNotifier
我已经将org.apache.flink.streaming jar添加到类路径中我一直导入到org.apache.flink.streaming.api.checkpoin
浏览 13提问于2016-09-15得票数 1
回答已采纳
Flink 1.14标记FlinkKafkaProducer，并用新的KafkaSink类替换它。我试图在MiniClusterWithClientResource集成测试中引入一种新方法，类似于这里所描述的：。我设法克服了这个问题，在我自己的KafkaSink包中继承了apache.flink.connector.kafka.sink类，但是，必须有更好的方法来处理测试，否则新的API并不是真正的测试友好型。package org.apache.flink.connector.kafka.sink;
浏览 9提问于2022-02-01得票数 1
在集成测试中测试flink mini集群上的流时，我遇到了一个问题。该流映射一个生成的Avro Java类( SpecificRecord )。 流作业是用Scala编写的。flink运行时正在崩溃，因为它无法实例化org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils 下面是堆栈跟踪： stack: java.lang.ClassCastExceptionnot instantiate org.apache.flink.formats.av
浏览 38提问于2020-09-25得票数 0
我在集成开发环境中运行了以下简单的flink应用程序，并且每隔5秒执行一次检查点操作，并希望将检查点数据写入目录file:///d:/applog/out/mycheckpoint/，但在运行了一段时间后下没有找到任何内容 代码是： import java.util.Date
import org.apache.flink.api.common.stat
浏览 20提问于2019-09-26得票数 0
回答已采纳
根据集成测试部分import java.lang.Longimport org.apache.flink.streaming.api.functions.sink.SinkFunctionimport org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironme
浏览 1提问于2018-03-07得票数 0
回答已采纳
下面是我观看的演示文稿中关于Flink优化器的幻灯片。对于Flink的优化器根据提供的数据集的基数来决定并行性的评论，我特别感到困惑。我目前正在阅读Flink 1.4 (我正在使用的版本)文档，我似乎找不到任何关于Flink关于并行性的决定的文档。，我是否需要为Flink的优化器提供有关数据集的统计信息，以便利用这个特性？
在相关的说明中，我认为通过指定一个maxParallelism值，这可能使Flink能够动态地确定哪个级别的并行性适合于提供的数据集(如上面所详述的)。但是，
浏览 0提问于2019-05-20得票数 1
回答已采纳
1回答
我是Flink的新手，我需要从Kafka读取数据，通过使用一些API并写入S3，有条件地丰富这些数据(如果记录属于X类的话)。我用上面的逻辑制作了一个hello world Flink应用程序，它工作起来很有魅力。(选项1)进行指数重试，直到从API获得响应为止，但是这会阻塞队列，因此我不喜欢这样
选项2)使用另一个主题(称为主题失败)，并在API关闭时将其发布到。同样
浏览 1提问于2020-03-05得票数 0
回答已采纳
我使用的是Flink 1.13.0，下面是简单的代码片段import org.apache.flink.table.api
浏览 1提问于2021-05-15得票数 0
回答已采纳
文档没有提到S3是一种潜在的集成，但我假设它是本地支持的。(BucketingSink.java:351)at org.apache.flink.streaming.api.functions.util.StreamingFunctionUtils.resto
浏览 2提问于2017-04-11得票数 0
回答已采纳
import java.util.Properties
importorg.apache.flink.streaming.api.org.apache.flink.api.scala._import org.apache.flink.cep.patte
浏览 3提问于2020-03-02得票数 0
回答已采纳
我使用Flink 1.3.2与来自flink连接器的hbase (flink-hbase_2.11)，使用DataSet API。在我的测试表中，没有人会写到这个表。(我通过flink web仪表板获得了这个数字，但是我可以从写到的东西中看到效果
我不能通过使用更小的数据集来使问题更小，因为在对一个包含500万条记录的表运行作业时，这个问题不会发生。
浏览 2提问于2017-12-07得票数 0
; at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:730)
at org.apache.flink.streaming.api
浏览 22提问于2020-03-04得票数 0
1回答
我有一个与千分尺集成的非开机弹簧应用程序。现在，我们正在使用LoggingRegistry将这些指标推送到日志文件中。我们想要增强这个项目，以在Rest API中公开这些指标(我们不能使用致动器，因为打开自动配置会导致我们的非引导应用程序中出现问题).Is有没有办法公开这些由Rest API中的测微器自动提供的指标？
浏览 4提问于2021-11-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
