See 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1116/display/redirect>

Changes:


------------------------------------------
[...truncated 182.21 MB...]
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.actor.Actor.aroundReceive(Actor.scala:537)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.actor.Actor.aroundReceive$(Actor.scala:535)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.actor.ActorCell.invoke(ActorCell.scala:548)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.dispatch.Mailbox.run(Mailbox.scala:231)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   ... 4 
more
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Caused 
by: java.io.IOException: Insufficient number of network buffers: required 16, 
but only 0 available. The total number of network buffers is currently set to 
2048 of 32768 bytes each. You can increase this number by setting the 
configuration keys 'taskmanager.memory.network.fraction', 
'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.internalCreateBufferPool(NetworkBufferPool.java:483)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:461)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.io.network.partition.ResultPartitionFactory.lambda$createBufferPoolFactory$0(ResultPartitionFactory.java:279)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.io.network.partition.ResultPartition.setup(ResultPartition.java:160)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.io.network.partition.SortMergeResultPartition.setup(SortMergeResultPartition.java:190)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.taskmanager.Task.setupPartitionsAndGates(Task.java:959)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:652)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126   at 
java.lang.Thread.run(Thread.java:750)
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM 
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess 
closeInternal
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopping SessionDispatcherLeaderProcess.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM 
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl closeAsync
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopping resource manager service.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
close
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Closing the slot manager.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM 
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager 
suspend
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Suspending the slot manager.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl 
lambda$getFileCloser$0
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
FileChannelManager removed spill file directory 
/tmp/flink-io-b4a5ad2d-6509-417b-b491-872b3027caea
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.io.network.NettyShuffleEnvironment 
close
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Shutting down the network environment and its components.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopping dispatcher akka://flink/user/rpc/dispatcher_2.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.dispatcher.Dispatcher 
terminateRunningJobs
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopping all currently running jobs of dispatcher 
akka://flink/user/rpc/dispatcher_2.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.io.disk.FileChannelManagerImpl 
lambda$getFileCloser$0
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
FileChannelManager removed spill file directory 
/tmp/flink-netty-shuffle-c5ec830e-eed7-49b0-94a5-30877c406683
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.taskexecutor.KvStateService shutdown
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Shutting down the kvState service and its components.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService 
stop
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stop job leader service.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$1
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopped dispatcher akka://flink/user/rpc/dispatcher_2.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.filecache.FileCache shutdown
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
removed file cache directory 
/tmp/flink-dist-cache-065e2305-4a5c-45c6-922f-ba65e1c6d3bf
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor 
handleOnStopException
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopped TaskExecutor akka://flink/user/rpc/taskmanager_0.
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopping Akka RPC service.
INFO     apache_beam.runners.portability.portable_runner:portable_runner.py:583 
Job state changed to FAILED
---------------------------- Captured log teardown -----------------------------
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Shutting down BLOB cache
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.blob.BlobServer close
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopped BLOB server at 0.0.0.0:36805
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 14, 
2022 9:50:22 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$8
INFO     apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: 
Stopped Akka RPC service.
=============================== warnings summary ===============================
../../build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py:15
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py>:15:
 DeprecationWarning: the imp module is deprecated in favour of importlib; see 
the module's documentation for alternative uses
    from imp import load_source

apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:63:
 PendingDeprecationWarning: Client.dataset is deprecated and will be removed in 
a future version. Use a string like 'my_project.my_dataset' or a 
cloud.google.bigquery.DatasetReference object, instead.
    dataset_ref = client.dataset(unique_dataset_name, project=project)

apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:1992:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    is_streaming_pipeline = p.options.view_as(StandardOptions).streaming

apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:1998:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    experiments = p.options.view_as(DebugOptions).experiments or []

apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1149:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    temp_location = p.options.view_as(GoogleCloudOptions).temp_location

apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1151:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    p.options.view_as(GoogleCloudOptions).job_name or 'AUTOMATIC_JOB_NAME')

apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2485:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    temp_location = pcoll.pipeline.options.view_as(

apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2487:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    job_name = pcoll.pipeline.options.view_as(GoogleCloudOptions).job_name

apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2518:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    | _PassThroughThenCleanup(files_to_remove_pcoll))

apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:1988:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    self.table_reference.projectId = pcoll.pipeline.options.view_as(

apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1142:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    self.project = self.project or p.options.view_as(GoogleCloudOptions).project

apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher

Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
  File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.7/threading.py", line 870, in run
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:100:
 PendingDeprecationWarning: Client.dataset is deprecated and will be removed in 
a future version. Use a string like 'my_project.my_dataset' or a 
cloud.google.bigquery.DatasetReference object, instead.
    table_ref = client.dataset(dataset_id).table(table_id)

    self._target(*self._args, **self._kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 671, in <lambda>
    target=lambda: self._read_inputs(elements_iterator),
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 654, in _read_inputs
    for elements in elements_iterator:
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
 line 426, in __next__
    return self._next()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
 line 826, in _next
    raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that 
terminated with:
        status = StatusCode.CANCELLED
        details = "Multiplexer hanging up"
        debug_error_string = "UNKNOWN:Error received from peer 
ipv6:%5B::1%5D:45271 {created_time:"2022-11-14T09:49:58.082957924+00:00", 
grpc_status:1, grpc_message:"Multiplexer hanging up"}"
>

apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
  File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.7/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/examples/dataframe/flight_delays.py>:47:
 FutureWarning: Dropping of nuisance columns in DataFrame reductions (with 
'numeric_only=None') is deprecated; in a future version this will raise 
TypeError.  Select only valid columns before calling the reduction.
    return airline_df[at_top_airports].mean()

  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 671, in <lambda>
    target=lambda: self._read_inputs(elements_iterator),
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
 line 654, in _read_inputs
    for elements in elements_iterator:
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
 line 426, in __next__
    return self._next()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
 line 826, in _next
    raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that 
terminated with:
        status = StatusCode.CANCELLED
        details = "Multiplexer hanging up"
        debug_error_string = "UNKNOWN:Error received from peer 
ipv6:%5B::1%5D:32791 {created_time:"2022-11-14T09:51:09.846171222+00:00", 
grpc_status:1, grpc_message:"Multiplexer hanging up"}"
>

apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/dataframe/io.py>:664:
 FutureWarning: WriteToFiles is experimental.
    sink=lambda _: _WriteToPandasFileSink(

apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics
  
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/fileio.py>:590:
 BeamDeprecationWarning: options is deprecated since First stable release. 
References to <pipeline>.options will not be supported
    p.options.view_as(GoogleCloudOptions).temp_location or

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file: 
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/pytest_postCommitExamples-flink-py37.xml>
 -
=========================== short test summary info ============================
FAILED apache_beam/examples/complete/tfidf_it_test.py::TfIdfIT::test_basics - 
RuntimeError: Pipeline 
BeamApp-jenkins-1114094301-2a9c253a_64c5f0f2-267e-429d-97ec-6ab555f4161a failed 
in state FAILED: java.io.IOException: Insufficient number of network buffers: 
required 2, but only 0 available. The total number of network buffers is 
currently set to 2048 of 32768 bytes each. You can increase this number by 
setting the configuration keys 'taskmanager.memory.network.fraction', 
'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'.
FAILED 
apache_beam/examples/cookbook/custom_ptransform_it_test.py::CustomPTransformIT::test_custom_ptransform_output_files_on_small_input
 - ValueError: Pipeline has validations errors: 
Option environment_config is not compatible with environment type LOOPBACK.
FAILED 
apache_beam/examples/cookbook/multiple_output_pardo_test.py::MultipleOutputParDo::test_multiple_output_pardo
 - RuntimeError: Pipeline 
BeamApp-jenkins-1114095015-830a339d_0044d6e3-4eda-4c40-b3de-b78ac14d6fe7 failed 
in state FAILED: java.io.IOException: Insufficient number of network buffers: 
required 16, but only 0 available. The total number of network buffers is 
currently set to 2048 of 32768 bytes each. You can increase this number by 
setting the configuration keys 'taskmanager.memory.network.fraction', 
'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'.
= 3 failed, 19 passed, 6 skipped, 6706 deselected, 41 warnings in 700.58s 
(0:11:40) =

> Task :sdks:python:test-suites:portable:py37:flinkExamples FAILED

FAILURE: Build completed with 2 failures.

1: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 240

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py310:flinkExamples'.
> 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.
==============================================================================

2: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 240

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py37:flinkExamples'.
> 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.
==============================================================================

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

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 13m 41s
133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date

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

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