Repository: beam Updated Branches: refs/heads/jstorm-runner a8edbb81f -> f6a89b0fc
[BEAM-1899] Start jstorm runner moduel in feature branch. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9d4de1b2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9d4de1b2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9d4de1b2 Branch: refs/heads/jstorm-runner Commit: 9d4de1b2f5bf4816cb834e08aae8c127d2dca4cf Parents: a8edbb8 Author: Pei He <[email protected]> Authored: Thu Apr 6 14:53:04 2017 +0800 Committer: Pei He <[email protected]> Committed: Sat Apr 22 14:23:53 2017 +0800 ---------------------------------------------------------------------- runners/jstorm/pom.xml | 194 ++++++++++++++++++++++++++++++++++++++++++++ runners/pom.xml | 1 + 2 files changed, 195 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/9d4de1b2/runners/jstorm/pom.xml ---------------------------------------------------------------------- diff --git a/runners/jstorm/pom.xml b/runners/jstorm/pom.xml new file mode 100644 index 0000000..31a9b22 --- /dev/null +++ b/runners/jstorm/pom.xml @@ -0,0 +1,194 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + http://www.apache.org/licenses/LICENSE-2.0 + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>org.apache.beam</groupId> + <artifactId>beam-runners-parent</artifactId> + <version>0.7.0-SNAPSHOT</version> + <relativePath>../pom.xml</relativePath> + </parent> + + <artifactId>beam-runners-jstorm</artifactId> + + <name>Apache Beam :: Runners :: JStorm</name> + + <packaging>jar</packaging> + + <properties> + <jstorm.core.version>2.2.1</jstorm.core.version> + </properties> + + <profiles> + <profile> + <!-- This profile adds execution of ValidatesRunner integration tests + against a JStorm local cluster. --> + <id>local-validates-runner-tests</id> + <activation><activeByDefault>false</activeByDefault></activation> + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-surefire-plugin</artifactId> + <executions> + <execution> + <id>validates-runner-tests</id> + <phase>integration-test</phase> + <goals> + <goal>test</goal> + </goals> + <configuration> + <groups> + org.apache.beam.sdk.testing.ValidatesRunner + </groups> + <parallel>none</parallel> + <failIfNoTests>true</failIfNoTests> + <dependenciesToScan> + <dependency>org.apache.beam:beam-sdks-java-core</dependency> + </dependenciesToScan> + <systemPropertyVariables> + <beamTestPipelineOptions> + [ + "--runner=org.apache.beam.runners.jstorm.JStormRunner" + ] + </beamTestPipelineOptions> + </systemPropertyVariables> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> + </profile> + </profiles> + + <dependencies> + <!-- JStorm dependencies --> + <dependency> + <groupId>com.alibaba.jstorm</groupId> + <artifactId>jstorm-core</artifactId> + <version>${jstorm.core.version}</version> + <scope>provided</scope> + </dependency> + + <!-- Beam dependencies --> + <dependency> + <groupId>org.apache.beam</groupId> + <artifactId>beam-sdks-java-core</artifactId> + <exclusions> + <!-- jstorm uses logback binding --> + <exclusion> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-jdk14</artifactId> + </exclusion> + </exclusions> + </dependency> + + <dependency> + <groupId>org.apache.beam</groupId> + <artifactId>beam-runners-core-java</artifactId> + <exclusions> + <!-- jstorm uses logback binding --> + <exclusion> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-jdk14</artifactId> + </exclusion> + </exclusions> + </dependency> + + <dependency> + <groupId>org.apache.beam</groupId> + <artifactId>beam-runners-core-construction-java</artifactId> + <exclusions> + <!-- jstorm uses logback binding --> + <exclusion> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-jdk14</artifactId> + </exclusion> + </exclusions> + </dependency> + + <!-- Module dependencies --> + <dependency> + <groupId>com.google.auto.service</groupId> + <artifactId>auto-service</artifactId> + <optional>true</optional> + </dependency> + <dependency> + <groupId>com.google.auto.value</groupId> + <artifactId>auto-value</artifactId> + </dependency> + + <!-- Depend on test jar to scan for ValidatesRunner tests --> + <dependency> + <groupId>org.apache.beam</groupId> + <artifactId>beam-sdks-java-core</artifactId> + <classifier>tests</classifier> + <scope>test</scope> + <exclusions> + <!-- jstorm uses logback binding --> + <exclusion> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-jdk14</artifactId> + </exclusion> + </exclusions> + </dependency> + + <!-- transitive test dependencies from beam-sdk-java-core --> + <dependency> + <groupId>com.fasterxml.jackson.dataformat</groupId> + <artifactId>jackson-dataformat-yaml</artifactId> + <scope>test</scope> + </dependency> + + <!-- test dependencies --> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.hamcrest</groupId> + <artifactId>hamcrest-all</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.mockito</groupId> + <artifactId>mockito-all</artifactId> + <scope>test</scope> + </dependency> + </dependencies> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-dependency-plugin</artifactId> + <executions> + <execution> + <goals><goal>analyze-only</goal></goals> + <configuration> + <!-- disable for now during runner development --> + <failOnWarning>false</failOnWarning> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/beam/blob/9d4de1b2/runners/pom.xml ---------------------------------------------------------------------- diff --git a/runners/pom.xml b/runners/pom.xml index 150e987..e06c39e 100644 --- a/runners/pom.xml +++ b/runners/pom.xml @@ -40,6 +40,7 @@ <module>google-cloud-dataflow-java</module> <module>spark</module> <module>apex</module> + <module>jstorm</module> </modules> <profiles>
