[
https://issues.apache.org/jira/browse/BEAM-9003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035858#comment-17035858
]
Valentyn Tymofieiev commented on BEAM-9003:
-------------------------------------------
Actually, that message may be caused by the fact that nose command above does
not pass the --dataflow_worker_jar, and there is an incompatibility in FnAPI
protocol.
To fix that one can run:
../../gradlew :runners:google-cloud-dataflow-java:worker:shadowJar
and then pass the jar:
{noformat}
python setup.py nosetests --test-pipeline-options="--runner=TestDataflowRunner
--dataflow_worker_jar='./../../runners/google-cloud-dataflow-java/worker/build/libs/beam-runners-google-cloud-dataflow-java-fn-api-worker-2.20.0-SNAPSHOT.jar'
--project=google.com:clouddfe --temp_location=gs://clouddfe-valentyn/
--output=gs://clouddfe-valentyn
--sdk_location=./dist/apache-beam-2.20.0.dev0.tar.gz --num_workers=1
--sleep_secs=20 " --tests=apache_beam.transforms.util_test.ReshuffleTest
--attr=ValidatesRunner --nocapture
{noformat}
> test_reshuffle_preserves_timestamps
> (apache_beam.transforms.util_test.ReshuffleTest) does not work in Streaming
> VR suite on Dataflow
> ------------------------------------------------------------------------------------------------------------------------------------
>
> Key: BEAM-9003
> URL: https://issues.apache.org/jira/browse/BEAM-9003
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow, sdk-py-core
> Reporter: Valentyn Tymofieiev
> Assignee: wendy liu
> Priority: Major
>
> Per investigation in https://issues.apache.org/jira/browse/BEAM-8877, the
> test times out and was recently added to VR test suite.
> [~liumomo315], I will sickbay this test for streaming, could you please help
> triage the failure?
> Thank you!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
