See 
<https://builds.apache.org/job/beam_python_mongoio_load_test/1/display/redirect>

Changes:


------------------------------------------
[...truncated 44.89 KB...]
Collecting parameterized<0.7.0,>=0.6.0
  Using cached 
https://files.pythonhosted.org/packages/3a/49/75f6dadb09e2f8ace3cdffe0c99a04f1b98dff41fbf9e768665d8b469e29/parameterized-0.6.3-py2.py3-none-any.whl
Collecting pyhamcrest<2.0,>=1.9
  Using cached 
https://files.pythonhosted.org/packages/9a/d5/d37fd731b7d0e91afcc84577edeccf4638b4f9b82f5ffe2f8b62e2ddc609/PyHamcrest-1.9.0-py2.py3-none-any.whl
Processing 
/home/jenkins/.cache/pip/wheels/54/b7/c7/2ada654ee54483c9329871665aaf4a6056c3ce36f29cf66e67/PyYAML-5.2-cp27-cp27mu-linux_x86_64.whl
Collecting requests_mock<2.0,>=1.7
  Using cached 
https://files.pythonhosted.org/packages/8c/f1/66c54a412543b29454102ae74b1454fce2d307b1c36e6bd2e9818394df88/requests_mock-1.7.0-py2.py3-none-any.whl
Collecting tenacity<6.0,>=5.0.2
  Using cached 
https://files.pythonhosted.org/packages/45/67/67bb1db087678bc5c6f20766cf18914dfe37b0b9d4e4c5bb87408460b75f/tenacity-5.1.5-py2.py3-none-any.whl
Collecting pytest<5.0,>=4.4.0
  Using cached 
https://files.pythonhosted.org/packages/64/f1/187a98b8f913a8f3a53d213cca2fae19718565f36165804d7f4f91fe5b76/pytest-4.6.6-py2.py3-none-any.whl
Collecting pytest-xdist<2,>=1.29.0
  Using cached 
https://files.pythonhosted.org/packages/f7/80/2af1fc039f779f61c7207dc9f79a1479874e7795f869fddaf135efde1cd4/pytest_xdist-1.30.0-py2.py3-none-any.whl
Requirement already satisfied: six>=1.5.2 in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from grpcio<2,>=1.12.1->apache-beam==2.19.0.dev0) (1.13.0)
Requirement already satisfied: enum34>=1.0.4; python_version < "3.4" in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from grpcio<2,>=1.12.1->apache-beam==2.19.0.dev0) (1.1.6)
Processing 
/home/jenkins/.cache/pip/wheels/9b/04/dd/7daf4150b6d9b12949298737de9431a324d4b797ffd63f526e/docopt-0.6.2-py2.py3-none-any.whl
Collecting requests>=2.7.0
  Using cached 
https://files.pythonhosted.org/packages/51/bd/23c926cd341ea6b7dd0b2a00aba99ae0f828be89d72b2190f27c11d4b7fb/requests-2.22.0-py2.py3-none-any.whl
Collecting pbr>=0.11
  Using cached 
https://files.pythonhosted.org/packages/7a/db/a968fd7beb9fe06901c1841cb25c9ccb666ca1b9a19b114d1bbedf1126fc/pbr-5.4.4-py2.py3-none-any.whl
Collecting pyasn1>=0.1.7
  Using cached 
https://files.pythonhosted.org/packages/62/1e/a94a8d635fa3ce4cfc7f506003548d0a2447ae76fd5ca53932970fe3053f/pyasn1-0.4.8-py2.py3-none-any.whl
Collecting pyasn1-modules>=0.0.5
  Using cached 
https://files.pythonhosted.org/packages/52/50/bb4cefca37da63a0c52218ba2cb1b1c36110d84dcbae8aa48cd67c5e95c2/pyasn1_modules-0.2.7-py2.py3-none-any.whl
Collecting rsa>=3.1.4
  Using cached 
https://files.pythonhosted.org/packages/02/e5/38518af393f7c214357079ce67a317307936896e961e35450b70fad2a9cf/rsa-4.0-py2.py3-none-any.whl
Requirement already satisfied: setuptools in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from protobuf<4,>=3.5.0.post1->apache-beam==2.19.0.dev0) (42.0.2)
Collecting pyparsing>=2.1.4
  Using cached 
https://files.pythonhosted.org/packages/c0/0c/fc2e007d9a992d997f04a80125b0f183da7fb554f1de701bbb70a8e7d479/pyparsing-2.4.5-py2.py3-none-any.whl
Collecting fasteners>=0.14
  Using cached 
https://files.pythonhosted.org/packages/18/bd/55eb2d6397b9c0e263af9d091ebdb756b15756029b3cededf6461481bc63/fasteners-0.15-py2.py3-none-any.whl
Collecting google-api-core[grpc]<2.0.0dev,>=1.6.0
  Using cached 
https://files.pythonhosted.org/packages/29/3a/c528ef37f48d6ffba16f0f3c0426456ba21e0dd32be9c61a2ade93e07faa/google_api_core-1.14.3-py2.py3-none-any.whl
Processing 
/home/jenkins/.cache/pip/wheels/de/3a/83/77a1e18e1a8757186df834b86ce6800120ac9c79cd8ca4091b/grpc_google_iam_v1-0.12.3-cp27-none-any.whl
Collecting google-resumable-media<0.5.0dev,>=0.3.1
  Using cached 
https://files.pythonhosted.org/packages/96/d7/b29a41b01b854480891dfc408211ffb0cc7a2a3d5f15a3b6740ec18c845b/google_resumable_media-0.4.1-py2.py3-none-any.whl
Processing 
/home/jenkins/.cache/pip/wheels/9e/3d/a2/1bec8bb7db80ab3216dbc33092bb7ccd0debfb8ba42b5668d5/googleapis_common_protos-1.6.0-cp27-none-any.whl
Collecting monotonic>=0.6; python_version == "2.7"
  Using cached 
https://files.pythonhosted.org/packages/ac/aa/063eca6a416f397bd99552c534c6d11d57f58f2e94c14780f3bbf818c4cf/monotonic-1.5-py2.py3-none-any.whl
Collecting atomicwrites>=1.0
  Using cached 
https://files.pythonhosted.org/packages/52/90/6155aa926f43f2b2a22b01be7241be3bfd1ceaf7d0b3267213e8127d41f4/atomicwrites-1.3.0-py2.py3-none-any.whl
Collecting packaging
  Using cached 
https://files.pythonhosted.org/packages/cf/94/9672c2d4b126e74c4496c6b3c58a8b51d6419267be9e70660ba23374c875/packaging-19.2-py2.py3-none-any.whl
Collecting wcwidth
  Using cached 
https://files.pythonhosted.org/packages/7e/9f/526a6947247599b084ee5232e4f9190a38f398d7300d866af3ab571a5bfe/wcwidth-0.1.7-py2.py3-none-any.whl
Requirement already satisfied: importlib-metadata>=0.12; python_version < "3.8" 
in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (1.1.1)
Requirement already satisfied: py>=1.5.0 in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (1.8.0)
Requirement already satisfied: pathlib2>=2.2.0; python_version < "3.6" in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (2.3.5)
Requirement already satisfied: pluggy<1.0,>=0.12 in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (0.13.1)
Collecting attrs>=17.4.0
  Using cached 
https://files.pythonhosted.org/packages/a2/db/4313ab3be961f7a763066401fb77f7748373b6094076ae2bda2806988af6/attrs-19.3.0-py2.py3-none-any.whl
Requirement already satisfied: more-itertools<6.0.0,>=4.0.0; python_version <= 
"2.7" in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (5.0.0)
Collecting pytest-forked
  Using cached 
https://files.pythonhosted.org/packages/03/1e/81235e1fcfed57a4e679d34794d60c01a1e9a29ef5b9844d797716111d80/pytest_forked-1.1.3-py2.py3-none-any.whl
Collecting execnet>=1.1
  Using cached 
https://files.pythonhosted.org/packages/d3/2e/c63af07fa471e0a02d05793c7a56a9f7d274a8489442a5dc4fb3b2b3c705/execnet-1.7.1-py2.py3-none-any.whl
Collecting urllib3!=1.25.0,!=1.25.1,<1.26,>=1.21.1
  Using cached 
https://files.pythonhosted.org/packages/b4/40/a9837291310ee1ccc242ceb6ebfd9eb21539649f193a7c8c86ba15b98539/urllib3-1.25.7-py2.py3-none-any.whl
Collecting certifi>=2017.4.17
  Using cached 
https://files.pythonhosted.org/packages/b9/63/df50cac98ea0d5b006c55a399c3bf1db9da7b5a24de7890bc9cfd5dd9e99/certifi-2019.11.28-py2.py3-none-any.whl
Collecting chardet<3.1.0,>=3.0.2
  Using cached 
https://files.pythonhosted.org/packages/bc/a9/01ffebfb562e4274b6487b4bb1ddec7ca55ec7510b22e4c51f14098443b8/chardet-3.0.4-py2.py3-none-any.whl
Collecting idna<2.9,>=2.5
  Using cached 
https://files.pythonhosted.org/packages/14/2c/cd551d81dbe15200be1cf41cd03869a46fe7226e7450af7a6545bfc474c9/idna-2.8-py2.py3-none-any.whl
Collecting google-auth<2.0dev,>=0.4.0
  Using cached 
https://files.pythonhosted.org/packages/7b/cb/786dc53d93494784935a62947643b48250b84a882474e714f9af5e1a1928/google_auth-1.7.1-py2.py3-none-any.whl
Requirement already satisfied: contextlib2; python_version < "3" in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from importlib-metadata>=0.12; python_version < 
"3.8"->pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (0.6.0.post1)
Requirement already satisfied: zipp>=0.5 in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from importlib-metadata>=0.12; python_version < 
"3.8"->pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (0.6.0)
Requirement already satisfied: configparser>=3.5; python_version < "3" in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from importlib-metadata>=0.12; python_version < 
"3.8"->pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (4.0.2)
Requirement already satisfied: scandir; python_version < "3.5" in 
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/lib/python2.7/site-packages>
 (from pathlib2>=2.2.0; python_version < 
"3.6"->pytest<5.0,>=4.4.0->apache-beam==2.19.0.dev0) (1.10.0)
Collecting apipkg>=1.4
  Using cached 
https://files.pythonhosted.org/packages/67/08/4815a09603fc800209431bec5b8bd2acf2f95abdfb558a44a42507fb94da/apipkg-1.5-py2.py3-none-any.whl
Installing collected packages: crcmod, dill, fastavro, future, docopt, urllib3, 
certifi, chardet, idna, requests, hdfs, httplib2, pbr, funcsigs, mock, numpy, 
pymongo, pyasn1, pyasn1-modules, rsa, oauth2client, pyparsing, pydot, 
python-dateutil, pytz, avro, pyvcf, typing, pyarrow, cachetools, monotonic, 
fasteners, google-apitools, googleapis-common-protos, google-auth, 
google-api-core, google-cloud-core, google-cloud-datastore, grpc-google-iam-v1, 
google-cloud-pubsub, google-resumable-media, google-cloud-bigquery, 
google-cloud-bigtable, proto-google-cloud-datastore-v1, googledatastore, nose, 
nose-xunitmp, pandas, parameterized, pyhamcrest, pyyaml, requests-mock, 
tenacity, atomicwrites, packaging, wcwidth, attrs, pytest, pytest-forked, 
apipkg, execnet, pytest-xdist, apache-beam
  Running setup.py develop for apache-beam
Successfully installed apache-beam apipkg-1.5 atomicwrites-1.3.0 attrs-19.3.0 
avro-1.9.1 cachetools-3.1.1 certifi-2019.11.28 chardet-3.0.4 crcmod-1.7 
dill-0.3.1.1 docopt-0.6.2 execnet-1.7.1 fastavro-0.21.24 fasteners-0.15 
funcsigs-1.0.2 future-0.18.2 google-api-core-1.14.3 google-apitools-0.5.28 
google-auth-1.7.1 google-cloud-bigquery-1.17.1 google-cloud-bigtable-1.0.0 
google-cloud-core-1.0.3 google-cloud-datastore-1.7.4 google-cloud-pubsub-1.0.2 
google-resumable-media-0.4.1 googleapis-common-protos-1.6.0 
googledatastore-7.0.2 grpc-google-iam-v1-0.12.3 hdfs-2.5.8 httplib2-0.12.0 
idna-2.8 mock-2.0.0 monotonic-1.5 nose-1.3.7 nose-xunitmp-0.4.1 numpy-1.16.5 
oauth2client-3.0.0 packaging-19.2 pandas-0.24.2 parameterized-0.6.3 pbr-5.4.4 
proto-google-cloud-datastore-v1-0.90.4 pyarrow-0.15.1 pyasn1-0.4.8 
pyasn1-modules-0.2.7 pydot-1.4.1 pyhamcrest-1.9.0 pymongo-3.9.0 pyparsing-2.4.5 
pytest-4.6.6 pytest-forked-1.1.3 pytest-xdist-1.30.0 python-dateutil-2.8.1 
pytz-2019.3 pyvcf-0.6.8 pyyaml-5.2 requests-2.22.0 requests-mock-1.7.0 rsa-4.0 
tenacity-5.1.5 typing-3.6.6 urllib3-1.25.7 wcwidth-0.1.7

> Task :sdks:python:test-suites:dataflow:py2:mongodbioIT
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/__init__.py>:84:
 UserWarning: You are using Apache Beam with Python 2. New releases of Apache 
Beam will soon support Python 3 only.
  'You are using Apache Beam with Python 2. '
INFO:root:Missing pipeline option (runner). Executing pipeline using the 
default runner: DirectRunner.
INFO:__main__:Writing 100000 documents to mongodb
<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/io/mongodbio_it_test.py>:72:
 FutureWarning: WriteToMongoDB is experimental.
  known_args.batch_size)
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function annotate_downstream_side_inputs at 0x7f5f76e36e60> 
====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function fix_side_input_pcoll_coders at 0x7f5f76e36f50> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function lift_combiners at 0x7f5f76ccf050> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function expand_sdf at 0x7f5f76ccf0c8> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function expand_gbk at 0x7f5f76ccf140> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function sink_flattens at 0x7f5f76ccf230> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function greedily_fuse at 0x7f5f76ccf2a8> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function read_to_impulse at 0x7f5f76ccf320> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function impulse_to_input at 0x7f5f76ccf398> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function inject_timer_pcollections at 0x7f5f76ccf500> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function sort_stages at 0x7f5f76ccf578> ====================
INFO:apache_beam.runners.portability.fn_api_runner_transforms:====================
 <function window_pcollection_coders at 0x7f5f76ccf5f0> ====================
INFO:apache_beam.runners.worker.statecache:Creating state cache with size 100
INFO:apache_beam.runners.portability.fn_api_runner:Created Worker handler 
<apache_beam.runners.portability.fn_api_runner.EmbeddedWorkerHandler object at 
0x7f5f76f84790> for environment urn: "beam:env:embedded_python:v1"

INFO:apache_beam.runners.portability.fn_api_runner:Running 
(ref_AppliedPTransform_Create 
documents/Read_3)+((ref_AppliedPTransform_WriteToMongoDB/ParDo(_GenerateObjectIdFn)_5)+((ref_AppliedPTransform_WriteToMongoDB/Reshuffle/AddRandomKeys_7)+((ref_AppliedPTransform_WriteToMongoDB/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9)+(WriteToMongoDB/Reshuffle/ReshufflePerKey/GroupByKey/Write))))
INFO:apache_beam.runners.portability.fn_api_runner:Running 
((WriteToMongoDB/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_WriteToMongoDB/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_14))+((ref_AppliedPTransform_WriteToMongoDB/Reshuffle/RemoveRandomKeys_15)+(ref_AppliedPTransform_WriteToMongoDB/ParDo(_WriteMongoFn)_16))
Traceback (most recent call last):
  File "/usr/lib/python2.7/runpy.py", line 174, in _run_module_as_main
    "__main__", fname, loader, pkg_name)
  File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
    exec code in run_globals
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/io/mongodbio_it_test.py";,>
 line 100, in <module>
    run()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/io/mongodbio_it_test.py";,>
 line 72, in run
    known_args.batch_size)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 436, in __exit__
    self.run().wait_until_finish()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/testing/test_pipeline.py";,>
 line 112, in run
    else test_runner_api))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 416, in run
    self._options).run(False)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 429, in run
    return self.runner.run_pipeline(self, self._options)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/direct/direct_runner.py";,>
 line 135, in run_pipeline
    return runner.run_pipeline(pipeline, options)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 392, in run_pipeline
    default_environment=self._default_environment))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 399, in run_via_runner_api
    return self.run_stages(stage_context, stages)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 481, in run_stages
    stage_context.safe_coders)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 777, in _run_stage
    result, splits = bundle_manager.process_bundle(data_input, data_output)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 1814, in process_bundle
    part, expected_outputs), part_inputs):
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/concurrent/futures/_base.py";,>
 line 641, in result_iterator
    yield fs.pop().result()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/concurrent/futures/_base.py";,>
 line 462, in result
    return self.__get_result()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/utils/thread_pool_executor.py";,>
 line 42, in run
    self._future.set_result(self._fn(*self._fn_args, **self._fn_kwargs))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 1814, in <lambda>
    part, expected_outputs), part_inputs):
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 1750, in process_bundle
    result_future = self._worker_handler.control_conn.push(process_bundle_req)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/portability/fn_api_runner.py";,>
 line 1176, in push
    response = self.worker.do_instruction(request)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 284, in do_instruction
    request.instruction_id)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,>
 line 310, in process_bundle
    bundle_processor.process_bundle(instruction_id))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 675, in process_bundle
    data.transform_id].process_encoded(data.data)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,>
 line 146, in process_encoded
    self.output(decoded_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 259, in output
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 146, in receive
    self.consumer.process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 597, in process
    delayed_application = self.dofn_receiver.receive(o)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 808, in receive
    self.process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 814, in process
    self._reraise_augmented(exn)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 812, in process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 448, in invoke_process
    windowed_value, self.process_method(windowed_value.value))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 951, in process_outputs
    self.main_receivers.receive(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 146, in receive
    self.consumer.process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 597, in process
    delayed_application = self.dofn_receiver.receive(o)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 808, in receive
    self.process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 814, in process
    self._reraise_augmented(exn)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 812, in process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 448, in invoke_process
    windowed_value, self.process_method(windowed_value.value))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 951, in process_outputs
    self.main_receivers.receive(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 146, in receive
    self.consumer.process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,>
 line 597, in process
    delayed_application = self.dofn_receiver.receive(o)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 808, in receive
    self.process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 814, in process
    self._reraise_augmented(exn)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 881, in _reraise_augmented
    raise_with_traceback(new_exn)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 812, in process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/runners/common.py";,>
 line 448, in invoke_process
    windowed_value, self.process_method(windowed_value.value))
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/io/mongodbio.py";,>
 line 463, in process
    self._flush()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/io/mongodbio.py";,>
 line 469, in _flush
    sink.write(self.batch)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/apache_beam/io/mongodbio.py";,>
 line 503, in write
    resp = self.client[self.db][self.coll].bulk_write(requests)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/collection.py";,>
 line 502, in bulk_write
    bulk_api_result = blk.execute(write_concern, session)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/bulk.py";,>
 line 511, in execute
    return self.execute_command(generator, write_concern, session)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/bulk.py";,>
 line 344, in execute_command
    with client._tmp_session(session) as s:
  File "/usr/lib/python2.7/contextlib.py", line 17, in __enter__
    return self.gen.next()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/mongo_client.py";,>
 line 1820, in _tmp_session
    s = self._ensure_session(session)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/mongo_client.py";,>
 line 1807, in _ensure_session
    return self.__start_session(True, causal_consistency=False)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/mongo_client.py";,>
 line 1760, in __start_session
    server_session = self._get_server_session()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/mongo_client.py";,>
 line 1793, in _get_server_session
    return self._topology.get_server_session()
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/topology.py";,>
 line 477, in get_server_session
    None)
  File 
"<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/build/gradleenv/-194514014/local/lib/python2.7/site-packages/pymongo/topology.py";,>
 line 205, in _select_servers_loop
    self._error_message(selector))
pymongo.errors.ServerSelectionTimeoutError: localhost:27017: [Errno 111] 
Connection refused [while running 'WriteToMongoDB/ParDo(_WriteMongoFn)']

> Task :sdks:python:test-suites:dataflow:py2:mongodbioIT FAILED

FAILURE: Build failed with an exception.

* Where:
Build file 
'<https://builds.apache.org/job/beam_python_mongoio_load_test/ws/src/sdks/python/test-suites/dataflow/py2/build.gradle'>
 line: 165

* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py2:mongodbioIT'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug 
option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 1m 58s
5 actionable tasks: 5 executed

Publishing build scan...
https://scans.gradle.com/s/zi4c7rvpgy77c

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to