beam-runners-parent org.apache.beam 2.3.0 4.0.0 beam-runners-spark Apache Beam :: Runners :: Spark maven-surefire-plugin default-test test org.apache.beam.runners.spark.UsesCheckpointRecovery, org.apache.beam.runners.spark.StreamingTest [ "--runner=TestSparkRunner", "--streaming=false", "--enableSparkMetricSinks=true" ] 1 false true false false org.codehaus.mojo exec-maven-plugin java test -classpath ${mainClass} --inputFile=${input} --output=${output} --runner=${runner} --sparkMaster=${sparkMaster} org.jacoco jacoco-maven-plugin prepare-agent report test report maven-dependency-plugin com.fasterxml.jackson.module:jackson-module-scala_2.11 jacoco org.jacoco jacoco-maven-plugin local-validates-runner-tests maven-surefire-plugin validates-runner-tests integration-test test org.apache.beam.sdk.testing.ValidatesRunner, org.apache.beam.runners.spark.UsesCheckpointRecovery org.apache.beam.sdk.testing.UsesSplittableParDo, org.apache.beam.sdk.testing.UsesCommittedMetrics, org.apache.beam.sdk.testing.UsesTestStream, org.apache.beam.sdk.testing.UsesCustomWindowMerging none 1 false true org.apache.beam:beam-sdks-java-core [ "--runner=TestSparkRunner", "--streaming=false", "--enableSparkMetricSinks=false" ] true false false 4 streaming-tests test test org.apache.beam.runners.spark.StreamingTest [ "--runner=TestSparkRunner", "--forceStreaming=true", "--enableSparkMetricSinks=true" ] org.apache.spark spark-core_2.11 2.2.1 provided avro-mapred org.apache.avro chill_2.11 com.twitter chill-java com.twitter xbean-asm5-shaded org.apache.xbean hadoop-client org.apache.hadoop spark-launcher_2.11 org.apache.spark spark-network-shuffle_2.11 org.apache.spark spark-unsafe_2.11 org.apache.spark jets3t net.java.dev.jets3t curator-recipes org.apache.curator javax.servlet-api javax.servlet commons-math3 org.apache.commons jul-to-slf4j org.slf4j jcl-over-slf4j org.slf4j log4j log4j slf4j-log4j12 org.slf4j compress-lzf com.ning lz4 net.jpountz.lz4 RoaringBitmap org.roaringbitmap commons-net commons-net json4s-jackson_2.11 org.json4s jersey-client org.glassfish.jersey.core jersey-common org.glassfish.jersey.core jersey-server org.glassfish.jersey.core jersey-container-servlet org.glassfish.jersey.containers jersey-container-servlet-core org.glassfish.jersey.containers netty-all io.netty netty io.netty stream com.clearspring.analytics metrics-jvm io.dropwizard.metrics metrics-json io.dropwizard.metrics metrics-graphite io.dropwizard.metrics ivy org.apache.ivy oro oro pyrolite net.razorvine py4j net.sf.py4j spark-tags_2.11 org.apache.spark commons-crypto org.apache.commons unused org.spark-project.spark org.apache.spark spark-streaming_2.11 2.2.1 provided spark-tags_2.11 org.apache.spark unused org.spark-project.spark org.apache.spark spark-network-common_2.11 2.2.1 provided leveldbjni-all org.fusesource.leveldbjni netty-all io.netty commons-crypto org.apache.commons unused org.spark-project.spark org.apache.hadoop hadoop-common 2.7.3 provided jdk.tools jdk.tools servlet-api javax.servlet hadoop-annotations org.apache.hadoop commons-cli commons-cli xmlenc xmlenc commons-httpclient commons-httpclient commons-codec commons-codec commons-collections commons-collections jetty org.mortbay.jetty jetty-util org.mortbay.jetty jsp-api javax.servlet.jsp jersey-core com.sun.jersey jersey-json com.sun.jersey jersey-server com.sun.jersey commons-logging commons-logging commons-lang commons-lang commons-configuration commons-configuration jackson-core-asl org.codehaus.jackson jackson-mapper-asl org.codehaus.jackson hadoop-auth org.apache.hadoop jsch com.jcraft curator-client org.apache.curator htrace-core org.apache.htrace commons-math3 org.apache.commons commons-net commons-net log4j log4j jets3t net.java.dev.jets3t slf4j-log4j12 org.slf4j curator-recipes org.apache.curator org.apache.hadoop hadoop-mapreduce-client-core 2.7.3 provided servlet-api javax.servlet hadoop-yarn-common org.apache.hadoop guice-servlet com.google.inject.extensions hadoop-annotations org.apache.hadoop netty io.netty slf4j-log4j12 org.slf4j com.esotericsoftware kryo-shaded 3.0.3 provided minlog com.esotericsoftware objenesis org.objenesis com.google.code.findbugs jsr305 3.0.1 compile com.google.auto.service auto-service 1.0-rc2 compile true com.fasterxml.jackson.core jackson-annotations 2.8.9 compile com.fasterxml.jackson.module jackson-module-scala_2.11 2.8.9 compile org.apache.avro avro 1.8.2 test xz org.tukaani jackson-core-asl org.codehaus.jackson jackson-mapper-asl org.codehaus.jackson org.slf4j slf4j-api 1.7.25 compile joda-time joda-time 2.4 compile org.apache.commons commons-compress 1.14 provided org.apache.commons commons-lang3 3.6 provided org.apache.commons commons-text 1.1 compile commons-io commons-io 2.4 provided org.apache.zookeeper zookeeper 3.4.6 provided jline jline log4j log4j netty io.netty slf4j-log4j12 org.slf4j org.scala-lang scala-library 2.11.8 provided org.apache.beam beam-model-pipeline 2.3.0 compile org.apache.beam beam-sdks-java-core 2.3.0 compile slf4j-jdk14 org.slf4j org.apache.beam beam-runners-core-construction-java 2.3.0 compile org.apache.beam beam-runners-core-java 2.3.0 compile slf4j-jdk14 org.slf4j io.dropwizard.metrics metrics-core 3.1.2 compile org.apache.beam beam-sdks-java-io-kafka 2.3.0 test spring-expression org.springframework org.apache.kafka kafka-clients 1.0.0 test lz4 net.jpountz.lz4 lz4-java org.lz4 org.apache.kafka kafka_2.11 1.0.0 test lz4 net.jpountz.lz4 jopt-simple net.sf.jopt-simple metrics-core com.yammer.metrics zkclient com.101tec slf4j-log4j12 org.slf4j junit junit 4.12 test hamcrest-core org.hamcrest org.hamcrest hamcrest-all 1.3 provided org.apache.beam beam-sdks-java-core 2.3.0 tests test slf4j-jdk14 org.slf4j org.mockito mockito-all 1.9.5 test com.fasterxml.jackson.dataformat jackson-dataformat-yaml 2.8.9 test snakeyaml org.yaml org.apache.beam beam-model-fn-execution 2.3.0 test-jar test org.apache.beam beam-runners-core-java 2.3.0 test-jar test 3.1.2 UTF-8 UTF-8