tzulitai opened a new pull request #115: URL: https://github.com/apache/flink-statefun/pull/115
This PR adds an E2E test that consists of a complete YAML-based remote module, with: - YAML auto-routable Kafka ingress - YAML generic Kafka egress - Remote functions using the Python SDK Since the coverage completely subsumes the routable Kafka E2E, the routable Kafka E2E test is removed in favor of this new E2E. Please see the class-level docs of `RemoteModuleE2E` for details of the test scenario. ## Brief change log - a8b4b7b Preliminary change to the Python SDK build script, to allow it to be run with Maven - 470dc52 Make the `-Prun-e2e-tests` build profile also build the Python SDK. This is required because the remote module E2E test requires the Python SDK wheels built. - ce76abd The test scenario of the new `RemoteModuleE2E` will result in output records to Kafka being written with indeterministic order. This commit adds a matcher to the `KafkaIOVerifier` that matches the consumed outputs with any order. - 31b616d The Python remote functions - 82e93b7 The actual E2E test implementation - 95a1366 Removes the routable Kafka E2E ## Verifying Travis should pass, or locally run `mvn clean install -Prun-e2e-tests` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
