You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Daniel Halperin (JIRA)" <ji...@apache.org> on 2016/10/25 22:14:58 UTC
[jira] [Resolved] (BEAM-805) DirectRunner occasionally flakes on
uncodeable elements
[ https://issues.apache.org/jira/browse/BEAM-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Daniel Halperin resolved BEAM-805.
----------------------------------
Resolution: Fixed
Fix Version/s: 0.4.0-incubating
> DirectRunner occasionally flakes on uncodeable elements
> -------------------------------------------------------
>
> Key: BEAM-805
> URL: https://issues.apache.org/jira/browse/BEAM-805
> Project: Beam
> Issue Type: Bug
> Components: runner-direct
> Affects Versions: 0.3.0-incubating
> Reporter: Daniel Halperin
> Assignee: Thomas Groh
> Fix For: 0.4.0-incubating
>
>
> I was able to reproduce this Jenkins flake: https://builds.apache.org/job/beam_PostCommit_MavenVerify/org.apache.beam$beam-runners-direct-java/1622/
> In about 8s using IntelliJ run until failure.
> {code}
> /Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/bin/java -ea -DbeamUseDummyRunner=false -Didea.launcher.port=7534 "-Didea.launcher.bin.path=/Applications/IntelliJ IDEA CE.app/Contents/bin" -Didea.junit.sm_runner -Dfile.encoding=UTF-8 -classpath "/Applications/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar:/Applications/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit-rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/lib/tools.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Users/dhalperi/IdeaProjects/incubator-beam/runners/direct-java/target/test-classes:/Users/dhalperi/IdeaProjects/incubator-beam/runners/direct-java/target/classes:/Users/dhalperi/IdeaProjects/incubator-beam/sdks/java/core/target/classes:/Users/dhalperi/.m2/repository/io/grpc/grpc-auth/1.0.1/grpc-auth-1.0.1.jar:/Users/dhalperi/.m2/repository/com/google/auth/google-auth-library-credentials/0.4.0/google-auth-library-credentials-0.4.0.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-core/1.0.1/grpc-core-1.0.1.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-context/1.0.1/grpc-context-1.0.1.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-netty/1.0.1/grpc-netty-1.0.1.jar:/Users/dhalperi/.m2/repository/io/netty/netty-codec-http2/4.1.3.Final/netty-codec-http2-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/netty/netty-codec-http/4.1.3.Final/netty-codec-http-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-stub/1.0.1/grpc-stub-1.0.1.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-all/1.0.1/grpc-all-1.0.1.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-protobuf/1.0.1/grpc-protobuf-1.0.1.jar:/Users/dhalperi/.m2/repository/com/google/protobuf/protobuf-java-util/3.0.0/protobuf-java-util-3.0.0.jar:/Users/dhalperi/.m2/repository/com/google/code/gson/gson/2.3/gson-2.3.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-protobuf-nano/1.0.1/grpc-protobuf-nano-1.0.1.jar:/Users/dhalperi/.m2/repository/com/google/protobuf/nano/protobuf-javanano/3.0.0-alpha-5/protobuf-javanano-3.0.0-alpha-5.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-okhttp/1.0.1/grpc-okhttp-1.0.1.jar:/Users/dhalperi/.m2/repository/com/squareup/okio/okio/1.6.0/okio-1.6.0.jar:/Users/dhalperi/.m2/repository/com/squareup/okhttp/okhttp/2.5.0/okhttp-2.5.0.jar:/Users/dhalperi/.m2/repository/io/grpc/grpc-protobuf-lite/1.0.1/grpc-protobuf-lite-1.0.1.jar:/Users/dhalperi/.m2/repository/com/google/protobuf/protobuf-lite/3.0.1/protobuf-lite-3.0.1.jar:/Users/dhalperi/.m2/repository/com/google/auth/google-auth-library-oauth2-http/0.4.0/google-auth-library-oauth2-http-0.4.0.jar:/Users/dhalperi/.m2/repository/io/netty/netty-handler/4.1.3.Final/netty-handler-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/netty/netty-buffer/4.1.3.Final/netty-buffer-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/netty/netty-common/4.1.3.Final/netty-common-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/netty/netty-transport/4.1.3.Final/netty-transport-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/netty/netty-resolver/4.1.3.Final/netty-resolver-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/io/netty/netty-codec/4.1.3.Final/netty-codec-4.1.3.Final.jar:/Users/dhalperi/.m2/repository/com/google/api/grpc/grpc-google-pubsub-v1/0.1.0/grpc-google-pubsub-v1-0.1.0.jar:/Users/dhalperi/.m2/repository/com/google/api/grpc/grpc-google-common-protos/0.1.0/grpc-google-common-protos-0.1.0.jar:/Users/dhalperi/.m2/repository/com/google/api/grpc/grpc-google-iam-v1/0.1.0/grpc-google-iam-v1-0.1.0.jar:/Users/dhalperi/.m2/repository/com/google/api-client/google-api-client/1.22.0/google-api-client-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/apis/google-api-services-bigquery/v2-rev295-1.22.0/google-api-services-bigquery-v2-rev295-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/apis/google-api-services-cloudresourcemanager/v1-rev6-1.22.0/google-api-services-cloudresourcemanager-v1-rev6-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/apis/google-api-services-pubsub/v1-rev10-1.22.0/google-api-services-pubsub-v1-rev10-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/apis/google-api-services-storage/v1-rev71-1.22.0/google-api-services-storage-v1-rev71-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/http-client/google-http-client/1.22.0/google-http-client-1.22.0.jar:/Users/dhalperi/.m2/repository/org/apache/httpcomponents/httpclient/4.0.1/httpclient-4.0.1.jar:/Users/dhalperi/.m2/repository/org/apache/httpcomponents/httpcore/4.0.1/httpcore-4.0.1.jar:/Users/dhalperi/.m2/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar:/Users/dhalperi/.m2/repository/commons-codec/commons-codec/1.3/commons-codec-1.3.jar:/Users/dhalperi/.m2/repository/com/google/http-client/google-http-client-jackson/1.22.0/google-http-client-jackson-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/http-client/google-http-client-jackson2/1.22.0/google-http-client-jackson2-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/oauth-client/google-oauth-client-java6/1.22.0/google-oauth-client-java6-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/oauth-client/google-oauth-client/1.22.0/google-oauth-client-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/cloud/bigdataoss/gcsio/1.4.5/gcsio-1.4.5.jar:/Users/dhalperi/.m2/repository/com/google/api-client/google-api-client-java6/1.22.0/google-api-client-java6-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/api-client/google-api-client-jackson2/1.22.0/google-api-client-jackson2-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/cloud/bigdataoss/util/1.4.5/util-1.4.5.jar:/Users/dhalperi/.m2/repository/com/google/protobuf/protobuf-java/3.0.0/protobuf-java-3.0.0.jar:/Users/dhalperi/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.7.2/jackson-core-2.7.2.jar:/Users/dhalperi/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.7.2/jackson-annotations-2.7.2.jar:/Users/dhalperi/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.7.2/jackson-databind-2.7.2.jar:/Users/dhalperi/.m2/repository/net/bytebuddy/byte-buddy/1.4.3/byte-buddy-1.4.3.jar:/Users/dhalperi/.m2/repository/org/apache/avro/avro/1.8.1/avro-1.8.1.jar:/Users/dhalperi/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/dhalperi/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/Users/dhalperi/.m2/repository/com/thoughtworks/paranamer/paranamer/2.7/paranamer-2.7.jar:/Users/dhalperi/.m2/repository/org/tukaani/xz/1.5/xz-1.5.jar:/Users/dhalperi/.m2/repository/org/xerial/snappy/snappy-java/1.1.2.1/snappy-java-1.1.2.1.jar:/Users/dhalperi/.m2/repository/org/apache/commons/commons-compress/1.9/commons-compress-1.9.jar:/Users/dhalperi/IdeaProjects/incubator-beam/runners/core-java/target/classes:/Users/dhalperi/.m2/repository/com/google/http-client/google-http-client-protobuf/1.22.0/google-http-client-protobuf-1.22.0.jar:/Users/dhalperi/.m2/repository/com/google/guava/guava/19.0/guava-19.0.jar:/Users/dhalperi/.m2/repository/com/google/guava/guava-testlib/19.0/guava-testlib-19.0.jar:/Users/dhalperi/.m2/repository/com/google/errorprone/error_prone_annotations/2.0.2/error_prone_annotations-2.0.2.jar:/Users/dhalperi/.m2/repository/joda-time/joda-time/2.4/joda-time-2.4.jar:/Users/dhalperi/.m2/repository/com/google/code/findbugs/annotations/3.0.1/annotations-3.0.1.jar:/Users/dhalperi/.m2/repository/net/jcip/jcip-annotations/1.0/jcip-annotations-1.0.jar:/Users/dhalperi/.m2/repository/com/google/code/findbugs/jsr305/3.0.1/jsr305-3.0.1.jar:/Users/dhalperi/.m2/repository/org/slf4j/slf4j-api/1.7.14/slf4j-api-1.7.14.jar:/Users/dhalperi/.m2/repository/com/google/auto/service/auto-service/1.0-rc2/auto-service-1.0-rc2.jar:/Users/dhalperi/.m2/repository/com/google/auto/auto-common/0.3/auto-common-0.3.jar:/Users/dhalperi/.m2/repository/com/google/auto/value/auto-value/1.1/auto-value-1.1.jar:/Users/dhalperi/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar:/Users/dhalperi/.m2/repository/junit/junit/4.11/junit-4.11.jar:/Users/dhalperi/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/dhalperi/.m2/repository/org/slf4j/slf4j-jdk14/1.7.14/slf4j-jdk14-1.7.14.jar:/Users/dhalperi/.m2/repository/org/mockito/mockito-all/1.9.5/mockito-all-1.9.5.jar:/Users/dhalperi/IdeaProjects/incubator-beam/sdks/java/core/target/test-classes:/Users/dhalperi/IdeaProjects/incubator-beam/runners/core-java/target/test-classes:/Users/dhalperi/.m2/repository/org/codehaus/woodstox/stax2-api/3.1.4/stax2-api-3.1.4.jar:/Users/dhalperi/.m2/repository/org/codehaus/woodstox/woodstox-core-asl/4.4.1/woodstox-core-asl-4.4.1.jar:/Users/dhalperi/.m2/repository/com/google/cloud/dataflow/google-cloud-dataflow-java-proto-library-all/0.5.160304/google-cloud-dataflow-java-proto-library-all-0.5.160304.jar" com.intellij.rt.execution.application.AppMain com.intellij.rt.execution.junit.JUnitStarter -ideVersion5 org.apache.beam.runners.direct.DirectRunnerTest,testUnencodableOutputElement "Until Failure"
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:16 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:17 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:18 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:19 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:20 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator onException
> SEVERE: Exception encountered while cleaning up after processing an element
> java.lang.NullPointerException
> at org.apache.beam.runners.direct.DoFnLifecycleManager.remove(DoFnLifecycleManager.java:63)
> at org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.onException(DoFnLifecycleManagerRemovingTransformEvaluator.java:68)
> at org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:51)
> at org.apache.beam.runners.direct.TransformExecutor.processElements(TransformExecutor.java:154)
> at org.apache.beam.runners.direct.TransformExecutor.run(TransformExecutor.java:121)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:21 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator onException
> SEVERE: Exception encountered while cleaning up after processing an element
> java.lang.NullPointerException
> at org.apache.beam.runners.direct.DoFnLifecycleManager.remove(DoFnLifecycleManager.java:63)
> at org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.onException(DoFnLifecycleManagerRemovingTransformEvaluator.java:68)
> at org.apache.beam.runners.direct.DoFnLifecycleManagerRemovingTransformEvaluator.processElement(DoFnLifecycleManagerRemovingTransformEvaluator.java:51)
> at org.apache.beam.runners.direct.TransformExecutor.processElements(TransformExecutor.java:154)
> at org.apache.beam.runners.direct.TransformExecutor.run(TransformExecutor.java:121)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> Oct 24, 2016 9:08:22 AM org.apache.beam.sdk.Pipeline applyInternal
> WARNING: Transform AnonymousParDo2 does not have a stable unique name. This will prevent updating of pipelines.
> java.lang.AssertionError:
> Expected: (exception with cause is an instance of org.apache.beam.sdk.coders.CoderException and exception with message a string containing "cannot encode a null Long")
> but: exception with cause is an instance of org.apache.beam.sdk.coders.CoderException cause <java.lang.AssertionError: Pipeline should fail to encode a null Long in VarLongCoder> is a java.lang.AssertionError
> Stacktrace was: org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.AssertionError: Pipeline should fail to encode a null Long in VarLongCoder
> at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:279)
> at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:72)
> at org.apache.beam.sdk.Pipeline.run(Pipeline.java:182)
> at org.apache.beam.runners.direct.DirectRunnerTest.testUnencodableOutputElement(DirectRunnerTest.java:389)
> at sun.reflect.GeneratedMethodAccessor7.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:497)
> at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
> at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
> at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:168)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:117)
> at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:64)
> at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:253)
> at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:84)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:497)
> at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
> Caused by: java.lang.AssertionError: Pipeline should fail to encode a null Long in VarLongCoder
> at org.junit.Assert.fail(Assert.java:88)
> at org.apache.beam.runners.direct.DirectRunnerTest$16.unreachable(DirectRunnerTest.java:383)
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
> at org.junit.Assert.assertThat(Assert.java:865)
> at org.junit.Assert.assertThat(Assert.java:832)
> at org.junit.rules.ExpectedException.handleException(ExpectedException.java:198)
> at org.junit.rules.ExpectedException.access$500(ExpectedException.java:85)
> at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:177)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:117)
> at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:64)
> at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:253)
> at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:84)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:497)
> at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
> Process finished with exit code 255
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)