See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1167/display/redirect>
Changes:
------------------------------------------
[...truncated 58.40 MB...]
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 27,
2022 3:49:35 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name MapPartition (MapPartition at [2]write short
words/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3507>), Map(decode)})
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Nov 27,
2022 3:49:36 AM org.apache.beam.runners.jobsubmission.JobInvocation$1 onFailure
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 SEVERE:
Error during job invocation
BeamApp-jenkins-1127034928-b3d8ded4_afb07e3c-59f2-47f5-9c16-87683d57b979.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:259)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.OnComplete.internal(Future.scala:300)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.OnComplete.internal(Future.scala:297)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Caused
by: org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.reflect.GeneratedMethodAccessor31.invoke(Unknown Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
java.lang.reflect.Method.invoke(Method.java:498)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
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 9 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
ERROR root:portable_runner.py:577 java.io.IOException: Insufficient number
of network buffers: required 16, but only 9 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.runners.portability.portable_runner:portable_runner.py:583
Job state changed to FAILED
=============================== 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
<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)
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
<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()
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-1127034249-d95ebb37_8b90b90a-86ab-42af-aa61-3412aa7c2089 failed
in state FAILED: java.io.IOException: Insufficient number of network buffers:
required 16, but only 13 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/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
- RuntimeError: Pipeline
BeamApp-jenkins-1127034450-30f11e89_662bcdea-0950-4571-8026-ea120e7575c1 failed
in state FAILED: java.io.IOException: Insufficient number of network buffers:
required 17, 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/mergecontacts_test.py::MergeContactsTest::test_mergecontacts
- RuntimeError: Pipeline
BeamApp-jenkins-1127034850-7cd9b3a9_79b3f7ed-a646-4265-9701-8cd00c06468a failed
in state FAILED: java.io.IOException: Insufficient number of network buffers:
required 17, but only 6 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/multiple_output_pardo_test.py::MultipleOutputParDo::test_multiple_output_pardo
- RuntimeError: Pipeline
BeamApp-jenkins-1127034928-b3d8ded4_afb07e3c-59f2-47f5-9c16-87683d57b979 failed
in state FAILED: java.io.IOException: Insufficient number of network buffers:
required 16, but only 9 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'.
= 4 failed, 18 passed, 6 skipped, 6723 deselected, 41 warnings in 657.13s
(0:10:57) =
> Task :sdks:python:test-suites:portable:py37:flinkExamples FAILED
> Task :sdks:python:test-suites:portable:py310: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: 245
* 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.
==============================================================================
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: 245
* 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.
==============================================================================
* 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 7s
133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/niwrtoube4246
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]
