BEAM-261 Use Apex 3.5.0-SNAPSHOT to use loopback as connect address.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a7e430d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a7e430d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a7e430d6 Branch: refs/heads/apex-runner Commit: a7e430d6b24de53a116258af75c7eb15d6133b4d Parents: aaf38dd Author: Thomas Weise <t...@apache.org> Authored: Wed Aug 31 16:41:52 2016 -0700 Committer: Thomas Weise <t...@apache.org> Committed: Sun Oct 16 23:22:59 2016 -0700 ---------------------------------------------------------------------- runners/apex/pom.xml | 6 +++--- .../beam/runners/apex/translators/CreateValuesTranslator.java | 3 ++- 2 files changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a7e430d6/runners/apex/pom.xml ---------------------------------------------------------------------- diff --git a/runners/apex/pom.xml b/runners/apex/pom.xml index bb08b3c..21e53a8 100644 --- a/runners/apex/pom.xml +++ b/runners/apex/pom.xml @@ -35,9 +35,9 @@ <packaging>jar</packaging> <properties> - <apex.core.version>3.4.0</apex.core.version> + <apex.core.version>3.5.0-SNAPSHOT</apex.core.version> <apex.malhar.version>3.4.0</apex.malhar.version> - <skipIntegrationTests>true</skipIntegrationTests> + <skipIntegrationTests>false</skipIntegrationTests> <!-- memory limit for embedded cluster --> <surefire.args>-Xmx2048m</surefire.args> </properties> @@ -206,7 +206,7 @@ </goals> <configuration> <ignoredUsedUndeclaredDependencies> - <ignoredUsedUndeclaredDependency>org.apache.apex:apex-api:jar:3.4.0</ignoredUsedUndeclaredDependency> + <ignoredUsedUndeclaredDependency>org.apache.apex:apex-api:jar:3.5.0-SNAPSHOT</ignoredUsedUndeclaredDependency> <ignoredUsedUndeclaredDependency>org.apache.commons:commons-lang3::3.1</ignoredUsedUndeclaredDependency> <ignoredUsedUndeclaredDependency>com.esotericsoftware.kryo:kryo::2.24.0</ignoredUsedUndeclaredDependency> <ignoredUsedUndeclaredDependency>com.datatorrent:netlet::1.2.1</ignoredUsedUndeclaredDependency> http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a7e430d6/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/CreateValuesTranslator.java ---------------------------------------------------------------------- diff --git a/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/CreateValuesTranslator.java b/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/CreateValuesTranslator.java index 387b19f..7a29057 100644 --- a/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/CreateValuesTranslator.java +++ b/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/CreateValuesTranslator.java @@ -23,6 +23,7 @@ import org.apache.beam.runners.apex.translators.io.ValuesSource; import org.apache.beam.sdk.coders.CannotProvideCoderException; import org.apache.beam.sdk.io.UnboundedSource; import org.apache.beam.sdk.transforms.Create; +import org.apache.beam.sdk.values.PBegin; import com.google.common.base.Throwables; @@ -38,7 +39,7 @@ public class CreateValuesTranslator<T> implements TransformTranslator<Create.Val public void translate(Create.Values<T> transform, TranslationContext context) { try { UnboundedSource<T, ?> unboundedSource = new ValuesSource<>(transform.getElements(), - transform.getDefaultOutputCoder(context.getInput())); + transform.getDefaultOutputCoder((PBegin)context.getInput())); ApexReadUnboundedInputOperator<T, ?> operator = new ApexReadUnboundedInputOperator<>(unboundedSource, context.getPipelineOptions()); context.addOperator(operator, operator.output);