beam-runners-parent org.apache.beam 2.2.0 4.0.0 beam-runners-flink_2.10 Apache Beam :: Runners :: Flink maven-failsafe-plugin integration-test verify 1 -Dlog4j.configuration=log4j-test.properties -XX:-UseGCOverheadLimit ${beamSurefireArgline} maven-surefire-plugin -Dlog4j.configuration=log4j-test.properties -XX:-UseGCOverheadLimit ${beamSurefireArgline} org.codehaus.mojo exec-maven-plugin none local-validates-runner-tests maven-surefire-plugin validates-runner-tests integration-test test org.apache.beam.sdk.testing.ValidatesRunner org.apache.beam.sdk.testing.FlattenWithHeterogeneousCoders, org.apache.beam.sdk.testing.LargeKeys$Above100MB, org.apache.beam.sdk.testing.UsesSplittableParDo, org.apache.beam.sdk.testing.UsesCommittedMetrics, org.apache.beam.sdk.testing.UsesTestStream none true org.apache.beam:beam-sdks-java-core [ "--runner=TestFlinkRunner", "--streaming=false" ] 4 streaming-validates-runner-tests integration-test test org.apache.beam.sdk.testing.ValidatesRunner org.apache.beam.sdk.testing.FlattenWithHeterogeneousCoders, org.apache.beam.sdk.testing.LargeKeys$Above100MB, org.apache.beam.sdk.testing.UsesCommittedMetrics, org.apache.beam.sdk.testing.UsesTestStream, org.apache.beam.sdk.testing.UsesSplittableParDo none true org.apache.beam:beam-sdks-java-core [ "--runner=TestFlinkRunner", "--streaming=true" ] 4 org.apache.flink flink-clients_2.10 1.3.0 compile org.apache.flink flink-core 1.3.0 compile org.apache.flink flink-metrics-core 1.3.0 compile org.apache.flink flink-java 1.3.0 compile org.apache.flink flink-runtime_2.10 1.3.0 compile org.apache.flink flink-streaming-java_2.10 1.3.0 compile org.apache.flink flink-core 1.3.0 test-jar test org.apache.flink flink-runtime_2.10 1.3.0 test-jar test org.apache.beam beam-sdks-common-runner-api 2.2.0 compile org.apache.beam beam-sdks-java-core 2.2.0 compile slf4j-jdk14 org.slf4j org.apache.beam beam-runners-core-java 2.2.0 compile slf4j-jdk14 org.slf4j org.apache.beam beam-runners-core-construction-java 2.2.0 compile slf4j-jdk14 org.slf4j com.fasterxml.jackson.core jackson-annotations 2.8.9 compile com.google.code.findbugs jsr305 3.0.1 compile org.slf4j slf4j-api 1.7.25 compile joda-time joda-time 2.4 compile org.apache.commons commons-compress 1.14 runtime org.apache.commons commons-lang3 3.6 test org.hamcrest hamcrest-all 1.3 test junit junit 4.12 test hamcrest-core org.hamcrest org.mockito mockito-all 1.9.5 test org.apache.beam beam-sdks-java-core 2.2.0 tests test slf4j-jdk14 org.slf4j com.google.apis google-api-services-bigquery v2-rev355-1.22.0 test guava-jdk5 com.google.guava google-api-client com.google.api-client org.apache.flink flink-streaming-java_2.10 1.3.0 test-jar test org.apache.flink flink-test-utils_2.10 1.3.0 test apacheds-jdbm1 org.apache.directory.jdbm flink-test-utils-junit org.apache.flink curator-test org.apache.curator com.google.auto.service auto-service 1.0-rc2 compile true com.fasterxml.jackson.dataformat jackson-dataformat-yaml 2.8.9 test snakeyaml org.yaml org.apache.beam beam-sdks-common-fn-api 2.2.0 test-jar test org.apache.beam beam-runners-core-java 2.2.0 test-jar test 1.3.0