You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2021/09/01 18:06:56 UTC

Build failed in Jenkins: beam_PostCommit_Python_VR_Samza #175

See <https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/175/display/redirect?page=changes>

Changes:

[baeminbo] Fix apiclient_test unittest not to fail with no credentials

[noreply] [BEAM-10913] - Adding new Grafana dashboard to monitor GAs post-commit


------------------------------------------
[...truncated 1.38 MB...]

self = <apache_beam.runners.portability.samza_runner_test.SamzaRunnerTest testMethod=test_windowing>

    def test_windowing(self):
      with self.create_pipeline() as p:
        res = (
            p
            | beam.Create([1, 2, 100, 101, 102])
            | beam.Map(lambda t: window.TimestampedValue(('k', t), t))
            | beam.WindowInto(beam.transforms.window.Sessions(10))
            | beam.GroupByKey()
            | beam.Map(lambda k_vs1: (k_vs1[0], sorted(k_vs1[1]))))
>       assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])]))

apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:775: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/pipeline.py:587: in __exit__
    self.result.wait_until_finish()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.runners.portability.portable_runner.PipelineResult object at 0x7f6343dfc3a0>
duration = None

    def wait_until_finish(self, duration=None):
      """
      :param duration: The maximum time in milliseconds to wait for the result of
      the execution. If None or zero, will wait until the pipeline finishes.
      :return: The result of the pipeline, i.e. PipelineResult.
      """
      def read_messages():
        # type: () -> None
        previous_state = -1
        for message in self._message_stream:
          if message.HasField('message_response'):
            logging.log(
                MESSAGE_LOG_LEVELS[message.message_response.importance],
                "%s",
                message.message_response.message_text)
          else:
            current_state = message.state_response.state
            if current_state != previous_state:
              _LOGGER.info(
                  "Job state changed to %s",
                  self._runner_api_state_to_pipeline_state(current_state))
              previous_state = current_state
          self._messages.append(message)
    
      message_thread = threading.Thread(
          target=read_messages, name='wait_until_finish_read')
      message_thread.daemon = True
      message_thread.start()
    
      if duration:
        state_thread = threading.Thread(
            target=functools.partial(self._observe_state, message_thread),
            name='wait_until_finish_state_observer')
        state_thread.daemon = True
        state_thread.start()
        start_time = time.time()
        duration_secs = duration / 1000
        while (time.time() - start_time < duration_secs and
               state_thread.is_alive()):
          time.sleep(1)
      else:
        self._observe_state(message_thread)
    
      if self._runtime_exception:
>       raise self._runtime_exception
E       RuntimeError: Pipeline test_windowing_1630519610.7909203_3a25345d-a922-42c6-bdea-038b299a256e failed in state FAILED: java.lang.NullPointerException

apache_beam/runners/portability/portable_runner.py:600: RuntimeError
----------------------------- Captured stderr call -----------------------------
WARNING:root:Make sure that locally built Python SDK docker image has Python 3.8 interpreter.
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService - Staging artifacts for job_518093f5-05e3-4d09-ae47-1ab4978305fe.
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService - Resolving artifacts for job_518093f5-05e3-4d09-ae47-1ab4978305fe.ref_Environment_default_environment_1.
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService - Getting 0 artifacts for job_518093f5-05e3-4d09-ae47-1ab4978305fe.null.
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService - Artifacts fully staged for job_518093f5-05e3-4d09-ae47-1ab4978305fe.
[grpc-default-executor-1] INFO org.apache.beam.runners.jobsubmission.JobInvocation - Starting job invocation test_windowing_1630519610.7909203_3a25345d-a922-42c6-bdea-038b299a256e
[samza-runner-job-invoker-1] INFO org.apache.beam.runners.samza.SamzaPipelineRunner - Portable pipeline to run:
[samza-runner-job-invoker-1] INFO org.apache.beam.runners.samza.SamzaPipelineRunner - digraph {
    rankdir=LR
    0 [label="Create/Impulse\nbeam:transform:impulse:v1"]
    1 [label="14Create/Impulse.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    0 -> 1 [style=solid label="1"]
    2 [label="Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey\nbeam:transform:group_by_key:v1"]
    1 -> 2 [style=solid label="4"]
    3 [label="58Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    2 -> 3 [style=solid label="5"]
    4 [label="assert_that/Create/Impulse\nbeam:transform:impulse:v1"]
    5 [label="GroupByKey\nbeam:transform:group_by_key:v1"]
    3 -> 5 [style=solid label="10"]
    6 [label="26assert_that/Create/Impulse.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    4 -> 6 [style=solid label="13"]
    7 [label="10GroupByKey.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    5 -> 7 [style=solid label="11"]
    8 [label="unzipped_flatten:0\nbeam:transform:flatten:v1"]
    6 -> 8 [style=solid label="20:1"]
    7 -> 8 [style=solid label="20:0"]
    9 [label="assert_that/Group/_CoGBKImpl/GroupByKey\nbeam:transform:group_by_key:v1"]
    8 -> 9 [style=solid label="20"]
    10 [label="39assert_that/Group/_CoGBKImpl/GroupByKey.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    9 -> 10 [style=solid label="21"]
}

[samza-runner-job-invoker-1] INFO org.apache.beam.runners.samza.SamzaRunner - Portable pipeline to run DOT graph:
digraph {
    rankdir=LR
    0 [label="Create/Impulse\nbeam:transform:impulse:v1"]
    1 [label="14Create/Impulse.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    0 -> 1 [style=solid label="1"]
    2 [label="Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey\nbeam:transform:group_by_key:v1"]
    1 -> 2 [style=solid label="4"]
    3 [label="58Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    2 -> 3 [style=solid label="5"]
    4 [label="assert_that/Create/Impulse\nbeam:transform:impulse:v1"]
    5 [label="GroupByKey\nbeam:transform:group_by_key:v1"]
    3 -> 5 [style=solid label="10"]
    6 [label="26assert_that/Create/Impulse.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    4 -> 6 [style=solid label="13"]
    7 [label="10GroupByKey.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    5 -> 7 [style=solid label="11"]
    8 [label="unzipped_flatten:0\nbeam:transform:flatten:v1"]
    6 -> 8 [style=solid label="20:1"]
    7 -> 8 [style=solid label="20:0"]
    9 [label="assert_that/Group/_CoGBKImpl/GroupByKey\nbeam:transform:group_by_key:v1"]
    8 -> 9 [style=solid label="20"]
    10 [label="39assert_that/Group/_CoGBKImpl/GroupByKey.None/beam:env:external:v1:0\nbeam:runner:executable_stage:v1"]
    9 -> 10 [style=solid label="21"]
}

[samza-runner-job-invoker-1] INFO org.apache.beam.runners.samza.translation.ConfigBuilder - Execution environment is LOCAL
[samza-runner-job-invoker-0] ERROR org.apache.beam.runners.jobsubmission.JobInvocation - Error during job invocation test_windowing_1630519610.7909203_3a25345d-a922-42c6-bdea-038b299a256e.
java.lang.RuntimeException: Failed to invoke samza job
	at org.apache.beam.runners.samza.SamzaPipelineRunner.run(SamzaPipelineRunner.java:83)
	at org.apache.beam.runners.jobsubmission.JobInvocation.runPipeline(JobInvocation.java:86)
	at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:125)
	at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:57)
	at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:78)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.RuntimeException: java.lang.IllegalArgumentException: Failed to serialize PipelineOptions
	at org.apache.beam.runners.samza.translation.ConfigBuilder.build(ConfigBuilder.java:110)
	at org.apache.beam.runners.samza.SamzaRunner.runPortablePipeline(SamzaRunner.java:93)
	at org.apache.beam.runners.samza.SamzaPipelineRunner.run(SamzaPipelineRunner.java:73)
	... 7 more
Caused by: java.lang.IllegalArgumentException: Failed to serialize PipelineOptions
	at org.apache.beam.runners.core.construction.SerializablePipelineOptions.serializeToJson(SerializablePipelineOptions.java:70)
	at org.apache.beam.runners.core.construction.SerializablePipelineOptions.<init>(SerializablePipelineOptions.java:44)
	at org.apache.beam.runners.samza.translation.ConfigBuilder.build(ConfigBuilder.java:102)
	... 9 more
Caused by: com.fasterxml.jackson.databind.JsonMappingException: Error while populating display data for component 'org.apache.beam.sdk.options.ProxyInvocationHandler$PipelineOptionsDisplayData': null
	at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider._wrapAsIOE(DefaultSerializerProvider.java:509)
	at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider._serialize(DefaultSerializerProvider.java:482)
	at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider.serializeValue(DefaultSerializerProvider.java:319)
	at com.fasterxml.jackson.databind.ObjectMapper._writeValueAndClose(ObjectMapper.java:4487)
	at com.fasterxml.jackson.databind.ObjectMapper.writeValueAsString(ObjectMapper.java:3742)
	at org.apache.beam.runners.core.construction.SerializablePipelineOptions.serializeToJson(SerializablePipelineOptions.java:68)
	... 11 more
Caused by: org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder$PopulateDisplayDataException: Error while populating display data for component 'org.apache.beam.sdk.options.ProxyInvocationHandler$PipelineOptionsDisplayData': null
	at org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder.include(DisplayData.java:784)
	at org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder.delegate(DisplayData.java:740)
	at org.apache.beam.sdk.options.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:157)
	at com.sun.proxy.$Proxy0.populateDisplayData(Unknown Source)
	at org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder.include(DisplayData.java:775)
	at org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder.access$100(DisplayData.java:703)
	at org.apache.beam.sdk.transforms.display.DisplayData.from(DisplayData.java:81)
	at org.apache.beam.sdk.options.ProxyInvocationHandler$Serializer.serialize(ProxyInvocationHandler.java:706)
	at org.apache.beam.sdk.options.ProxyInvocationHandler$Serializer.serialize(ProxyInvocationHandler.java:654)
	at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider._serialize(DefaultSerializerProvider.java:480)
	... 15 more
Caused by: java.lang.NullPointerException
	at com.fasterxml.jackson.databind.DeserializationContext.isEnabled(DeserializationContext.java:395)
	at com.fasterxml.jackson.databind.deser.std.StdDeserializer._checkFromStringCoercion(StdDeserializer.java:1364)
	at com.fasterxml.jackson.databind.deser.std.StdDeserializer._parseIntPrimitive(StdDeserializer.java:728)
	at com.fasterxml.jackson.databind.deser.std.NumberDeserializers$IntegerDeserializer.deserialize(NumberDeserializers.java:529)
	at com.fasterxml.jackson.databind.deser.std.NumberDeserializers$IntegerDeserializer.deserialize(NumberDeserializers.java:506)
	at org.apache.beam.sdk.options.PipelineOptionsFactory.deserializeNode(PipelineOptionsFactory.java:1791)
	at org.apache.beam.sdk.options.ProxyInvocationHandler.getValueFromJson(ProxyInvocationHandler.java:517)
	at org.apache.beam.sdk.options.ProxyInvocationHandler.getValueFromJson(ProxyInvocationHandler.java:512)
	at org.apache.beam.sdk.options.ProxyInvocationHandler.access$400(ProxyInvocationHandler.java:93)
	at org.apache.beam.sdk.options.ProxyInvocationHandler$PipelineOptionsDisplayData.populateDisplayData(ProxyInvocationHandler.java:359)
	at org.apache.beam.sdk.transforms.display.DisplayData$InternalBuilder.include(DisplayData.java:775)
	... 24 more
ERROR:root:java.lang.NullPointerException
------------------------------ Captured log call -------------------------------
WARNING  root:environments.py:371 Make sure that locally built Python SDK docker image has Python 3.8 interpreter.
ERROR    root:portable_runner.py:567 java.lang.NullPointerException
=============================== warnings summary ===============================
target/.tox-samza-runner-test/samza-runner-test/lib/python3.8/site-packages/tenacity/_asyncio.py:42
  <https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/ws/src/sdks/python/test-suites/portable/py38/build/srcs/sdks/python/target/.tox-samza-runner-test/samza-runner-test/lib/python3.8/site-packages/tenacity/_asyncio.py>:42: DeprecationWarning: "@coroutine" decorator is deprecated since Python 3.8, use "async def" instead
    def call(self, fn, *args, **kwargs):

-- Docs: https://docs.pytest.org/en/latest/warnings.html
- generated xml file: <https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/ws/src/sdks/python/test-suites/portable/py38/build/srcs/sdks/python/pytest_samza-runner-test.xml> -
========= 35 failed, 1 passed, 14 skipped, 1 warnings in 30.98 seconds =========
ERROR: InvocationError for command <https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/ws/src/sdks/python/test-suites/portable/py38/build/srcs/sdks/python/scripts/pytest_validates_runner.sh> samza-runner-test apache_beam/runners/portability/samza_runner_test.py '--samza_job_server_jar=<https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/ws/src/runners/samza/job-server/build/libs/beam-runners-samza-job-server-2.34.0-SNAPSHOT.jar> --environment_type=LOOPBACK' (exited with code 1)
samza-runner-test run-test-post: commands[0] | bash <https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/ws/src/sdks/python/test-suites/portable/py38/build/srcs/sdks/python/scripts/run_tox_cleanup.sh>
___________________________________ summary ____________________________________
ERROR:   samza-runner-test: commands failed

> Task :sdks:python:test-suites:portable:py38:samzaCompatibilityMatrixLOOPBACK FAILED

FAILURE: Build completed with 3 failures.

1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py36:samzaCompatibilityMatrixLOOPBACK'.
> 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.
==============================================================================

2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py37:samzaCompatibilityMatrixLOOPBACK'.
> 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.
==============================================================================

3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py38:samzaCompatibilityMatrixLOOPBACK'.
> 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/6.8.3/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 5m 57s
66 actionable tasks: 43 executed, 23 from cache

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

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

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


Jenkins build is back to normal : beam_PostCommit_Python_VR_Samza #176

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_VR_Samza/176/display/redirect?page=changes>


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