9cbcf84df43ecef8658691ba84b005bf29c258d1 - flink-statefun

commit	9cbcf84df43ecef8658691ba84b005bf29c258d1	[log] [tgz]
author	Evans Ye <evansye@apache.org>	Sat Aug 07 02:37:58 2021 +0800
committer	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Mon Aug 09 18:37:47 2021 +0800
tree	22b4f4f565747647b92512471383597c3a92f23c
parent	99ada68b9d65c18e9f59f35e6e8147946c2c699a [diff]

[FLINK-23672] Add smoke-e2e-java for Java SDK smoke test

This closes #248.

statefun-e2e-tests/pom.xml[diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/pom.xml[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/pom.xml - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/common/Constants.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/Constants.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/common/Ids.java[Copied from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/Ids.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/common/ModuleParameters.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/ModuleParameters.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/common/Types.java[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandFlinkSource.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandFlinkSource.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandGenerator.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandGenerator.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandRouter.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandRouter.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/DriverModule.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/CommonModule.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/FunctionStateTracker.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/FunctionStateTracker.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/protobuf/commands.proto[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/protobuf/commands.proto - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/protobuf/internal.proto[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/protobuf/internal.proto - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/common/ModuleParametersTest.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/ModuleParametersTest.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/CommandGeneratorTest.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/CommandGeneratorTest.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/FunctionStateTrackerTest.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/FunctionStateTrackerTest.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/testutils/SimpleVerificationServer.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/SimpleVerificationServer.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/testutils/SmokeRunner.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/SmokeRunner.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/testutils/SmokeRunnerParameters.java[Copied from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/ModuleParameters.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/testutils/Utils.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/Utils.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/pom.xml[diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/AsyncCompleter.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/AsyncCompleter.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/CommandInterpreter.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreter.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/CommandInterpreterFn.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreterFn.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/EmbeddedFnModule.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/EmbeddedModule.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/FunctionProvider.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/FunctionProvider.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/Command.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/CommandOrBuilder.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/Commands.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/CommandsOrBuilder.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/CommandsOuterClass.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/SourceCommand.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/SourceCommandOrBuilder.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/VerificationResult.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/generated/VerificationResultOrBuilder.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreterTest.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/embedded/EmbeddedSmokeHarnessTest.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/HarnessTest.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/embedded/SmokeVerificationEmbeddedE2E.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/SmokeVerificationEmbeddedE2E.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/resources/Dockerfile[diff]
statefun-e2e-tests/statefun-smoke-e2e-java/pom.xml[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/CommandInterpreter.java[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/CommandInterpreterAppServer.java[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/CommandInterpreterFn.java[Copied from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreterFn.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/Constants.java[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/Ids.java[Renamed from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/Ids.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/UndertowHttpHandler.java[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/protobuf/commands.proto[Copied from statefun-e2e-tests/statefun-smoke-e2e-common/src/main/protobuf/commands.proto - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/java/org/apache/flink/statefun/e2e/smoke/java/SmokeVerificationJavaE2E.java[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/Dockerfile[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/Dockerfile.remote-function[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/log4j.properties[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/remote-module/module.yaml[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-multilang-base/pom.xml[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-multilang-harness/pom.xml[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e-multilang-harness/src/test/java/org/apache/flink/statefun/e2e/smoke/multilang/harness/MultiLangSmokeHarnessTest.java[Copied from statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/HarnessTest.java - diff]
statefun-e2e-tests/statefun-smoke-e2e-multilang-harness/src/test/resources/module.yaml[Added - diff]
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreterTest.java[Deleted - diff]

57 files changed