同一段代码，在main里面可以正常正常，在Test里面却直接结束
StreamExecutionEnvironment bsEnv =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings bsSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
StreamTableEnvironment bsTableEnv
请不要发送这些无意义的邮件
> 2020年12月27日 23:19，蒋德祥 写道：
>
>
ION) {
throw new RuntimeException("Lets test checkpointing");
}
return value;
}
});
~ Abhinav Bajaj
From: Eleanore Jin
Date: Wednesday, March 4, 2020 at 4:40 PM
To: user , user-zh
Subject: How to test flink job recover from checkpoint
Hi,
I
Hi Eleanore,
You can change your application tasks to throw exceptions in a certain
frequency.
Alternatively, if the application has external dependencies (e.g. source),
you can trigger failures manually by manipulating the status of the
external service (e.g. shutdown the source service, or
Hi,
I have a flink application and checkpoint is enabled, I am running locally
using miniCluster.
I just wonder if there is a way to simulate the failure, and verify that
flink job restarts from checkpoint?
Thanks a lot!
Eleanore
我在linux上对flink的flink-connector-kafka-0.10 这个module进行测试，执行mvn test 没有问题，但是执行 mvn
integration-test 失败，如下：
执行命令：
cd flink-connectors/flink-connector-kafka-0.10
mvn integration-test -Dtest=Kafka010ProducerITCase
日志：
[INFO] Error stacktraces are turned on.
[INFO] Scanning for projects...
[WARNING
test
mail list test
10 matches
Mail list logo
