See 
<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/668/display/redirect?page=changes>

Changes:

[kedin] [SQL] Add custom table name resolution

------------------------------------------
[...truncated 362.09 KB...]
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 268, in 
test_multimap_side_input_type_coercion
    equal_to([('a', [1, 3]), ('b', [2])]))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_multimap_side_input_type_coercion_1565906568.15_39c0c7fc-3240-4f66-896d-5f18747729df
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 105, in 
test_pardo
    assert_that(res, equal_to(['aax', 'bcbcx']))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_1565906573.19_d24a7e41-142f-4a6d-b2f7-29aea202a94e failed in state 
FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 177, in 
test_pardo_side_and_main_outputs
    assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_side_and_main_outputs_1565906573.81_7fb1f562-c022-4bf7-a338-4ceb12d8a0d9
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 188, in 
test_pardo_side_inputs
    ('a', 'y'), ('b', 'y'), ('c', 'y')]))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_side_inputs_1565906575.05_b6ba0928-9933-48c2-95f1-f21cb159c569 
failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_side_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 159, in 
test_pardo_side_outputs
    assert_that(xy.y, equal_to(['y', 'xy']), label='y')
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_side_outputs_1565906575.6_08eb8af4-1694-4712-8018-3d3d8fd8a7f8 
failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_state_only (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 309, in 
test_pardo_state_only
    equal_to(expected))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_state_only_1565906576.17_9d6172d2-08bd-412a-a48c-447fc85b1951 failed 
in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_state_timers (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 402, in 
test_pardo_state_timers
    self._run_pardo_state_timers(False)
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 462, in 
_run_pardo_state_timers
    assert_that(actual, is_buffered_correctly)
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_state_timers_1565906576.57_6a7b43d3-090d-4cf6-99ad-dd31d3d0189a 
failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_timers (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 362, in 
test_pardo_timers
    assert_that(actual, equal_to(expected))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_timers_1565906577.11_5f9998f8-cad0-4a71-9560-8f95db86ef6c failed in 
state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 278, in 
test_pardo_unfusable_side_inputs
    equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')]))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_unfusable_side_inputs_1565906577.51_f37d0ff7-5d7f-4124-8b06-3f2b39942abf
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 215, in 
test_pardo_windowed_side_inputs
    label='windowed')
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_pardo_windowed_side_inputs_1565906577.9_52f56649-613e-40f5-9b4c-d13dca964d03
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 593, in 
test_read
    equal_to(['a', 'b', 'c']))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_read_1565906578.34_0bec2092-9b03-4e5e-ab57-88a290092400 failed in state 
FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_reshuffle (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 563, in 
test_reshuffle
    equal_to([1, 2, 3]))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_reshuffle_1565906578.73_7ca2b52e-4004-48d6-b0fc-5a9b631231c1 failed in 
state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_sdf_wrap_range_source (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 549, in 
test_sdf_wrap_range_source
    self._run_sdf_wrapper_pipeline(RangeSource(0, 4), [0, 1, 2, 3])
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 535, in 
_run_sdf_wrapper_pipeline
    p | beam.io.Read(source)
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_sdf_wrap_range_source_1565906579.2_e784db48-04d5-4c6a-9066-16a608ba8dbc 
failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_sdf_wrapper_overrides_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/mock/mock.py";,>
 line 1305, in patched
    return func(*args, **keywargs)
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 546, in 
test_sdf_wrapper_overrides_read
    self._run_sdf_wrapper_pipeline(RangeSource(0, 4), ['1'])
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 535, in 
_run_sdf_wrapper_pipeline
    p | beam.io.Read(source)
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_sdf_wrapper_overrides_read_1565906579.43_515c2403-6a39-44f5-8324-de9c3a1840a5
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_windowed_pardo_state_timers (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 405, in 
test_windowed_pardo_state_timers
    self._run_pardo_state_timers(True)
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 462, in 
_run_pardo_state_timers
    assert_that(actual, is_buffered_correctly)
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_windowed_pardo_state_timers_1565906579.65_f4944a07-accc-40a9-9ab1-a01192cfd510
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
ERROR: test_windowing (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 605, in 
test_windowing
    assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])]))
  File "apache_beam/pipeline.py", line 426, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 455, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
test_windowing_1565906580.09_ae30a59b-58db-4445-9990-a94f7477f2b1 failed in 
state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder

======================================================================
FAIL: test_assert_that (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 93, in 
test_assert_that
    assert_that(p | beam.Create(['a', 'b']), equal_to(['a']))
AssertionError: "Failed assert" does not match "Pipeline 
test_assert_that_1565906536.24_369dc874-1d29-4b0f-8d37-5889c5d6f16a failed in 
state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder"

======================================================================
FAIL: test_error_message_includes_stage (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 639, in 
test_error_message_includes_stage
    self.assertIn('StageC', message)
AssertionError: 'StageC' not found in u'Pipeline 
test_error_message_includes_stage_1565906543.25_80ac4295-355c-421f-bdb5-e86d5a3e6612
 failed in state FAILED: java.lang.ClassCastException: 
org.apache.beam.sdk.coders.LengthPrefixCoder cannot be cast to 
org.apache.beam.sdk.coders.KvCoder'

----------------------------------------------------------------------
Ran 38 tests in 44.478s

FAILED (failures=2, errors=22, skipped=10)

> Task :sdks:python:test-suites:portable:py2:sparkValidatesRunner FAILED

FAILURE: Build failed with an exception.

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

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py2:sparkValidatesRunner'.
> 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 3m 20s
60 actionable tasks: 48 executed, 12 from cache

Publishing build scan...
https://gradle.com/s/zyk23cl5oq7zg

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

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Reply via email to