我需要测试一个共享状态的CoFlatMapFunction。通过阅读，我得出结论，我应该使用per：https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling的TestHarness类 因为它不是公共api
浏览 104提问于2019-02-16得票数 0
回答已采纳
1回答
我已经写了一个小的flink应用程序。我有一些输入，并用来自外部源的数据来丰富它。它是一个RichAsyncFunction，在open方法中，我构造了一个用于丰富的http客户端。现在我想为我的工作写一个集成测试。但是由于http客户端是在open方法中创建的，所以我没有办法提供它，并在我的集成测试中模拟它。我试图在构造函数中重构它，但我总是得到序列化错误。这是我正在使用的示例：
提前感谢:)
浏览 28提问于2020-06-01得票数 2
下面提到的Apache测试代码在我想使用KeyedOneInputStreamOperatorTestHarnessK、IN、Int或Long作为key (K)参数时不会在Scala中编译。可以使用字符串、整数或java.lang.Long类型的泛型参数编译相同的代码：importval operator: KeyedProcessOperator[Int, TaxiRide,
浏览 7提问于2021-12-31得票数 2
2回答
有人知道如何在Flink中测试窗口函数吗？我正在使用依赖项flink-test-utils_2.11。我的步骤是：
public class AggregateVariantCEVTest
浏览 0提问于2019-06-25得票数 0
我有一个过程功能，我使用mockito进行单元测试。context, out) }
我们如何在这里测试计时器，在我的过程乐趣中，我已经注册了事件计时器，但是当我调试时在示例流程函数中向ctx.timerService().registerEventTimeTimer(ctx.timestamp() + 3000我们如何在这里测试flink计
浏览 2提问于2021-02-14得票数 0
回答已采纳
在用MiniClusterWithClientResource测试flink作业时，是否有办法控制触发 timer的处理时间？我能够测试KeyedCoProcessFunction的两种方法，即processElement().触发计时器回调，例如onTimer().在单元中，使用testharness测试并控制处理时间，即：//通过直接提高操作者的处理时间testHarness.setProcessingTime(300000)来触发处理时间定时器
浏览 2提问于2020-08-25得票数 0
我的直觉可能是正确的使用包装和/或分类器。为了为构建文件找到正确的导入标记，我建议查看.cache/bazel/bazel_user/.../external/maven/BUILD file我想使用Bazel构建工具测试我自己的异步flink流操作符RichAsyncFunction。这与的问题基本相同
主要的问题是，我找不到导入<em
浏览 0提问于2020-05-09得票数 1
我是flink的新手，我正在尝试编写junit测试用例来测试KeyedBroadCastProcessFunction。下面是我的代码，我目前正在调用TestUtils类中的getDataStreamOutput方法，并将输入数据和模式规则传递给方法，一旦输入数据根据模式规则列表进行评估，如果输入数据满足条件，我将获得信号并调用接收器函数我可以使用类似下面的CoFlatMapFunction来组合数据流，并在方法运行时继续发送输入规则，但对于这个数据流，必须再次从kafka主题中获取数据
浏览 130提问于2020-07-16得票数 0
在阅读了官方的flink测试文档()后，我能够使用Test Harness为ProcessFunction开发测试，如下所示： new OneInputStreamOperatorTestHarness[StaticAdequacyTilePublishedData()
现在，我试着对一个ProcessA
浏览 18提问于2019-11-01得票数 1
我们希望为使用Spring和Spring的项目编写测试。当我们在Kotlin中编码时，我们希望使用而不是Mockito，因为它更适合Kotlin代码风格和最佳实践。RabbitListenerTestHarness类为测试@RabbitListener提供了一些方便的特性，但是它返回了与MockK的Answer接口不兼容的Mockito的Answer接口的实现。是否有一种使用MockK的Mockit
浏览 5提问于2022-01-10得票数 0
回答已采纳
为了能够创建一些功能测试，我正在尝试遵循这个指南：
问题是，无论是InMemoryTransportCache类还是SetTransportProvider方法都不能导入。我在github上的MassTransit源代码中也找不到它们的声明。如何实现最上面链接描述的内容？
浏览 10提问于2020-03-05得票数 0
回答已采纳
2回答
我在一个类中有5到6个方法，并希望在不同的节点上并行运行这些方法。我已经设置了网格2，其中有4个节点。在我的testng.xml下面查找public WebDriver driver = null;
publ
浏览 4提问于2015-01-19得票数 1
我正在尝试创建一个具有处理所有异常的方法的类。它接受指向函数的指针，执行该函数，然后处理该函数是否抛出异常。然后，我创建了一个获取无效子字符串的函数来证明异常被捕获，然而，我的类没有获得异常，并且Visual Studio在子字符串行上断开了“异常未处理”。cpp文件：
浏览 1提问于2019-10-21得票数 0
1回答
是否可以在Selenium IDE中使用user-extsions.js创建自定义命令，并使其能够将自身更改为自定义导出格式?如果可以，如何更改？我将使用Selenium IDE来记录测试，这些测试将以完全自定义的Java格式导出，作为全自动测试系统的一部分运行。该格式不是JUnit，而是每个测试都是它自己的类，并根据系统整体的输入动态加载。我想要做的是在Selenium IDE中创建一个名为"takeScreenshot“
浏览 1提问于2012-10-12得票数 2
listState.add(unprocessedItem); // This part gets executed for listStateInput1 ....我正在使用testHarness来执行集成测试。当listState的TTL过期时，我正在测试listState项计数。下面是我的测试函数片段。有一个自定义allowedLateness，它使用自定义计时器.实现。// Actual: Gettin
浏览 2提问于2020-04-05得票数 2
3回答
我要使用apache运行简单的worcount示例。使用$SPARK_HOME/jars中的本地jar文件，它正确运行，但使用maven依赖于它的错误： <groupId>org.apache.flink</groupId>
浏览 19提问于2017-11-28得票数 0
回答已采纳
1回答
这是内存不足造成的吗？
、、、
当我使用chipyard编译Boom时，出现了这个问题。是因为记忆不足吗？我正在运行一个1核心2G云服务器。做了详细的阐述。包含更多信息的错误报告文件保存为:目标' generator_temp‘失败的generator_temp配方：*generator_temp错误1
我应该调整到8G内存，或者通过什么命令来增加进程可以使用的内存大小当我调整内存到16G时，出现了这样的情况。/chipyard.TestHarness.Larg
浏览 0提问于2021-03-09得票数 3
回答已采纳
我必须说的第一件事是，我不太确定如何表达这个问题，因为我对Xamarin并不熟悉。
using System;
namespace Demo.UnitTests中的文件Demo.UI.TestHarness.iOS中添加了对这个DummyTest的
浏览 2提问于2016-05-23得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
