84f6ce0cc7dac0bb474f308a3911812e36aa7bee - flink-statefun

commit	84f6ce0cc7dac0bb474f308a3911812e36aa7bee	[log] [tgz]
author	Igal Shilman <igal@apache.org>	Thu Sep 23 14:49:09 2021 +0200
committer	Igal Shilman <igal@apache.org>	Thu Sep 23 15:39:07 2021 +0200
tree	6cb840c9bbce5eef49dae74b4882f375a636ba2b
parent	2600dfb077d05338d6dbebee3cba6d92ef75aa25 [diff]

[FLINK-24364][e2e] Add message cancellation embedded e2e case

This commit adds a message cancellation test case for the smoke e2e test.
The generation of message cancellation commands is disabled by default, and
only enabled for the embedded sdk e2e tests.

statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/SmokeRunnerParameters.java[diff]
statefun-e2e-tests/statefun-smoke-e2e-common/src/main/protobuf/commands.proto[diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandGenerator.java[diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/CommandInterpreter.java[diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/embedded/EmbeddedSmokeHarnessTest.java[diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/embedded/SmokeVerificationEmbeddedE2E.java[diff]

6 files changed