You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/06/19 19:48:38 UTC
Build failed in Jenkins: beam_PostCommit_Python_Verify #2525
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2525/display/redirect?page=changes>
Changes:
[jbonofre] [BEAM-975] Improve default connection options, javadoc and style in
------------------------------------------
[...truncated 585.90 KB...]
}
primitive_transform {
id: "9"
function_spec {
id: "10"
urn: "urn:org.apache.beam:sink:runner:0.1"
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "0"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "6"
}
}
step_name: "FlatMap(cross_product)/0"
}
coders {
function_spec {
id: "6"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\207\001{\"component_encodings\": [{\"@type\": \"kind:bytes\"}, {\"@type\": \"kind:global_window\"}], \"is_wrapper\": true, \"@type\": \"kind:windowed_value\"}"
}
}
}
coders {
function_spec {
id: "4"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\372\002{\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}, {\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}"
}
}
}
}
}
root: INFO: CONTROL RESPONSE instruction_id: "12"
register {
}
root: INFO: CONTROL REQUEST instruction_id: "13"
process_bundle {
process_bundle_descriptor_reference: "11"
}
root: INFO: start <DataOutputOperation FlatMap(cross_product)/0 >
root: INFO: start <DataOutputOperation FlatMap(cross_product)/Write >
root: INFO: start <DoOperation Create/Read output_tags=[u'out']>
root: INFO: start <DataInputOperation Create/Read/inject_source receivers=[ConsumerSet[Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DataInputOperation Create/Read/inject_source receivers=[ConsumerSet[Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DoOperation Create/Read output_tags=[u'out'], receivers=[ConsumerSet[Create/Read.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=2]]>
root: INFO: finish <DataOutputOperation FlatMap(cross_product)/Write >
root: INFO: finish <DataOutputOperation FlatMap(cross_product)/0 >
root: INFO: CONTROL RESPONSE instruction_id: "13"
process_bundle {
}
root: INFO: Running [('assert_that/Create/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource object at 0x7f53943b9bd0>, start_position=None, stop_position=None))), ('assert_that/Group/pair_with_0', WorkerDoFn(output_tags=['out'], input=(0, 0))), ('assert_that/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0], write_windowed_values=True, input=(1, 0)))]
root: INFO: CONTROL REQUEST instruction_id: "27"
register {
process_bundle_descriptor {
id: "26"
primitive_transform {
id: "15"
function_spec {
id: "17"
urn: "urn:org.apache.beam:source:runner:0.1"
}
inputs {
key: "16"
value {
}
}
outputs {
key: "out"
value {
coder_reference: "18"
}
}
step_name: "assert_that/Create/Read/inject_source"
}
primitive_transform {
id: "14"
function_spec {
id: "19"
urn: "urn:org.apache.beam:dofn:java:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\230\003eNp1kMluAjEQRAnZwJAFsucL4DJfgUiiSHCAUU6RZXs8YMlbexHiMFJyifLZMQxSxIFjV5XrdfurOWDEErbkmHKiMhe15s5n1rhAqJAirLNSY2IFri00lQWfmegYn9lkp5TkIzPWCBrDbziqoJl3cFhbjpdCBw/He/0bY6tnBWfGkWCcR2/TeZJfNzKCk9RyOqngbJB3TQw2hm2bh/NJ3hH6f25N4g+0qafDCtAndPY5jmhfGqd8ljAcfQhdmJXQCwTdBLio4HKQ94NQ3AeiLGZGUZHOg6v3RtpfeFzwkkQZ4Po3bwcnFgvuSg29Q5RdBI3qZ/PdCP1Eu6ngluY9wlhUUZIgjMbKFBzuEqy12q6Wuu8PddcJ9CINJbK+JH3UQ2p+rOCJRhrgOfsDh82nFA=="
}
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "15"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "20"
}
}
step_name: "assert_that/Create/Read"
}
primitive_transform {
id: "21"
function_spec {
id: "22"
urn: "urn:org.apache.beam:dofn:java:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\210\010eNq9VG1z1DYQ9tkXcnHS8pa2tEBDgRQfbc6BvgKBpiQNL26O4ESEzjSjkW3dSZxteSU515vhZuDDAZ/4p/0PyJd0ks4QPjKjsbWr1fOsn931C9uLSUFiRnFESdbSkuSqI2SmWrGQ1F0haUqilG5LUhRUroq13AWr+RJqQ7A9NI31oKCY8VwrcP6PZA7G/lZCDRTRQir3waMt475fuV2oG5iJ9hCOeWhGlLoo9RhNwWQbTfP8wG60y1cwFaHJQoqYKgVunPA0bVUPF8eSEk1xp8xjzYVJb9o7fJwKkoxxXJhBjRWR0CoF+GQEn4Zw3AtqgRPU1+eW0ek3lvXcrJr13Lbe1qxuzdqEE+0RnGyi2j9wCtWJ7Co4jY71+uPd7Gv4DOU+Exn1n9G8x3P133tBpWSX+n0he8poQv1KErwhlF4RWcY13hhoJnL8hEreGfgq6Sm/GLv8Qxr6B9Xwq2q0igF8jhpLKcmihNyBL9b/tZEFZ5DdyeHLEXzV1HA2hHMxxlHJU81zjN0u1URr6cL5w6rwrBBS40wkZWqU+Rqd/UAXwNwILoTwDWpgnPBYYwwXX8GlEC6jWVwQLrEmXdznmuFdkpYU5tvvKVBMjQHfsmmPGdntoB4465vL6JzR/G/bGprlVMpX+jtWx67WJlwx+ntND9mtRWgix/DAVeT06AC+QxN7ZN9rWPhoZSg1T6sytNh80EF1x5qqgd80ui+GcI2dZ0cLWd2E6yP4IYQfmZHvpxB+ZvNt0/+/MIdVs/Cr2d/w2GSbjRv+ZqQ03AphaQS3Q7gzgt+GsOztx/5uYu8exK5EZhSrpixojE0zrLKlUsMfIawhp7LvsbUy2oH7gUWG8GAHHn5w6Ld5nog+z7suBIbrzyGse+iU5hlVmmQFjkUW8ZxKaAeW4eUKJ7RDylTDozdoSkve7VJpWDeOYtkPcVf3rm3tm/DYsIVD2IzQSRLHZVampBrpqk0pbBmyRn+cmsFGR2HvRbj3UhGRdO9LzL/miUHeHsLTqIw0/NV6B4N/u+4="
}
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "14"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "23"
}
}
step_name: "assert_that/Group/pair_with_0"
}
primitive_transform {
id: "24"
function_spec {
id: "25"
urn: "urn:org.apache.beam:sink:runner:0.1"
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "21"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "23"
}
}
step_name: "assert_that/Group/Flatten/Write"
}
coders {
function_spec {
id: "23"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\346\017{\"component_encodings\": [{\"is_pair_like\": true, \"component_encodings\": [{\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"is_pair_like\": true, \"component_encodings\": [{\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"kind:pair\"}], \"@type\": \"kind:pair\"}, {\"@type\": \"kind:global_window\"}], \"is_wrapper\": true, \"@type\": \"kind:windowed_value\"}"
}
}
}
coders {
function_spec {
id: "20"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\321\n{\"component_encodings\": [{\"is_pair_like\": true, \"component_encodings\": [{\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"@type\": \"kind:pair\"}, {\"@type\": \"kind:global_window\"}], \"is_wrapper\": true, \"@type\": \"kind:windowed_value\"}"
}
}
}
coders {
function_spec {
id: "18"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\372\002{\"is_pair_like\": true, \"component_encodings\": [{\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}, {\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}"
}
}
}
}
}
root: INFO: CONTROL RESPONSE instruction_id: "27"
register {
}
root: INFO: CONTROL REQUEST instruction_id: "28"
process_bundle {
process_bundle_descriptor_reference: "26"
}
root: INFO: start <DataOutputOperation assert_that/Group/Flatten/Write >
root: INFO: start <DoOperation assert_that/Group/pair_with_0 output_tags=[u'out']>
root: INFO: start <DoOperation assert_that/Create/Read output_tags=[u'out']>
root: INFO: start <DataInputOperation assert_that/Create/Read/inject_source receivers=[ConsumerSet[assert_that/Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DataInputOperation assert_that/Create/Read/inject_source receivers=[ConsumerSet[assert_that/Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DoOperation assert_that/Create/Read output_tags=[u'out'], receivers=[ConsumerSet[assert_that/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
root: INFO: finish <DoOperation assert_that/Group/pair_with_0 output_tags=[u'out'], receivers=[ConsumerSet[assert_that/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
root: INFO: finish <DataOutputOperation assert_that/Group/Flatten/Write >
root: INFO: CONTROL RESPONSE instruction_id: "28"
process_bundle {
}
root: INFO: Running [('FlatMap(cross_product)/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.runners.portability.maptask_executor_runner.InMemorySource object at 0x7f53943c04d0>, start_position=None, stop_position=None))), ('FlatMap(cross_product)', WorkerDoFn(output_tags=['out'], input=(0, 0), side_inputs=[WorkerSideInputSource(source=<apache_beam.runners.portability.maptask_executor_runner.InMemorySource object at 0x7f53943eb690>, tag=0)])), ('assert_that/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(1, 0))), ('assert_that/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(2, 0))), ('assert_that/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(3, 0))), ('assert_that/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[1], write_windowed_values=True, input=(4, 0)))]
--------------------- >> end captured logging << ---------------------
======================================================================
FAIL: test_using_slow_impl (apache_beam.coders.slow_coders_test.SlowCoders)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/coders/slow_coders_test.py",> line 41, in test_using_slow_impl
import apache_beam.coders.stream
AssertionError: ImportError not raised
----------------------------------------------------------------------
Ran 1249 tests in 196.402s
FAILED (failures=1, errors=2, skipped=16)
Test failed: <unittest.runner.TextTestResult run=1249 errors=2 failures=1>
error: Test failed: <unittest.runner.TextTestResult run=1249 errors=2 failures=1>
ERROR: InvocationError: '<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/target/.tox/py27gcp/bin/python> setup.py test'
___________________________________ summary ____________________________________
docs: commands succeeded
lint: commands succeeded
ERROR: py27: commands failed
ERROR: py27cython: commands failed
ERROR: py27gcp: commands failed
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user kirpichov@google.com
Jenkins build is back to normal : beam_PostCommit_Python_Verify
#2528
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2528/display/redirect?page=changes>
Build failed in Jenkins: beam_PostCommit_Python_Verify #2527
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2527/display/redirect?page=changes>
Changes:
[iemejia] Make HBaseIO tests faster by only using the core daemons needed by HBase
------------------------------------------
[...truncated 584.71 KB...]
}
primitive_transform {
id: "9"
function_spec {
id: "10"
urn: "urn:org.apache.beam:sink:runner:0.1"
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "0"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "6"
}
}
step_name: "FlatMap(cross_product)/0"
}
coders {
function_spec {
id: "6"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\207\001{\"is_wrapper\": true, \"@type\": \"kind:windowed_value\", \"component_encodings\": [{\"@type\": \"kind:bytes\"}, {\"@type\": \"kind:global_window\"}]}"
}
}
}
coders {
function_spec {
id: "4"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\372\002{\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}, {\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}], \"is_pair_like\": true, \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}"
}
}
}
}
}
root: INFO: CONTROL RESPONSE instruction_id: "12"
register {
}
root: INFO: CONTROL REQUEST instruction_id: "13"
process_bundle {
process_bundle_descriptor_reference: "11"
}
root: INFO: start <DataOutputOperation FlatMap(cross_product)/0 >
root: INFO: start <DataOutputOperation FlatMap(cross_product)/Write >
root: INFO: start <DoOperation Create/Read output_tags=[u'out']>
root: INFO: start <DataInputOperation Create/Read/inject_source receivers=[ConsumerSet[Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DataInputOperation Create/Read/inject_source receivers=[ConsumerSet[Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DoOperation Create/Read output_tags=[u'out'], receivers=[ConsumerSet[Create/Read.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=2]]>
root: INFO: finish <DataOutputOperation FlatMap(cross_product)/Write >
root: INFO: finish <DataOutputOperation FlatMap(cross_product)/0 >
root: INFO: CONTROL RESPONSE instruction_id: "13"
process_bundle {
}
root: INFO: Running [('assert_that/Create/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource object at 0x7f544c04a5d0>, start_position=None, stop_position=None))), ('assert_that/Group/pair_with_0', WorkerDoFn(output_tags=['out'], input=(0, 0))), ('assert_that/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0], write_windowed_values=True, input=(1, 0)))]
root: INFO: CONTROL REQUEST instruction_id: "27"
register {
process_bundle_descriptor {
id: "26"
primitive_transform {
id: "15"
function_spec {
id: "17"
urn: "urn:org.apache.beam:source:runner:0.1"
}
inputs {
key: "16"
value {
}
}
outputs {
key: "out"
value {
coder_reference: "18"
}
}
step_name: "assert_that/Create/Read/inject_source"
}
primitive_transform {
id: "14"
function_spec {
id: "19"
urn: "urn:org.apache.beam:dofn:java:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\224\003eNp1kMtqAjEYha29abQX7b1PoJt5CrEtBV3o0FUJSSajgdz+XBAXA+2m9LEbHaG4cPmfc/jOSb6aA0YsYUuOKScqc1Fr7nxmjQuECinCOis1Jlbg2kJTWfCZiY7xmU12Skk+MmONoDH8hqMKmnkHh7XleCl08HC8x98YWz0rODOOBOM8epvOk/y6kRGcJMrppIKzQd41MdgYtjQP55O8I/T/3ZrEH2hTT4cVoE/o7Pc4on1pnPJZquHoQ+jCrIReIOimgosKLgdpp/C44CWJMsDVb94jjEUVJQnCaKxMweH6vZH3g1DcB6IsZkZRkX4BeklvrbbQUkP/UHedQC/SUCLrDemJN2nBbQV3NG8HJxYL7hLj/hBjF0Gjeuh8d8JDojxW8EQjDfCc/QF5CacU"
}
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "15"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "20"
}
}
step_name: "assert_that/Create/Read"
}
primitive_transform {
id: "21"
function_spec {
id: "22"
urn: "urn:org.apache.beam:dofn:java:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\210\010eNq9k21z1DYQx332ARcHWkgobXlICgXqg3IObSkPBZr2UhJqckmdKIEZGI1s607q2ZZXkjluhpspLw541W/Kd6h8CZMwQ3jZGY3t3ZX/Wv129x/bi0lBYkZxREnW0pLkqitkplqxkNRtkzQlUUq3JSkKKpfEg9wFq/kKaiOwPeTgbg5OnPA0bVUPF8eSEk1xt8xjzYXZXPf2h1NBEqyHBXXhEGq0RUI3jQGHx3AkhIYX1AInqK/OL6LZt5b10qya9dK2/q1ZvZq1AVOdMbhNVHsB06hOZE/BUXS4P5h8HXsDn6HcZyKj/t807/NcvX9fUyl5Tv2BkH1l7kr96qp4XSjdFlnGNV4faiZyvEUl7w59lfSVX0xc/j42/h4bv2LTKobwOWrcTUkWJeQ+HF99ZyMLTiDbMJkZw2xTw8kQvogxjkqeap5j7PaoJlpLF07tp8KzQkiNM5GUqSHzJTrziZrAV2P4OoTTqIFxwmONMZx5DWdDOIdO4oJwiTXp4QHXDD8naUlhrvORAsXUGDDP6h4z2O2gHjirG4vorGH+1LZGZjkV+Yq/Y3Xtam3AN4b/+aaH7NYCXECOOQe+RU6fDuEiOrRz2CUNl/+3MpSap1UZvmNzQRfVHWuqBl7TcG+GcIWdYgeDrP6Eq2P4PoRrzOBrheCzuU5nBAtoetKgmPFcK7j+4XiYwMTfSqipBdFCKvfhWtXDK5XbhR/MbPxoZH7y0FFR6qLUEzUFNzpomud79s+d8jXcjJSGWyHcHsOdEH4Zw90R3PNMBlVLFzSuxus+u82us0r3V6O76LEbHTb5+beo1PB7CO3d8JIJ/7EXfhChI4UUMVUKllm7jJ7BSmCRETx8Bn9+cui3eZ6IAc97LgRG99EIVqucuMIJ7ZIy1dB5i06QOC6zMiXVmFetS2EtsNCM5hlVmmQFjkUW8ZxKWDf+xmAiau7z10Fn7+xwl1MRkXQnBwM0NBlsjGAzQlNa8l6PSqOBDtLY3eIu7SS6uWvCllHZHsHjqIw0PGn9B+NhvSc="
}
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "14"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "23"
}
}
step_name: "assert_that/Group/pair_with_0"
}
primitive_transform {
id: "24"
function_spec {
id: "25"
urn: "urn:org.apache.beam:sink:runner:0.1"
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "21"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "23"
}
}
step_name: "assert_that/Group/Flatten/Write"
}
coders {
function_spec {
id: "23"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\346\017{\"is_wrapper\": true, \"@type\": \"kind:windowed_value\", \"component_encodings\": [{\"component_encodings\": [{\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [{\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"kind:pair\"}], \"is_pair_like\": true, \"@type\": \"kind:pair\"}, {\"@type\": \"kind:global_window\"}]}"
}
}
}
coders {
function_spec {
id: "20"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\321\n{\"is_wrapper\": true, \"@type\": \"kind:windowed_value\", \"component_encodings\": [{\"component_encodings\": [{\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}, {\"component_encodings\": [], \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\"}], \"is_pair_like\": true, \"@type\": \"kind:pair\"}, {\"@type\": \"kind:global_window\"}]}"
}
}
}
coders {
function_spec {
id: "18"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\372\002{\"component_encodings\": [{\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}, {\"component_encodings\": [], \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}], \"is_pair_like\": true, \"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\"}"
}
}
}
}
}
root: INFO: CONTROL RESPONSE instruction_id: "27"
register {
}
root: INFO: CONTROL REQUEST instruction_id: "28"
process_bundle {
process_bundle_descriptor_reference: "26"
}
root: INFO: start <DataOutputOperation assert_that/Group/Flatten/Write >
root: INFO: start <DoOperation assert_that/Group/pair_with_0 output_tags=[u'out']>
root: INFO: start <DoOperation assert_that/Create/Read output_tags=[u'out']>
root: INFO: start <DataInputOperation assert_that/Create/Read/inject_source receivers=[ConsumerSet[assert_that/Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DataInputOperation assert_that/Create/Read/inject_source receivers=[ConsumerSet[assert_that/Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DoOperation assert_that/Create/Read output_tags=[u'out'], receivers=[ConsumerSet[assert_that/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
root: INFO: finish <DoOperation assert_that/Group/pair_with_0 output_tags=[u'out'], receivers=[ConsumerSet[assert_that/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
root: INFO: finish <DataOutputOperation assert_that/Group/Flatten/Write >
root: INFO: CONTROL RESPONSE instruction_id: "28"
process_bundle {
}
root: INFO: Running [('FlatMap(cross_product)/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.runners.portability.maptask_executor_runner.InMemorySource object at 0x7f544c3e8a50>, start_position=None, stop_position=None))), ('FlatMap(cross_product)', WorkerDoFn(output_tags=['out'], input=(0, 0), side_inputs=[WorkerSideInputSource(source=<apache_beam.runners.portability.maptask_executor_runner.InMemorySource object at 0x7f544c340bd0>, tag=0)])), ('assert_that/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(1, 0))), ('assert_that/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(2, 0))), ('assert_that/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(3, 0))), ('assert_that/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[1], write_windowed_values=True, input=(4, 0)))]
--------------------- >> end captured logging << ---------------------
======================================================================
FAIL: test_using_slow_impl (apache_beam.coders.slow_coders_test.SlowCoders)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/coders/slow_coders_test.py",> line 41, in test_using_slow_impl
import apache_beam.coders.stream
AssertionError: ImportError not raised
----------------------------------------------------------------------
Ran 1249 tests in 130.688s
FAILED (failures=1, errors=2, skipped=16)
Test failed: <unittest.runner.TextTestResult run=1249 errors=2 failures=1>
error: Test failed: <unittest.runner.TextTestResult run=1249 errors=2 failures=1>
ERROR: InvocationError: '<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/target/.tox/py27gcp/bin/python> setup.py test'
___________________________________ summary ____________________________________
docs: commands succeeded
lint: commands succeeded
ERROR: py27: commands failed
ERROR: py27cython: commands failed
ERROR: py27gcp: commands failed
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user kirpichov@google.com
Build failed in Jenkins: beam_PostCommit_Python_Verify #2526
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2526/display/redirect>
------------------------------------------
[...truncated 584.74 KB...]
}
primitive_transform {
id: "9"
function_spec {
id: "10"
urn: "urn:org.apache.beam:sink:runner:0.1"
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "0"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "6"
}
}
step_name: "FlatMap(cross_product)/0"
}
coders {
function_spec {
id: "4"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\372\002{\"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\", \"component_encodings\": [{\"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\", \"component_encodings\": []}, {\"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\", \"component_encodings\": []}], \"is_pair_like\": true}"
}
}
}
coders {
function_spec {
id: "6"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\207\001{\"is_wrapper\": true, \"@type\": \"kind:windowed_value\", \"component_encodings\": [{\"@type\": \"kind:bytes\"}, {\"@type\": \"kind:global_window\"}]}"
}
}
}
}
}
root: INFO: CONTROL RESPONSE instruction_id: "12"
register {
}
root: INFO: CONTROL REQUEST instruction_id: "13"
process_bundle {
process_bundle_descriptor_reference: "11"
}
root: INFO: start <DataOutputOperation FlatMap(cross_product)/0 >
root: INFO: start <DataOutputOperation FlatMap(cross_product)/Write >
root: INFO: start <DoOperation Create/Read output_tags=[u'out']>
root: INFO: start <DataInputOperation Create/Read/inject_source receivers=[ConsumerSet[Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DataInputOperation Create/Read/inject_source receivers=[ConsumerSet[Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DoOperation Create/Read output_tags=[u'out'], receivers=[ConsumerSet[Create/Read.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=2]]>
root: INFO: finish <DataOutputOperation FlatMap(cross_product)/Write >
root: INFO: finish <DataOutputOperation FlatMap(cross_product)/0 >
root: INFO: CONTROL RESPONSE instruction_id: "13"
process_bundle {
}
root: INFO: Running [('assert_that/Create/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource object at 0x7f12282ffdd0>, start_position=None, stop_position=None))), ('assert_that/Group/pair_with_0', WorkerDoFn(output_tags=['out'], input=(0, 0))), ('assert_that/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0], write_windowed_values=True, input=(1, 0)))]
root: INFO: CONTROL REQUEST instruction_id: "27"
register {
process_bundle_descriptor {
id: "26"
primitive_transform {
id: "15"
function_spec {
id: "17"
urn: "urn:org.apache.beam:source:runner:0.1"
}
inputs {
key: "16"
value {
}
}
outputs {
key: "out"
value {
coder_reference: "18"
}
}
step_name: "assert_that/Create/Read/inject_source"
}
primitive_transform {
id: "14"
function_spec {
id: "19"
urn: "urn:org.apache.beam:dofn:java:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\230\003eNp1kctqAjEYha29abQX7b1PoJt5CukFQRcauiohyWQ0kEny54K4GGg3pY/d6AjFhcv/nMN3DslXc8CppXwpCBO0zFzUWjifWeMCZVLJsM4KTaiVpLbQVOViZqLjYmaTnVJKjMyLRtAYfsNRBU3cIWFtBVlKHTwc7/E3xlbPcsGNo8E4j96n8yS/bWQEJ4lyOqngbIC7JgYbw5bm4XyCO1L/361J/IE282xYAfqEzn6Po9oXxpU+SzUCfUidm5XUCwTdVHBRweUg7ZSe5KKgUQW4+sU9ynkso6JBGk1Kkwu4HjdwOzi5WAhXaOgdKtlF0KimzXcn9FPZTQW3DLdW2wkJcncIUifQqzKMqnpxepD7hHio4JHhfpCl8IGWlnBTMpm+A57GjcgCPGd/iJenFA=="
}
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "15"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "20"
}
}
step_name: "assert_that/Create/Read"
}
primitive_transform {
id: "21"
function_spec {
id: "22"
urn: "urn:org.apache.beam:dofn:java:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\210\010eNq9VG1v1EYQ9tkXcnHS8pa2tEBDgRQfbc6BvgKBpiQNL26O4GQJlRqt1vbe7XK217O7zvUkToIPB3zin/Y/sL6kSioRPiKN7J3Z8TOjZ57xC9uLSUFiRnFESdbSkuSqI2SmWrGQ1F0haUqilG5LUhRUroq13AWr+RJqQ7A9NI31oKCY8VwrcP6PZC7G8VZCDRTRQir3waMtE75fhV2oG5iJ9hCOeWhGlLoo9RhNwWQbTfP8wG+0y1cwFaHJQoqYKgVunPA0bVUPF8eSEk1xp8xjzYVpb9o7fJ0KkoxxXJhBjRWR0KoF+GQEn4Zw3AtqgRPU1+eW0ek3lvXcWM16bltva1a3Zm3CifYITjZR7R84hepEdhWcRsd6/fFp9jV8hnKfiYz6z2je47n6772gUrJL/b6QPWU4oX5FCd4QSq+ILOMabww0Ezl+QiXvDHyV9JRfjEP+IQ79g2n41TRaxQA+R42llGRRQu7AF+v/2siCM8ju5PDlCL5qajgbwrkY46jkqeY5xm6XaqK1dOH8YVZ4VgipcSaSMjXMfI3OfkAFMDeCCyF8gxoYJzzWGMPFV3AphMtoFheES6xJF/e5ZniXpCWF+fZ7BhRT48C3bNpjhnY7qAfO+uYyOmc4/9u2hsacivmKf8fq2JVtwhXDv9f0kN1ahCZyTB24ipweHcB3aGKv2PcaFj7aGErN02oMLTYfdFDdsaZq4DcN74shXGPn2dFEVl/C9RH8EMKPzND3Uwg/s/m20f8vzGHVLvxqzjc8NtlmY8HfjJSGWyEsjeB2CHdG8NsQlr393N9N7t2D3JXIrGIlyoLG2IhhlS2VGv4IYQ05lX+PrZXRDtwPLDKEBzvw8INLv83zRPR53nUhMLX+HMJ6tepc4YR2SJlqaL9BJ0kcl1mZkmrpKiFReBRYaEpL3u1SaYpuHFVkP8Vd3UPb2nfhsSkWDmEzQo3+uAUDsnUUyF6Gey8VEUn3Ojb/FGQgngxhO0KnNM+o0iQrcCyyiOdUwtPAKiMNf7XeAY6fu+4="
}
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "14"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "23"
}
}
step_name: "assert_that/Group/pair_with_0"
}
primitive_transform {
id: "24"
function_spec {
id: "25"
urn: "urn:org.apache.beam:sink:runner:0.1"
}
inputs {
key: "ignored_input_tag"
value {
target {
primitive_transform_reference: "21"
name: "out"
}
}
}
outputs {
key: "out"
value {
coder_reference: "23"
}
}
step_name: "assert_that/Group/Flatten/Write"
}
coders {
function_spec {
id: "23"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\346\017{\"is_wrapper\": true, \"@type\": \"kind:windowed_value\", \"component_encodings\": [{\"@type\": \"kind:pair\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}], \"is_pair_like\": true}, {\"@type\": \"kind:pair\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}], \"is_pair_like\": true}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}], \"is_pair_like\": true}], \"is_pair_like\": true}], \"is_pair_like\": true}, {\"@type\": \"kind:global_window\"}]}"
}
}
}
coders {
function_spec {
id: "18"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\372\002{\"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\", \"component_encodings\": [{\"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\", \"component_encodings\": []}, {\"@type\": \"DillCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlwumTk5ziAmVyGDZmMhY20hU5IeAMyHESs=\", \"component_encodings\": []}], \"is_pair_like\": true}"
}
}
}
coders {
function_spec {
id: "20"
urn: "urn:org.apache.beam:coder:python:0.1"
data {
type_url: "type.googleapis.com/google.protobuf.BytesValue"
value: "\n\321\n{\"is_wrapper\": true, \"@type\": \"kind:windowed_value\", \"component_encodings\": [{\"@type\": \"kind:pair\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}], \"is_pair_like\": true}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": [{\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}, {\"@type\": \"FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/\", \"component_encodings\": []}], \"is_pair_like\": true}], \"is_pair_like\": true}, {\"@type\": \"kind:global_window\"}]}"
}
}
}
}
}
root: INFO: CONTROL RESPONSE instruction_id: "27"
register {
}
root: INFO: CONTROL REQUEST instruction_id: "28"
process_bundle {
process_bundle_descriptor_reference: "26"
}
root: INFO: start <DataOutputOperation assert_that/Group/Flatten/Write >
root: INFO: start <DoOperation assert_that/Group/pair_with_0 output_tags=[u'out']>
root: INFO: start <DoOperation assert_that/Create/Read output_tags=[u'out']>
root: INFO: start <DataInputOperation assert_that/Create/Read/inject_source receivers=[ConsumerSet[assert_that/Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DataInputOperation assert_that/Create/Read/inject_source receivers=[ConsumerSet[assert_that/Create/Read/inject_source.out0, coder=DillCoder, len(consumers)=1]]>
root: INFO: finish <DoOperation assert_that/Create/Read output_tags=[u'out'], receivers=[ConsumerSet[assert_that/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
root: INFO: finish <DoOperation assert_that/Group/pair_with_0 output_tags=[u'out'], receivers=[ConsumerSet[assert_that/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
root: INFO: finish <DataOutputOperation assert_that/Group/Flatten/Write >
root: INFO: CONTROL RESPONSE instruction_id: "28"
process_bundle {
}
root: INFO: Running [('FlatMap(cross_product)/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.runners.portability.maptask_executor_runner.InMemorySource object at 0x7f12282f1d90>, start_position=None, stop_position=None))), ('FlatMap(cross_product)', WorkerDoFn(output_tags=['out'], input=(0, 0), side_inputs=[WorkerSideInputSource(source=<apache_beam.runners.portability.maptask_executor_runner.InMemorySource object at 0x7f12282f1fd0>, tag=0)])), ('assert_that/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(1, 0))), ('assert_that/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(2, 0))), ('assert_that/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(3, 0))), ('assert_that/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[1], write_windowed_values=True, input=(4, 0)))]
--------------------- >> end captured logging << ---------------------
======================================================================
FAIL: test_using_slow_impl (apache_beam.coders.slow_coders_test.SlowCoders)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/coders/slow_coders_test.py",> line 41, in test_using_slow_impl
import apache_beam.coders.stream
AssertionError: ImportError not raised
----------------------------------------------------------------------
Ran 1249 tests in 134.010s
FAILED (failures=1, errors=2, skipped=16)
Test failed: <unittest.runner.TextTestResult run=1249 errors=2 failures=1>
error: Test failed: <unittest.runner.TextTestResult run=1249 errors=2 failures=1>
ERROR: InvocationError: '<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/target/.tox/py27gcp/bin/python> setup.py test'
___________________________________ summary ____________________________________
docs: commands succeeded
lint: commands succeeded
ERROR: py27: commands failed
ERROR: py27cython: commands failed
ERROR: py27gcp: commands failed
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user kirpichov@google.com