You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/10/17 16:50:55 UTC
[03/11] incubator-beam git commit: BEAM-261 Use Apex 3.5.0-SNAPSHOT
to use loopback as connect address.
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 <th...@apache.org>
Authored: Wed Aug 31 16:41:52 2016 -0700
Committer: Thomas Weise <th...@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);