See 
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/10049/display/redirect>

Changes:


------------------------------------------
[...truncated 166.20 KB...]
E     MetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
E     MetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=3993, attempted=3993)
E     MetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionStepProgress), 
labels={'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F14-invoke-617071551014647054/map-tasks-completion/map-tasks',
 'execution_step': 'F14'}), committed=1, attempted=1)
E     MetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 'm_out-out0', 'original_name': 
'm_out-out0-ElementCount'}), committed=5, attempted=5)
E     MetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'original_name': 'm_out-out0-MeanByteCount', 'output_user_name': 
'm_out-out0'}), committed=15, attempted=15)
E     MetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 'GroupByKey/Read-out0-ElementCount', 
'output_user_name': 'GroupByKey/Read-out0'}), committed=1, attempted=1)
E     MetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 'GroupByKey/Read-out0', 'original_name': 
'GroupByKey/Read-out0-MeanByteCount'}), committed=28, attempted=28)
E     MetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
E     MetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
E     MetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)

apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py:61: 
AssertionError
=============================== warnings summary ===============================
../../build/gradleenv/-1734967051/lib/python3.8/site-packages/hdfs/config.py:15
../../build/gradleenv/-1734967051/lib/python3.8/site-packages/hdfs/config.py:15
  
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/build/gradleenv/-1734967051/lib/python3.8/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

../../build/gradleenv/-1734967051/lib/python3.8/site-packages/tenacity/_asyncio.py:42
  
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/build/gradleenv/-1734967051/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):

apache_beam/typehints/pandas_type_compatibility_test.py:67
  
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/sdks/python/apache_beam/typehints/pandas_type_compatibility_test.py>:67:
 FutureWarning: pandas.Int64Index is deprecated and will be removed from pandas 
in a future version. Use pandas.Index with the appropriate dtype instead.
    }).set_index(pd.Int64Index(range(123, 223), name='an_index')),

apache_beam/typehints/pandas_type_compatibility_test.py:90
  
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/sdks/python/apache_beam/typehints/pandas_type_compatibility_test.py>:90:
 FutureWarning: pandas.Int64Index is deprecated and will be removed from pandas 
in a future version. Use pandas.Index with the appropriate dtype instead.
    pd.Int64Index(range(123, 223), name='an_index'),

apache_beam/typehints/pandas_type_compatibility_test.py:91
  
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/sdks/python/apache_beam/typehints/pandas_type_compatibility_test.py>:91:
 FutureWarning: pandas.Int64Index is deprecated and will be removed from pandas 
in a future version. Use pandas.Index with the appropriate dtype instead.
    pd.Int64Index(range(475, 575), name='another_index'),

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file: 
<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/sdks/python/pytest-beam_python3.8_sdk.xml>
 -
=========================== short test summary info ============================
FAILED 
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py::ExerciseMetricsPipelineTest::test_metrics_fnapi_it
 - AssertionError: "Unable to match metrics for matcher  name: 'ElementCount' 
(label_key: 'output_user_name' label_value: 'GroupByKey/Reify-out0').  
(label_key: 'original_name' label_value: 'GroupByKey/Reify-out0-ElementCount'). 
 attempted: a value greater than <0> committed: a value greater than <0>Unable 
to match metrics for matcher  name: 'MeanByteCount' (label_key: 
'output_user_name' label_value: 'GroupByKey/Reify-out0').  (label_key: 
'original_name' label_value: 'GroupByKey/Reify-out0-MeanByteCount').  
attempted: a value greater than <0> committed: a value greater than <0>Unable 
to match metrics for matcher  name: 'ElementCount' (label_key: 
'output_user_name' label_value: 'GroupByKey/GroupByWindow-out0').  (label_key: 
'original_name' label_value: 'GroupByKey/GroupByWindow-out0-ElementCount').  
attempted: a value greater than <0> committed: a value greater than <0>Unable 
to match metrics for matcher  name: 'MeanByteCount' (label_key: 
'output_user_name' label_value: 'GroupByKey/GroupByWindow-out0').  (label_key: 
'original_name' label_value: 'GroupByKey/GroupByWindow-out0-MeanByteCount').  
attempted: a value greater than <0> committed: a value greater than <0>Unable 
to match metrics for matcher  name: 'ElementCount' (label_key: 
'output_user_name' label_value: 'GroupByKey/Reify-out0').  (label_key: 
'original_name' label_value: 'GroupByKey/Reify-out0-ElementCount').  attempted: 
a value greater than <0> committed: a value greater than <0>Unable to match 
metrics for matcher  name: 'MeanByteCount' (label_key: 'output_user_name' 
label_value: 'GroupByKey/Reify-out0').  (label_key: 'original_name' 
label_value: 'GroupByKey/Reify-out0-MeanByteCount').  attempted: a value 
greater than <0> committed: a value greater than <0>\nActual 
MetricResults:\nMetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.UserMetricsDoFn,
 name=total_values), labels={}), committed=100, 
attempted=100)\nMetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.UserMetricsDoFn,
 name=distribution_values), labels={}), committed=DistributionResult(sum=100, 
count=4, min=0, max=100, mean=25.0), attempted=DistributionResult(sum=100, 
count=4, min=0, max=100, mean=25.0))\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalVcpuTime), 
labels={'original_name': 'Service-cpu_num_seconds'}), committed=622, 
attempted=622)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalMemoryUsage), 
labels={'original_name': 'Service-mem_mb_seconds'}), committed=2548240, 
attempted=2548240)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalPdUsage), 
labels={'original_name': 'Service-pd_gb_seconds'}), committed=7776, 
attempted=7776)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalSsdUsage), 
labels={'original_name': 'Service-pd_ssd_gb_seconds'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalShuffleDataProcessed), 
labels={'original_name': 'Service-shuffle_service_actual_gb'}), committed=None, 
attempted=None)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=BillableShuffleDataProcessed), 
labels={'original_name': 'Service-shuffle_service_chargeable_gb'}), 
committed=None, attempted=None)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalStreamingDataProcessed), 
labels={'original_name': 'Service-streaming_service_gb'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=TotalGpuTime), 
labels={'original_name': 'Service-gpu_num_seconds'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=CurrentShuffleSlotCount), 
labels={'original_name': 'dax-shuffle-current-shuffle-slots'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=CurrentVcpuCount), 
labels={'original_name': 'Service-cpu_num'}), committed=2, 
attempted=2)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=CurrentMemoryUsage), 
labels={'original_name': 'Service-mem_mb'}), committed=8192, 
attempted=8192)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=CurrentPdUsage), 
labels={'original_name': 'Service-pd_gb'}), committed=25, 
attempted=25)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=CurrentSsdUsage), 
labels={'original_name': 'Service-pd_ssd_gb'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=CurrentGpuCount), 
labels={'original_name': 'Service-gpu_num'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=PeakShuffleSlotCount), 
labels={'original_name': 'dax-shuffle-peak-shuffle-slots'}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionStepProgress), 
labels={'execution_step': 'F16', 'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F16-invoke-617071551014645850/map-tasks-completion/map-tasks'}),
 committed=1, attempted=1)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0-MeanByteCount'}),
 committed=26, attempted=26)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0-MeanByteCount'}),
 committed=45, attempted=45)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0-ElementCount'}),
 committed=4, attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 'Create/FlatMap(<lambda at 
core.py:3507>)-out0-ElementCount', 'output_user_name': 'Create/FlatMap(<lambda 
at core.py:3507>)-out0'}), committed=4, 
attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0-MeanByteCount', 
'output_user_name': 'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0'}), 
committed=18, attempted=18)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'original_name': 'Create/FlatMap(<lambda at 
core.py:3507>)-out0-MeanByteCount', 'output_user_name': 'Create/FlatMap(<lambda 
at core.py:3507>)-out0'}), committed=14, 
attempted=14)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0', 'original_name': 
'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0-ElementCount'}), 
committed=4, attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'original_name': 'Create/Impulse-out0-MeanByteCount', 
'output_user_name': 'Create/Impulse-out0'}), committed=13, 
attempted=13)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0-ElementCount',
 'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0'}), 
committed=4, attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 'Create/Impulse-out0-ElementCount', 
'output_user_name': 'Create/Impulse-out0'}), committed=1, 
attempted=1)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/AddRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/FlatMap(<lambda at 
core.py:3507>), metric=MetricName(namespace=dataflow/v1b3, 
name=ExecutionTime_StartBundle), labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/AddRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/FlatMap(<lambda at 
core.py:3507>), metric=MetricName(namespace=dataflow/v1b3, 
name=ExecutionTime_FinishBundle), labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/FlatMap(<lambda at 
core.py:3507>), metric=MetricName(namespace=dataflow/v1b3, 
name=ExecutionTime_ProcessElement), labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/AddRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionStepProgress), 
labels={'execution_step': 'F15', 'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F15-invoke-617071551014648018/map-tasks-completion/map-tasks'}),
 committed=1, attempted=1)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 'metrics-out0', 'original_name': 
'metrics-out0-ElementCount'}), committed=4, 
attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0-MeanByteCount'}),
 committed=48, attempted=48)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 'map_to_common_key-out0-ElementCount', 
'output_user_name': 'map_to_common_key-out0'}), committed=4, 
attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0-MeanByteCount', 
'output_user_name': 'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0'}), 
committed=14, attempted=14)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0-ElementCount',
 'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0'}),
 committed=4, attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 'Create/Map(decode)-out0', 'original_name': 
'Create/Map(decode)-out0-MeanByteCount'}), committed=14, 
attempted=14)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 'metrics-out0', 'original_name': 
'metrics-out0-MeanByteCount'}), committed=14, 
attempted=14)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0-ElementCount',
 'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0'}), 
committed=4, attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 'Create/Map(decode)-out0', 'original_name': 
'Create/Map(decode)-out0-ElementCount'}), committed=4, 
attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0', 'original_name': 
'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0-ElementCount'}), 
committed=4, attempted=4)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 'map_to_common_key-out0', 'original_name': 
'map_to_common_key-out0-MeanByteCount'}), committed=18, 
attempted=18)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0',
 'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0-MeanByteCount'}),
 committed=18, 
attempted=18)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)\nMetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=946, 
attempted=946)\nMetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)\nMetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=1000, 
attempted=1000)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=map_to_common_key, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=map_to_common_key, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=map_to_common_key, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, 
attempted=0)\nMetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)\nMetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=3993, attempted=3993)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionStepProgress), 
labels={'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F14-invoke-617071551014647054/map-tasks-completion/map-tasks',
 'execution_step': 'F14'}), committed=1, 
attempted=1)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'output_user_name': 'm_out-out0', 'original_name': 
'm_out-out0-ElementCount'}), committed=5, 
attempted=5)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'original_name': 'm_out-out0-MeanByteCount', 'output_user_name': 
'm_out-out0'}), committed=15, attempted=15)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=ElementCount), 
labels={'original_name': 'GroupByKey/Read-out0-ElementCount', 
'output_user_name': 'GroupByKey/Read-out0'}), committed=1, 
attempted=1)\nMetricResult(key=MetricKey(step=, 
metric=MetricName(namespace=dataflow/v1b3, name=MeanByteCount), 
labels={'output_user_name': 'GroupByKey/Read-out0', 'original_name': 
'GroupByKey/Read-out0-MeanByteCount'}), committed=28, 
attempted=28)\nMetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)\nMetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)\nMetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)" is not false : Unable to match metrics 
for matcher  name: 'ElementCount' (label_key: 'output_user_name' label_value: 
'GroupByKey/Reify-out0').  (label_key: 'original_name' label_value: 
'GroupByKey/Reify-out0-ElementCount').  attempted: a value greater than <0> 
committed: a value greater than <0>Unable to match metrics for matcher  name: 
'MeanByteCount' (label_key: 'output_user_name' label_value: 
'GroupByKey/Reify-out0').  (label_key: 'original_name' label_value: 
'GroupByKey/Reify-out0-MeanByteCount').  attempted: a value greater than <0> 
committed: a value greater than <0>Unable to match metrics for matcher  name: 
'ElementCount' (label_key: 'output_user_name' label_value: 
'GroupByKey/GroupByWindow-out0').  (label_key: 'original_name' label_value: 
'GroupByKey/GroupByWindow-out0-ElementCount').  attempted: a value greater than 
<0> committed: a value greater than <0>Unable to match metrics for matcher  
name: 'MeanByteCount' (label_key: 'output_user_name' label_value: 
'GroupByKey/GroupByWindow-out0').  (label_key: 'original_name' label_value: 
'GroupByKey/GroupByWindow-out0-MeanByteCount').  attempted: a value greater 
than <0> committed: a value greater than <0>Unable to match metrics for matcher 
 name: 'ElementCount' (label_key: 'output_user_name' label_value: 
'GroupByKey/Reify-out0').  (label_key: 'original_name' label_value: 
'GroupByKey/Reify-out0-ElementCount').  attempted: a value greater than <0> 
committed: a value greater than <0>Unable to match metrics for matcher  name: 
'MeanByteCount' (label_key: 'output_user_name' label_value: 
'GroupByKey/Reify-out0').  (label_key: 'original_name' label_value: 
'GroupByKey/Reify-out0-MeanByteCount').  attempted: a value greater than <0> 
committed: a value greater than <0>
Actual MetricResults:
MetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.UserMetricsDoFn,
 name=total_values), labels={}), committed=100, attempted=100)
MetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.UserMetricsDoFn,
 name=distribution_values), labels={}), committed=DistributionResult(sum=100, 
count=4, min=0, max=100, mean=25.0), attempted=DistributionResult(sum=100, 
count=4, min=0, max=100, mean=25.0))
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalVcpuTime), labels={'original_name': 'Service-cpu_num_seconds'}), 
committed=622, attempted=622)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalMemoryUsage), labels={'original_name': 'Service-mem_mb_seconds'}), 
committed=2548240, attempted=2548240)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalPdUsage), labels={'original_name': 'Service-pd_gb_seconds'}), 
committed=7776, attempted=7776)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalSsdUsage), labels={'original_name': 'Service-pd_ssd_gb_seconds'}), 
committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalShuffleDataProcessed), labels={'original_name': 
'Service-shuffle_service_actual_gb'}), committed=None, attempted=None)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=BillableShuffleDataProcessed), labels={'original_name': 
'Service-shuffle_service_chargeable_gb'}), committed=None, attempted=None)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalStreamingDataProcessed), labels={'original_name': 
'Service-streaming_service_gb'}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=TotalGpuTime), labels={'original_name': 'Service-gpu_num_seconds'}), 
committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=CurrentShuffleSlotCount), labels={'original_name': 
'dax-shuffle-current-shuffle-slots'}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=CurrentVcpuCount), labels={'original_name': 'Service-cpu_num'}), 
committed=2, attempted=2)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=CurrentMemoryUsage), labels={'original_name': 'Service-mem_mb'}), 
committed=8192, attempted=8192)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=CurrentPdUsage), labels={'original_name': 'Service-pd_gb'}), committed=25, 
attempted=25)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=CurrentSsdUsage), labels={'original_name': 'Service-pd_ssd_gb'}), 
committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=CurrentGpuCount), labels={'original_name': 'Service-gpu_num'}), 
committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=PeakShuffleSlotCount), labels={'original_name': 
'dax-shuffle-peak-shuffle-slots'}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ExecutionStepProgress), labels={'execution_step': 'F16', 'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F16-invoke-617071551014645850/map-tasks-completion/map-tasks'}),
 committed=1, attempted=1)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0-MeanByteCount'}),
 committed=26, attempted=26)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0-MeanByteCount'}),
 committed=45, attempted=45)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify-out0-ElementCount'}),
 committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 'Create/FlatMap(<lambda at 
core.py:3507>)-out0-ElementCount', 'output_user_name': 'Create/FlatMap(<lambda 
at core.py:3507>)-out0'}), committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0-MeanByteCount', 
'output_user_name': 'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0'}), 
committed=18, attempted=18)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'original_name': 'Create/FlatMap(<lambda at 
core.py:3507>)-out0-MeanByteCount', 'output_user_name': 'Create/FlatMap(<lambda 
at core.py:3507>)-out0'}), committed=14, attempted=14)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0', 'original_name': 
'Create/MaybeReshuffle/Reshuffle/AddRandomKeys-out0-ElementCount'}), 
committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'original_name': 
'Create/Impulse-out0-MeanByteCount', 'output_user_name': 
'Create/Impulse-out0'}), committed=13, attempted=13)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0-ElementCount',
 'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)-out0'}), 
committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 
'Create/Impulse-out0-ElementCount', 'output_user_name': 
'Create/Impulse-out0'}), committed=1, attempted=1)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/AddRandomKeys, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/FlatMap(<lambda at core.py:3507>), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/AddRandomKeys, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/FlatMap(<lambda at core.py:3507>), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/FlatMap(<lambda at core.py:3507>), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/AddRandomKeys, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ExecutionStepProgress), labels={'execution_step': 'F15', 'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F15-invoke-617071551014648018/map-tasks-completion/map-tasks'}),
 committed=1, attempted=1)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'output_user_name': 'metrics-out0', 
'original_name': 'metrics-out0-ElementCount'}), committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0', 
'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0-MeanByteCount'}),
 committed=48, attempted=48)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 
'map_to_common_key-out0-ElementCount', 'output_user_name': 
'map_to_common_key-out0'}), committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0-MeanByteCount', 
'output_user_name': 'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0'}), 
committed=14, attempted=14)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0-ElementCount',
 'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0'}),
 committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 'Create/Map(decode)-out0', 
'original_name': 'Create/Map(decode)-out0-MeanByteCount'}), committed=14, 
attempted=14)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 'metrics-out0', 
'original_name': 'metrics-out0-MeanByteCount'}), committed=14, attempted=14)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0-ElementCount',
 'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read-out0'}), 
committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'output_user_name': 'Create/Map(decode)-out0', 
'original_name': 'Create/Map(decode)-out0-ElementCount'}), committed=4, 
attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0', 'original_name': 
'Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys-out0-ElementCount'}), 
committed=4, attempted=4)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 'map_to_common_key-out0', 
'original_name': 'map_to_common_key-out0-MeanByteCount'}), committed=18, 
attempted=18)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0',
 'original_name': 
'Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)-out0-MeanByteCount'}),
 committed=18, attempted=18)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=946, attempted=946)
MetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=1000, attempted=1000)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=map_to_common_key, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=map_to_common_key, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=map_to_common_key, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys,
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps),
 metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=Create/Map(decode), 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=metrics, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=3993, attempted=3993)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ExecutionStepProgress), labels={'original_name': 
'dax_workflow_stage_progress_/workflows/wf-2022-12-12_03_34_07-1789462535558505897/phases/graph_runner/step-invocations/F14-invoke-617071551014647054/map-tasks-completion/map-tasks',
 'execution_step': 'F14'}), committed=1, attempted=1)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'output_user_name': 'm_out-out0', 'original_name': 
'm_out-out0-ElementCount'}), committed=5, attempted=5)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'original_name': 'm_out-out0-MeanByteCount', 
'output_user_name': 'm_out-out0'}), committed=15, attempted=15)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=ElementCount), labels={'original_name': 
'GroupByKey/Read-out0-ElementCount', 'output_user_name': 
'GroupByKey/Read-out0'}), committed=1, attempted=1)
MetricResult(key=MetricKey(step=, metric=MetricName(namespace=dataflow/v1b3, 
name=MeanByteCount), labels={'output_user_name': 'GroupByKey/Read-out0', 
'original_name': 'GroupByKey/Read-out0-MeanByteCount'}), committed=28, 
attempted=28)
MetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_FinishBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_StartBundle), 
labels={}), committed=0, attempted=0)
MetricResult(key=MetricKey(step=m_out, 
metric=MetricName(namespace=dataflow/v1b3, name=ExecutionTime_ProcessElement), 
labels={}), committed=0, attempted=0)
======= 1 failed, 4 passed, 5 skipped, 6 warnings in 2675.40s (0:44:35) ========
cleanup_container
Untagged: 
us.gcr.io/apache-beam-testing/jenkins/beam_python3.8_sdk:20221212-105434236360014
Untagged: 
us.gcr.io/apache-beam-testing/jenkins/beam_python3.8_sdk@sha256:f976aa2b2340732a73bfc90b52f435b3f1bf25e7c1682e7d3861e424cf96e77a
Untagged: 
us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk:82b16fe8-a1db-413c-8a16-98f321029989
Untagged: 
us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk@sha256:8e0cfbc2eeb1713457fdee45962e9498a07a5fc13d894d7713ef28955e34d66d
Deleted: sha256:953a837cda33d8cbb3ec77a1bd6370bf6ed702e6ec549c52983ad2845ce9c98b
Deleted: sha256:1686446c3fbde58aaea6a37bdcecd9f9a98a3367e07fc51863429925bc31461f
Deleted: sha256:af35feac8e3c2d6da0cd2a494185835d0a8c063d7e4b2447e65dab59d4c531a6
Deleted: sha256:1abc83251a4726ae9e7723e188041a379319775de65fa1a48d17f7b4ec770050
Deleted: sha256:a37fe563a1b46dcff987193730411dea8432fa4f2db8165ed646d0bce4f32d65
Deleted: sha256:8387abf9cb4063e92d87af201c63fad239d5a4c2395cd61ce1ba4e96049ce537
WARNING: Successfully resolved tag to sha256, but it is recommended to use 
sha256 directly.
Digests:
- 
us.gcr.io/apache-beam-testing/jenkins/beam_python3.8_sdk@sha256:f976aa2b2340732a73bfc90b52f435b3f1bf25e7c1682e7d3861e424cf96e77a
  Associated tags:
 - 20221212-105434236360014
Tags:
- 
us.gcr.io/apache-beam-testing/jenkins/beam_python3.8_sdk:20221212-105434236360014
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/beam_python3.8_sdk:20221212-105434236360014].
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/beam_python3.8_sdk@sha256:f976aa2b2340732a73bfc90b52f435b3f1bf25e7c1682e7d3861e424cf96e77a].
Digests:
- 
us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk@sha256:8e0cfbc2eeb1713457fdee45962e9498a07a5fc13d894d7713ef28955e34d66d
  Associated tags:
 - 82b16fe8-a1db-413c-8a16-98f321029989
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk:82b16fe8-a1db-413c-8a16-98f321029989].
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk@sha256:8e0cfbc2eeb1713457fdee45962e9498a07a5fc13d894d7713ef28955e34d66d].
Digests:
- 
us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk@sha256:3bdb465b9444c41ef037e63a14b48014beb15aaa7c2c19d1cdd603e515ba80aa
  Associated tags:
 - 7b763b28-86d2-4cd9-abb9-fa43c423157d
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk:7b763b28-86d2-4cd9-abb9-fa43c423157d].
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python38_sdk/beam_python_prebuilt_sdk@sha256:3bdb465b9444c41ef037e63a14b48014beb15aaa7c2c19d1cdd603e515ba80aa].
Removed the container

> Task :sdks:python:test-suites:dataflow:py38:validatesContainer FAILED

> Task :sdks:python:test-suites:dataflow:py310:validatesContainer
cleanup_container
WARNING: Successfully resolved tag to sha256, but it is recommended to use 
sha256 directly.
Digests:
- 
us.gcr.io/apache-beam-testing/jenkins/beam_python3.10_sdk@sha256:1813372afd118f1122ab3f16fdc0cac163771a4f81ea274954554f1d4b73bfc4
  Associated tags:
 - 20221212-105434317747432
Tags:
- 
us.gcr.io/apache-beam-testing/jenkins/beam_python3.10_sdk:20221212-105434317747432
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/beam_python3.10_sdk:20221212-105434317747432].
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/beam_python3.10_sdk@sha256:1813372afd118f1122ab3f16fdc0cac163771a4f81ea274954554f1d4b73bfc4].
Digests:
- 
us.gcr.io/apache-beam-testing/jenkins/prebuild_python310_sdk/beam_python_prebuilt_sdk@sha256:3abc3cd4a1ff3f78a1648097242186a3602210dc6a4dc9870d00aab48803bd34
  Associated tags:
 - 62517be2-d1d5-428f-8308-daa403535104
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python310_sdk/beam_python_prebuilt_sdk:62517be2-d1d5-428f-8308-daa403535104].
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python310_sdk/beam_python_prebuilt_sdk@sha256:3abc3cd4a1ff3f78a1648097242186a3602210dc6a4dc9870d00aab48803bd34].
Digests:
- 
us.gcr.io/apache-beam-testing/jenkins/prebuild_python310_sdk/beam_python_prebuilt_sdk@sha256:f312da5e5a8f906ef8dca8e24e2fe8bde0d3c48ff26a100c02dd765e794b2d9e
  Associated tags:
 - f6c6d703-f958-405a-bf51-c4faaab2f581
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python310_sdk/beam_python_prebuilt_sdk:f6c6d703-f958-405a-bf51-c4faaab2f581].
Deleted 
[us.gcr.io/apache-beam-testing/jenkins/prebuild_python310_sdk/beam_python_prebuilt_sdk@sha256:f312da5e5a8f906ef8dca8e24e2fe8bde0d3c48ff26a100c02dd765e794b2d9e].

> Task :sdks:python:test-suites:dataflow:py310:validatesContainer FAILED

FAILURE: Build completed with 4 failures.

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

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:dataflow:py37:validatesContainer'.
> 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_Py_ValCont/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
 line: 331

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

3: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
 line: 331

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

4: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_Py_ValCont/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
 line: 331

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:dataflow:py310:validatesContainer'.
> 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 1h 2m 46s
62 actionable tasks: 51 executed, 4 from cache, 7 up-to-date

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

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