From builds-return-15298-archive-asf-public=cust-asf.ponee.io@beam.apache.org Sun Jun 30 12:11:16 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id E892D180645 for ; Sun, 30 Jun 2019 14:11:15 +0200 (CEST) Received: (qmail 77377 invoked by uid 500); 30 Jun 2019 12:11:15 -0000 Mailing-List: contact builds-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: builds@beam.apache.org Delivered-To: mailing list builds@beam.apache.org Received: (qmail 77366 invoked by uid 99); 30 Jun 2019 12:11:15 -0000 Received: from Unknown (HELO mailrelay1-lw-us.apache.org) (10.10.3.159) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 30 Jun 2019 12:11:15 +0000 Received: from jenkins02.apache.org (jenkins02.apache.org [195.201.213.130]) by mailrelay1-lw-us.apache.org (ASF Mail Server at mailrelay1-lw-us.apache.org) with ESMTP id C6DFA8108 for ; Sun, 30 Jun 2019 12:11:14 +0000 (UTC) Received: from jenkins02.apache.org (localhost.localdomain [127.0.0.1]) by jenkins02.apache.org (ASF Mail Server at jenkins02.apache.org) with ESMTP id 19E4A33E018F for ; Sun, 30 Jun 2019 12:11:13 +0000 (UTC) Date: Sun, 30 Jun 2019 12:11:13 +0000 (UTC) From: Apache Jenkins Server To: builds@beam.apache.org Message-ID: <745053339.3519.1561896673321.JavaMail.jenkins@jenkins02> Subject: Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #843 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable X-Instance-Identity: MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAkqVKZPv7YyHBB3FvWfV7XQehwe/Ga3aadzSNknt8g382X3uN8A3SOQ+Ixq9HxS+ZlN6XR4TECySmSRy2JN5Rx8svxAD0TjtSF9LuU98dD+LniNDP7Lq6gvRFuJhbMHoS0nuTizDZLsK4X8TW5MyV9w+jFbdoZfRE5O/Mse0fkOeL5uoIS/3Vvu/W+x9QSjDkB7CaU56bPFlQjqqJBl3Cn9r34CkXQZYnLb/NjW4vcpw0+TgMUAPTIVEr5BTPZRshz19g7huwg3zANT5HBIZnzV4hsVY9w4JHkceFdKi/ibNnjPjsFs9pm0HSGJ/RDxjIvSTYT02eH4+m1RAYaj2E9QIDAQAB X-Jenkins-Job: beam_PreCommit_Portable_Python_Cron X-Jenkins-Result: FAILURE See ------------------------------------------ [...truncated 1.09 MB...] [group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGro= up - Name collision: Group already contains a Metric with the name 'beam.me= tric:element_count:v1'. Metric will not be reported.[localhost, taskmanager= , 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [= 2]{count, format}, 1] [group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGro= up - Name collision: Group already contains a Metric with the name 'beam.me= tric:sampled_byte_size:v1'. Metric will not be reported.[localhost, taskman= ager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea= 7, [2]{count, format}, 1] [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/write/ref_PCollection_PCollection_24:0=20 [group -> [2]{count, format} (1/2)] INFO org.apache.flink.runtime.taskmanag= er.Task - group -> [2]{count, format} (1/2) (ab189f33ab6788d4c37e08df553e27= 56) switched from RUNNING to FINISHED. [group -> [2]{count, format} (1/2)] INFO org.apache.flink.runtime.taskmanag= er.Task - Freeing task resources for group -> [2]{count, format} (1/2) (ab1= 89f33ab6788d4c37e08df553e2756). [group -> [2]{count, format} (1/2)] INFO org.apache.flink.runtime.taskmanag= er.Task - Ensuring all FileSystem streams are closed for task group -> [2]{= count, format} (1/2) (ab189f33ab6788d4c37e08df553e2756) [FINISHED] [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task group -> [2]{count, format} ab189f33ab678= 8d4c37e08df553e2756. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - group -> [2]{count, format} (1/2) (ab189f33ab678= 8d4c37e08df553e2756) switched from RUNNING to FINISHED. [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/read/ref_PCollection_PCollection_17:0=20 [group -> [2]{count, format} (2/2)] INFO org.apache.flink.runtime.taskmanag= er.Task - group -> [2]{count, format} (2/2) (4836fac250546b61a49718fc5ad0c1= 6b) switched from RUNNING to FINISHED. [group -> [2]{count, format} (2/2)] INFO org.apache.flink.runtime.taskmanag= er.Task - Freeing task resources for group -> [2]{count, format} (2/2) (483= 6fac250546b61a49718fc5ad0c16b). [group -> [2]{count, format} (2/2)] INFO org.apache.flink.runtime.taskmanag= er.Task - Ensuring all FileSystem streams are closed for task group -> [2]{= count, format} (2/2) (4836fac250546b61a49718fc5ad0c16b) [FINISHED] [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task group -> [2]{count, format} 4836fac250546= b61a49718fc5ad0c16b. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - group -> [2]{count, format} (2/2) (4836fac250546= b61a49718fc5ad0c16b) switched from RUNNING to FINISHED. [[2]write/Write/WriteImpl/DoOnce/{FlatMap(), Map(de= code)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> ToKeyedWorkIt= em, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] INFO org.apache.= flink.runtime.taskmanager.Task - [2]write/Write/WriteImpl/DoOnce/{FlatMap(<= lambda at core.py:2257>), Map(decode)} -> [1]write/Write/WriteImpl/Initiali= zeWrite -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedW= orkItem) (1/2) (6dbc5fac3b796b4e1c53cd4fe93bb4ea) switched from RUNNING to = FINISHED. [[2]write/Write/WriteImpl/DoOnce/{FlatMap(), Map(de= code)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> ToKeyedWorkIt= em, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] INFO org.apache.= flink.runtime.taskmanager.Task - Freeing task resources for [2]write/Write/= WriteImpl/DoOnce/{FlatMap(), Map(decode)} -> [1]wri= te/Write/WriteImpl/InitializeWrite -> (Map -> ToKeyedWorkItem, Map -> ToKey= edWorkItem, Map -> ToKeyedWorkItem) (1/2) (6dbc5fac3b796b4e1c53cd4fe93bb4ea= ). [[2]write/Write/WriteImpl/DoOnce/{FlatMap(), Map(de= code)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> ToKeyedWorkIt= em, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] INFO org.apache.= flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed= for task [2]write/Write/WriteImpl/DoOnce/{FlatMap(= ), Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> ToKe= yedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) (6dbc5fa= c3b796b4e1c53cd4fe93bb4ea) [FINISHED] [ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (= 1/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfor= m_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (1/2) (5aee7b7e09f030a= e86dc8682935d59e4) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (= 1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resourc= es for ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 ->= Map (1/2) (5aee7b7e09f030ae86dc8682935d59e4). [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [2]write/Write/WriteImpl/DoOnce/{FlatMap(= ), Map(decode)} -> [1]write/Write/WriteImpl/Initial= izeWrite -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyed= WorkItem) 6dbc5fac3b796b4e1c53cd4fe93bb4ea. [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1= /2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransform= _write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) (0fbb92d5c07be9095= 14c426a36d8fda1) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (= 1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSys= tem streams are closed for task ref_AppliedPTransform_write/Write/WriteImpl= /WriteBundles_34-side0 -> Map (1/2) (5aee7b7e09f030ae86dc8682935d59e4) [FIN= ISHED] [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfo= rm_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) (0634a4eb67f2d= b6ccf41291f9669a4b9) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resour= ces for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 = -> Map (1/2) (0634a4eb67f2db6ccf41291f9669a4b9). [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2= /2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransform= _write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) (8215fc1c29b90e0a9= d39c6367de87d82) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resource= s for ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> M= ap (2/2) (8215fc1c29b90e0a9d39c6367de87d82). [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resource= s for ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> M= ap (1/2) (0fbb92d5c07be909514c426a36d8fda1). [ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (= 2/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfor= m_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) (acbb6df74e437b4= b45c5aca445a442dc) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (= 2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resourc= es for ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 ->= Map (2/2) (acbb6df74e437b4b45c5aca445a442dc). [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfo= rm_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) (02f9478519c06= a963e88b6ff06a48ede) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resour= ces for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 = -> Map (2/2) (02f9478519c06a963e88b6ff06a48ede). [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSy= stem streams are closed for task ref_AppliedPTransform_write/Write/WriteImp= l/FinalizeWrite_43-side0 -> Map (2/2) (02f9478519c06a963e88b6ff06a48ede) [F= INISHED] [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSy= stem streams are closed for task ref_AppliedPTransform_write/Write/WriteImp= l/FinalizeWrite_43-side0 -> Map (1/2) (0634a4eb67f2db6ccf41291f9669a4b9) [F= INISHED] [ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (= 2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSys= tem streams are closed for task ref_AppliedPTransform_write/Write/WriteImpl= /WriteBundles_34-side0 -> Map (2/2) (acbb6df74e437b4b45c5aca445a442dc) [FIN= ISHED] [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSyst= em streams are closed for task ref_AppliedPTransform_write/Write/WriteImpl/= PreFinalize_42-side0 -> Map (1/2) (0fbb92d5c07be909514c426a36d8fda1) [FINIS= HED] [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSyst= em streams are closed for task ref_AppliedPTransform_write/Write/WriteImpl/= PreFinalize_42-side0 -> Map (2/2) (8215fc1c29b90e0a9d39c6367de87d82) [FINIS= HED] [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/write/ref_PCollection_PCollection_24:0=20 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/WriteBundles_34-side0 -> Map 5aee7b7e09f030ae86dc8682935d59e4. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/FinalizeWrite_43-side0 -> Map 02f9478519c06a963e88b6ff06a48ede. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [2]write/Write/WriteImpl/DoOnce/{FlatMap(), Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrit= e -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkIte= m) (1/2) (6dbc5fac3b796b4e1c53cd4fe93bb4ea) switched from RUNNING to FINISH= ED. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/FinalizeWrite_43-side0 -> Map 0634a4eb67f2db6ccf41291f9669a4b9. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Writ= eBundles_34-side0 -> Map (1/2) (5aee7b7e09f030ae86dc8682935d59e4) switched = from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/WriteBundles_34-side0 -> Map acbb6df74e437b4b45c5aca445a442dc. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/PreFinalize_42-side0 -> Map 0fbb92d5c07be909514c426a36d8fda1. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43-side0 -> Map (2/2) (02f9478519c06a963e88b6ff06a48ede) switched= from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/PreFinalize_42-side0 -> Map 8215fc1c29b90e0a9d39c6367de87d82. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43-side0 -> Map (1/2) (0634a4eb67f2db6ccf41291f9669a4b9) switched= from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Writ= eBundles_34-side0 -> Map (2/2) (acbb6df74e437b4b45c5aca445a442dc) switched = from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/PreF= inalize_42-side0 -> Map (1/2) (0fbb92d5c07be909514c426a36d8fda1) switched f= rom RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/PreF= inalize_42-side0 -> Map (2/2) (8215fc1c29b90e0a9d39c6367de87d82) switched f= rom RUNNING to FINISHED. [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:element= _count:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be43-3= 316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [3]write/Writ= e/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)}, 1] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:pardo_e= xecution_time:start_bundle_msecs:v1'. Metric will not be reported.[localhos= t, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-06301210= 57-86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(Windo= wIntoFn)}, 1] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:pardo_e= xecution_time:finish_bundle_msecs:v1'. Metric will not be reported.[localho= st, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121= 057-86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(Wind= owIntoFn)}, 1] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:ptransf= orm_execution_time:total_msecs:v1'. Metric will not be reported.[localhost,= taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057= -86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowI= ntoFn)}, 1] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:pardo_e= xecution_time:process_bundle_msecs:v1'. Metric will not be reported.[localh= ost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-063012= 1057-86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(Win= dowIntoFn)}, 1] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:sampled= _byte_size:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be= 43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [3]write/= Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)}, 1] [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/read/ref_PCollection_PCollection_17:0=20 [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/write/ref_PCollection_PCollection_28:0=20 [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/read/ref_PCollection_PCollection_27:0=20 [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/write/ref_PCollection_PCollection_28:0=20 [grpc-default-executor-0] WARN bundle_processor.create_operation - No uniqu= e name set for transform fn/read/ref_PCollection_PCollection_27:0=20 [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:element= _count:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be43-3= 316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [3]write/Writ= e/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)}, 0] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:pardo_e= xecution_time:start_bundle_msecs:v1'. Metric will not be reported.[localhos= t, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-06301210= 57-86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(Windo= wIntoFn)}, 0] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:pardo_e= xecution_time:finish_bundle_msecs:v1'. Metric will not be reported.[localho= st, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121= 057-86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(Wind= owIntoFn)}, 0] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:ptransf= orm_execution_time:total_msecs:v1'. Metric will not be reported.[localhost,= taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057= -86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowI= ntoFn)}, 0] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:pardo_e= xecution_time:process_bundle_msecs:v1'. Metric will not be reported.[localh= ost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-063012= 1057-86ac8ea7, [3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(Win= dowIntoFn)}, 0] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name co= llision: Group already contains a Metric with the name 'beam.metric:sampled= _byte_size:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be= 43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [3]write/= Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)}, 0] [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.flink.metric= s.MetricGroup - Name collision: Group already contains a Metric with the na= me 'beam.metric:element_count:v1'. Metric will not be reported.[localhost, = taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-= 86ac8ea7, [1]write/Write/WriteImpl/FinalizeWrite, 0] [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.flink.metric= s.MetricGroup - Name collision: Group already contains a Metric with the na= me 'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric will not = be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, = BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/FinalizeWrite, 0= ] [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.flink.metric= s.MetricGroup - Name collision: Group already contains a Metric with the na= me 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric will no= t be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec= , BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/FinalizeWrite,= 0] [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.flink.metric= s.MetricGroup - Name collision: Group already contains a Metric with the na= me 'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will = not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85= ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/FinalizeWrit= e, 0] [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.flink.metric= s.MetricGroup - Name collision: Group already contains a Metric with the na= me 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric will n= ot be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85e= c, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/FinalizeWrite= , 0] [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.flink.metric= s.MetricGroup - Name collision: Group already contains a Metric with the na= me 'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[localho= st, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630121= 057-86ac8ea7, [1]write/Write/WriteImpl/FinalizeWrite, 0] [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN= org.apache.flink.metrics.MetricGroup - Name collision: Group already conta= ins a Metric with the name 'beam.metric:ptransform_execution_time:total_mse= cs:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be43-3316-= 4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/Wr= iteImpl/PreFinalize, 0] [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN= org.apache.flink.metrics.MetricGroup - Name collision: Group already conta= ins a Metric with the name 'beam.metric:pardo_execution_time:finish_bundle_= msecs:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be43-33= 16-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write= /WriteImpl/PreFinalize, 0] [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN= org.apache.flink.metrics.MetricGroup - Name collision: Group already conta= ins a Metric with the name 'beam.metric:pardo_execution_time:start_bundle_m= secs:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be43-331= 6-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/= WriteImpl/PreFinalize, 0] [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN= org.apache.flink.metrics.MetricGroup - Name collision: Group already conta= ins a Metric with the name 'beam.metric:pardo_execution_time:process_bundle= _msecs:v1'. Metric will not be reported.[localhost, taskmanager, 4a15be43-3= 316-4796-902c-f41d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Writ= e/WriteImpl/PreFinalize, 0] [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN= org.apache.flink.metrics.MetricGroup - Name collision: Group already conta= ins a Metric with the name 'beam.metric:element_count:v1'. Metric will not = be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, = BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/PreFinalize, 0] [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN= org.apache.flink.metrics.MetricGroup - Name collision: Group already conta= ins a Metric with the name 'beam.metric:sampled_byte_size:v1'. Metric will = not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85= ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/PreFinalize,= 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric= will not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d= 04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extrac= t, 1] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric wi= ll not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04e= d85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extract, = 1] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:element_count:v1'. Metric will not be reported.[loca= lhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630= 121057-86ac8ea7, [1]write/Write/WriteImpl/Extract, 1] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metri= c will not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41= d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extra= ct, 1] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric = will not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d0= 4ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extract= , 1] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[= localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-= 0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extract, 1] [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - [3= ]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> To= KeyedWorkItem (2/2) (a0e89735d57046604f5d916e6193d298) switched from RUNNIN= G to FINISHED. [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Fr= eeing task resources for [3]write/Write/WriteImpl/{WriteBundles, Pair, Wind= owInto(WindowIntoFn)} -> ToKeyedWorkItem (2/2) (a0e89735d57046604f5d916e619= 3d298). [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - En= suring all FileSystem streams are closed for task [3]write/Write/WriteImpl/= {WriteBundles, Pair, WindowInto(WindowIntoFn)} -> ToKeyedWorkItem (2/2) (a0= e89735d57046604f5d916e6193d298) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [3]write/Write/WriteImpl/{WriteBundles, P= air, WindowInto(WindowIntoFn)} -> ToKeyedWorkItem a0e89735d57046604f5d916e6= 193d298. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [3]write/Write/WriteImpl/{WriteBundles, Pair, Wi= ndowInto(WindowIntoFn)} -> ToKeyedWorkItem (2/2) (a0e89735d57046604f5d916e6= 193d298) switched from RUNNING to FINISHED. [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - [3= ]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> To= KeyedWorkItem (1/2) (356e5b088c64878b7d547278dbfa5661) switched from RUNNIN= G to FINISHED. [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Fr= eeing task resources for [3]write/Write/WriteImpl/{WriteBundles, Pair, Wind= owInto(WindowIntoFn)} -> ToKeyedWorkItem (1/2) (356e5b088c64878b7d547278dbf= a5661). [[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} ->= ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - En= suring all FileSystem streams are closed for task [3]write/Write/WriteImpl/= {WriteBundles, Pair, WindowInto(WindowIntoFn)} -> ToKeyedWorkItem (1/2) (35= 6e5b088c64878b7d547278dbfa5661) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [3]write/Write/WriteImpl/{WriteBundles, P= air, WindowInto(WindowIntoFn)} -> ToKeyedWorkItem 356e5b088c64878b7d547278d= bfa5661. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [3]write/Write/WriteImpl/{WriteBundles, Pair, Wi= ndowInto(WindowIntoFn)} -> ToKeyedWorkItem (1/2) (356e5b088c64878b7d547278d= bfa5661) switched from RUNNING to FINISHED. [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] INFO org.apache.flink= .runtime.taskmanager.Task - write/Write/WriteImpl/GroupByKey -> [1]write/Wr= ite/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (= 2/2) (b15331139bd865fd4e2ec6b9d65ef382) switched from RUNNING to FINISHED. [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] INFO org.apache.flink= .runtime.taskmanager.Task - Freeing task resources for write/Write/WriteImp= l/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem= , Map -> ToKeyedWorkItem) (2/2) (b15331139bd865fd4e2ec6b9d65ef382). [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] INFO org.apache.flink= .runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for = task write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -= > (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2) (b15331139bd865fd4= e2ec6b9d65ef382) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task write/Write/WriteImpl/GroupByKey -> [1]wr= ite/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkI= tem) b15331139bd865fd4e2ec6b9d65ef382. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - write/Write/WriteImpl/GroupByKey -> [1]write/Wri= te/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2= /2) (b15331139bd865fd4e2ec6b9d65ef382) switched from RUNNING to FINISHED. [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric= will not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d= 04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extrac= t, 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric wi= ll not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04e= d85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extract, = 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:element_count:v1'. Metric will not be reported.[loca= lhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-0630= 121057-86ac8ea7, [1]write/Write/WriteImpl/Extract, 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metri= c will not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41= d04ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extra= ct, 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric = will not be reported.[localhost, taskmanager, 4a15be43-3316-4796-902c-f41d0= 4ed85ec, BeamApp-root-0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extract= , 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN org.apache.flink= .metrics.MetricGroup - Name collision: Group already contains a Metric with= the name 'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[= localhost, taskmanager, 4a15be43-3316-4796-902c-f41d04ed85ec, BeamApp-root-= 0630121057-86ac8ea7, [1]write/Write/WriteImpl/Extract, 0] [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] INFO org.apache.flink= .runtime.taskmanager.Task - write/Write/WriteImpl/GroupByKey -> [1]write/Wr= ite/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (= 1/2) (750630598ac40033a6956947e8dc5f86) switched from RUNNING to FINISHED. [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] INFO org.apache.flink= .runtime.taskmanager.Task - Freeing task resources for write/Write/WriteImp= l/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem= , Map -> ToKeyedWorkItem) (1/2) (750630598ac40033a6956947e8dc5f86). [write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (M= ap -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] INFO org.apache.flink= .runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for = task write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -= > (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) (750630598ac40033a= 6956947e8dc5f86) [FINISHED] [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfo= rm_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) (5c69e19b6bade= 139592ab19a2a02368c) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resour= ces for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 = -> Map (1/2) (5c69e19b6bade139592ab19a2a02368c). [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSy= stem streams are closed for task ref_AppliedPTransform_write/Write/WriteImp= l/FinalizeWrite_43-side1 -> Map (1/2) (5c69e19b6bade139592ab19a2a02368c) [F= INISHED] [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1= /2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransform= _write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) (cff973c9f5aef85e0= 52f73e472be2c4f) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task write/Write/WriteImpl/GroupByKey -> [1]wr= ite/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkI= tem) 750630598ac40033a6956947e8dc5f86. [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2= /2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransform= _write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) (686a34cddb01ab44c= 0dcdfcd876e5628) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resource= s for ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> M= ap (2/2) (686a34cddb01ab44c0dcdfcd876e5628). [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resource= s for ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> M= ap (1/2) (cff973c9f5aef85e052f73e472be2c4f). [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSyst= em streams are closed for task ref_AppliedPTransform_write/Write/WriteImpl/= PreFinalize_42-side1 -> Map (2/2) (686a34cddb01ab44c0dcdfcd876e5628) [FINIS= HED] [ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1= /2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSyst= em streams are closed for task ref_AppliedPTransform_write/Write/WriteImpl/= PreFinalize_42-side1 -> Map (1/2) (cff973c9f5aef85e052f73e472be2c4f) [FINIS= HED] [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfo= rm_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) (233d413cac221= 8caa2b116202c29389d) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resour= ces for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 = -> Map (2/2) (233d413cac2218caa2b116202c29389d). [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSy= stem streams are closed for task ref_AppliedPTransform_write/Write/WriteImp= l/FinalizeWrite_43-side1 -> Map (2/2) (233d413cac2218caa2b116202c29389d) [F= INISHED] [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/FinalizeWrite_43-side1 -> Map 5c69e19b6bade139592ab19a2a02368c. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/PreFinalize_42-side1 -> Map 686a34cddb01ab44c0dcdfcd876e5628. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - write/Write/WriteImpl/GroupByKey -> [1]write/Wri= te/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1= /2) (750630598ac40033a6956947e8dc5f86) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/PreFinalize_42-side1 -> Map cff973c9f5aef85e052f73e472be2c4f. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/FinalizeWrite_43-side1 -> Map 233d413cac2218caa2b116202c29389d. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43-side1 -> Map (1/2) (5c69e19b6bade139592ab19a2a02368c) switched= from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/PreF= inalize_42-side1 -> Map (2/2) (686a34cddb01ab44c0dcdfcd876e5628) switched f= rom RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/PreF= inalize_42-side1 -> Map (1/2) (cff973c9f5aef85e052f73e472be2c4f) switched f= rom RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43-side1 -> Map (2/2) (233d413cac2218caa2b116202c29389d) switched= from RUNNING to FINISHED. [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2)] INFO= org.apache.flink.runtime.taskmanager.Task - [1]write/Write/WriteImpl/PreFi= nalize -> Map -> ToKeyedWorkItem (2/2) (c496f469afb0babba69977d54ef6f1b9) s= witched from RUNNING to FINISHED. [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2)] INFO= org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [1]= write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2) (c496f469= afb0babba69977d54ef6f1b9). [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2)] INFO= org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem stream= s are closed for task [1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeye= dWorkItem (2/2) (c496f469afb0babba69977d54ef6f1b9) [FINISHED] [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [1]write/Write/WriteImpl/PreFinalize -> M= ap -> ToKeyedWorkItem c496f469afb0babba69977d54ef6f1b9. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [1]write/Write/WriteImpl/PreFinalize -> Map -> T= oKeyedWorkItem (2/2) (c496f469afb0babba69977d54ef6f1b9) switched from RUNNI= NG to FINISHED. [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] INFO= org.apache.flink.runtime.taskmanager.Task - [1]write/Write/WriteImpl/PreFi= nalize -> Map -> ToKeyedWorkItem (1/2) (a8ae47d96e4d85662e9dae7872beb74f) s= witched from RUNNING to FINISHED. [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] INFO= org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [1]= write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2) (a8ae47d9= 6e4d85662e9dae7872beb74f). [[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] INFO= org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem stream= s are closed for task [1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeye= dWorkItem (1/2) (a8ae47d96e4d85662e9dae7872beb74f) [FINISHED] [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [1]write/Write/WriteImpl/PreFinalize -> M= ap -> ToKeyedWorkItem a8ae47d96e4d85662e9dae7872beb74f. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfo= rm_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) (02c8726368b2a= ed6e7e82dffcfe05c62) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - ref_AppliedPTransfo= rm_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) (1f9692408eb3c= 429185ed127ca1c8b96) switched from RUNNING to FINISHED. [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resour= ces for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 = -> Map (2/2) (02c8726368b2aed6e7e82dffcfe05c62). [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resour= ces for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 = -> Map (1/2) (1f9692408eb3c429185ed127ca1c8b96). [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map = (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSy= stem streams are closed for task ref_AppliedPTransform_write/Write/WriteImp= l/FinalizeWrite_43-side2 -> Map (2/2) (02c8726368b2aed6e7e82dffcfe05c62) [F= INISHED] [ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map = (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSy= stem streams are closed for task ref_AppliedPTransform_write/Write/WriteImp= l/FinalizeWrite_43-side2 -> Map (1/2) (1f9692408eb3c429185ed127ca1c8b96) [F= INISHED] [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/FinalizeWrite_43-side2 -> Map 1f9692408eb3c429185ed127ca1c8b96. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task ref_AppliedPTransform_write/Write/WriteIm= pl/FinalizeWrite_43-side2 -> Map 02c8726368b2aed6e7e82dffcfe05c62. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [1]write/Write/WriteImpl/PreFinalize -> Map -> T= oKeyedWorkItem (1/2) (a8ae47d96e4d85662e9dae7872beb74f) switched from RUNNI= NG to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43-side2 -> Map (1/2) (1f9692408eb3c429185ed127ca1c8b96) switched= from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - ref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43-side2 -> Map (2/2) (02c8726368b2aed6e7e82dffcfe05c62) switched= from RUNNING to FINISHED. [grpc-default-executor-0] INFO filebasedsink.finalize_write - Starting fina= lize_write threads with num_shards: 2 (skipped: 0), batches: 2, num_threads= : 2 [[1]write/Write/WriteImpl/FinalizeWrite (2/2)] INFO org.apache.flink.runtim= e.taskmanager.Task - [1]write/Write/WriteImpl/FinalizeWrite (2/2) (cadf23f4= 3d1cb986e617284602b03f38) switched from RUNNING to FINISHED. [[1]write/Write/WriteImpl/FinalizeWrite (2/2)] INFO org.apache.flink.runtim= e.taskmanager.Task - Freeing task resources for [1]write/Write/WriteImpl/Fi= nalizeWrite (2/2) (cadf23f43d1cb986e617284602b03f38). [[1]write/Write/WriteImpl/FinalizeWrite (2/2)] INFO org.apache.flink.runtim= e.taskmanager.Task - Ensuring all FileSystem streams are closed for task [1= ]write/Write/WriteImpl/FinalizeWrite (2/2) (cadf23f43d1cb986e617284602b03f3= 8) [FINISHED] [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [1]write/Write/WriteImpl/FinalizeWrite ca= df23f43d1cb986e617284602b03f38. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [1]write/Write/WriteImpl/FinalizeWrite (2/2) (ca= df23f43d1cb986e617284602b03f38) switched from RUNNING to FINISHED. [grpc-default-executor-0] INFO filebasedsink.finalize_write - Renamed 2 sha= rds in 0.20 seconds. [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] INFO org.apache.beam.runners= .fnexecution.control.DefaultJobBundleFactory - Closing environment urn: "be= am:env:docker:v1" payload: "\n4jenkins-docker-apache.bintray.io/beam/python3:latest" [grpc-default-executor-0] INFO sdk_worker.run - No more requests from contr= ol plane [grpc-default-executor-0] INFO sdk_worker.run - SDK Harness waiting for in-= flight requests to complete [grpc-default-executor-0] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMu= ltiplexer - Hanged up for unknown endpoint. [grpc-default-executor-1] INFO data_plane.close - Closing all cached grpc d= ata channels. [grpc-default-executor-1] INFO sdk_worker.close - Closing all cached gRPC s= tate handlers. [grpc-default-executor-1] INFO sdk_worker.run - Done consuming work. [grpc-default-executor-1] INFO sdk_worker_main.main - Python sdk harness ex= iting. [grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.logging.= GrpcLoggingService - Logging client hanged up. [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN org.apache.beam.sdk.fn.= data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint. [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] INFO org.apache.flink.runtim= e.taskmanager.Task - [1]write/Write/WriteImpl/FinalizeWrite (1/2) (5aa6b7b3= 760f002ad529a8bb20fe1751) switched from RUNNING to FINISHED. [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] INFO org.apache.flink.runtim= e.taskmanager.Task - Freeing task resources for [1]write/Write/WriteImpl/Fi= nalizeWrite (1/2) (5aa6b7b3760f002ad529a8bb20fe1751). [[1]write/Write/WriteImpl/FinalizeWrite (1/2)] INFO org.apache.flink.runtim= e.taskmanager.Task - Ensuring all FileSystem streams are closed for task [1= ]write/Write/WriteImpl/FinalizeWrite (1/2) (5aa6b7b3760f002ad529a8bb20fe175= 1) [FINISHED] [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Un-registering task and sending final execution stat= e FINISHED to JobManager for task [1]write/Write/WriteImpl/FinalizeWrite 5a= a6b7b3760f002ad529a8bb20fe1751. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - [1]write/Write/WriteImpl/FinalizeWrite (1/2) (5a= a6b7b3760f002ad529a8bb20fe1751) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.execu= tiongraph.ExecutionGraph - Job BeamApp-root-0630121057-86ac8ea7 (f520fc055d= 4704e7a0d732dfd3c8d8fd) switched from state RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.check= point.CheckpointCoordinator - Stopping checkpoint coordinator for job f520f= c055d4704e7a0d732dfd3c8d8fd. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.check= point.StandaloneCompletedCheckpointStore - Shutting down [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispa= tcher.StandaloneDispatcher - Job f520fc055d4704e7a0d732dfd3c8d8fd reached g= lobally terminal state FINISHED. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobma= ster.JobMaster - Stopping the JobMaster for job BeamApp-root-0630121057-86a= c8ea7(f520fc055d4704e7a0d732dfd3c8d8fd). [flink-runner-job-invoker] INFO org.apache.flink.runtime.minicluster.MiniCl= uster - Shutting down Flink Mini Cluster [flink-runner-job-invoker] INFO org.apache.flink.runtime.dispatcher.Dispatc= herRestEndpoint - Shutting down rest endpoint. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_= 0. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobma= ster.JobMaster - Close ResourceManager connection c08538addf513d775bf38da1a= b3bbe3e: JobManager is shutting down.. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobma= ster.slotpool.SlotPool - Suspending SlotPool. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state= .TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalState= StoresManager. [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobma= ster.slotpool.SlotPool - Stopping SlotPool. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispa= tcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatch= erebeea1fb-96b2-482a-865e-8b601f6a7723. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispa= tcher.StandaloneDispatcher - Stopping all currently running jobs of dispatc= her akka://flink/user/dispatcherebeea1fb-96b2-482a-865e-8b601f6a7723. [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resou= rcemanager.StandaloneResourceManager - Disconnect job manager b7aaf5ce4ecab= b6b964bda9a4cbd4804@akka://flink/user/jobmanager_1 for job f520fc055d4704e7= a0d732dfd3c8d8fd from the resource manager. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - JobManager for job f520fc055d4704e7a0d732dfd3c8d8fd = with leader id b7aaf5ce4ecabb6b964bda9a4cbd4804 lost leadership. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.di= sk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flin= k-io-fc52d116-8d13-43e7-b4dd-a99876cccdf2 [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.ne= twork.NetworkEnvironment - Shutting down the network environment and its co= mponents. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.= handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down sta= ck trace sample coordinator. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispa= tcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatche= rebeea1fb-96b2-482a-865e-8b601f6a7723. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taske= xecutor.JobLeaderService - Stop job leader service. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taske= xecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_0= . [ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher= .DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui [flink-runner-job-invoker] INFO org.apache.flink.runtime.dispatcher.Dispatc= herRestEndpoint - Shut down complete. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resou= rcemanager.slotmanager.SlotManager - Closing the SlotManager. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resou= rcemanager.slotmanager.SlotManager - Suspending the SlotManager. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.a= kka.AkkaRpcService - Stopping Akka RPC service. [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.= PermanentBlobCache - Shutting down BLOB cache [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.= TransientBlobCache - Shutting down BLOB cache [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.= BlobServer - Stopped BLOB server at 0.0.0.0:44261 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.a= kka.AkkaRpcService - Stopped Akka RPC service. [flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner -= Execution finished in 6563 msecs [flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner -= Final accumulator values: [flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner -= __metricscontainers : MetricQueryResults(Counters(17read/Read/Impulse.None= /beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:= v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_2:0}: 0, 40write/Writ= e/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:ptrans= form_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PC= ollection_20:0}: 0, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:do= cker:v1:0:beam:metric:user {NAMESPACE=3D__main__.WordExtractingDoFn, PTRANS= FORM=3Dref_AppliedPTransform_split_17, NAME=3Dempty_lines}: 3, 40write/Writ= e/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_= execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection= _PCollection_20:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam= :env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PT= RANSFORM=3Dfn/read/ref_PCollection_PCollection_20:0}: 0, 40write/Write/Writ= eImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execut= ion_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Wr= ite/WriteImpl/PreFinalize_42}: 600, 40write/Write/WriteImpl/DoOnce/Map(deco= de).None/beam:env:docker:v1:2:beam:metric:element_count:v1 {PCOLLECTION=3Dr= ef_PCollection_PCollection_20}: 1, 6format.None/beam:env:docker:v1:0:beam:m= etric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3Dref_AppliedPTr= ansform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}: 17, 40write/Wri= te/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo= _execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_= write/Write/WriteImpl/PreFinalize_42}: 0, 19group/GroupByWindow.None/beam:e= nv:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANS= FORM=3Dref_AppliedPTransform_format_24}: 0, 6format.None/beam:env:docker:v1= :0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dre= f_AppliedPTransform_write/Write/WriteImpl/Pair_35}: 0, 40write/Write/WriteI= mpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:element_count:= v1 {PCOLLECTION=3Dref_PCollection_PCollection_20}: 1, 40write/Write/WriteIm= pl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:element_count:v= 1 {PCOLLECTION=3Dref_PCollection_PCollection_21}: 1, 40write/Write/WriteImp= l/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:ptransform_execu= tion_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollection_= 20:0}: 0, 6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_tim= e:process_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/W= riteImpl/Pair_35}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:= docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFOR= M=3Dfn/write/ref_PCollection_PCollection_20:0}: 0, 17read/Read/Impulse.None= /beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs= :v1 {PTRANSFORM=3Dref_AppliedPTransform_read/Read/Split_5}: 12, 36write/Wri= te/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_exe= cution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write= /Write/WriteImpl/DoOnce/Map(decode)_32}: 42, 40write/Write/WriteImpl/DoOnce= /Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:pro= cess_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteI= mpl/InitializeWrite_33}: 29, 40write/Write/WriteImpl/DoOnce/Map(decode).Non= e/beam:env:docker:v1:2:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCol= lection_PCollection_30}: 2, 17read/Read/Impulse.None/beam:env:docker:v1:0:b= eam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dfn/writ= e/ref_PCollection_PCollection_2:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(d= ecode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:start_bun= dle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/Fina= lizeWrite_43}: 703, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:do= cker:v1:0:beam:metric:user {NAMESPACE=3D__main__.WordExtractingDoFn, PTRANS= FORM=3Dref_AppliedPTransform_split_17, NAME=3Dword_lengths}: 418, 36write/W= rite/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element= _count:v1 {PCOLLECTION=3Dref_PCollection_PCollection_19}: 1, 36write/Write/= WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element_coun= t:v1 {PCOLLECTION=3Dref_PCollection_PCollection_18}: 1, 40write/Write/Write= Impl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_executi= on_time:start_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PColle= ction_29:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:do= cker:v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCollection_PColl= ection_29}: 0, 6format.None/beam:env:docker:v1:0:beam:metric:pardo_executio= n_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Writ= e/WriteImpl/Pair_35}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/be= am:env:docker:v1:2:beam:metric:pardo_execution_time:process_bundle_msecs:v1= {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43= }: 186, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:= 0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/= write/ref_PCollection_PCollection_29:0}: 0, 46write/Write/WriteImpl/GroupBy= Key/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_tim= e:start_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollection_2= 7:0}: 0, 46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:doc= ker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFOR= M=3Dfn/read/ref_PCollection_PCollection_27:0}: 0, 6format.None/beam:env:doc= ker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM= =3Dfn/write/ref_PCollection_PCollection_24:0}: 0, 6format.None/beam:env:doc= ker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM= =3Dfn/read/ref_PCollection_PCollection_17:0}: 0, 17read/Read/Impulse.None/b= eam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {P= TRANSFORM=3Dref_AppliedPTransform_read/Read/Split_5}: 30, 46write/Write/Wri= teImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:eleme= nt_count:v1 {PCOLLECTION=3Dref_PCollection_PCollection_28}: 2, 36read/Read/= Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_exec= ution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_read/= Read/ReadSplits_16}: 0, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:en= v:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTR= ANSFORM=3Dref_AppliedPTransform_read/Read/ReadSplits_16}: 22, 46write/Write= /WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:e= lement_count:v1 {PCOLLECTION=3Dref_PCollection_PCollection_27}: 1, 40write/= Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pa= rdo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransfor= m_write/Write/WriteImpl/InitializeWrite_33}: 54, 6format.None/beam:env:dock= er:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM= =3Dfn/write/ref_PCollection_PCollection_24:0}: 0, 6format.None/beam:env:doc= ker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFO= RM=3Dfn/write/ref_PCollection_PCollection_24:0}: 0, 36read/Read/Reshuffle/R= emoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:= start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_read/Read/ReadSpl= its_16}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker= :v1:1:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3D= fn/read/ref_PCollection_PCollection_20:0}: 0, 46write/Write/WriteImpl/Group= ByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_t= ime:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollecti= on_27:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docke= r:v1:1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM= =3Dfn/read/ref_PCollection_PCollection_20:0}: 0, 6format.None/beam:env:dock= er:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFOR= M=3Dref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36= }: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:= beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dref_A= ppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43}: 0, 40write/Write/= WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:ptransfo= rm_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCol= lection_20:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:= docker:v1:2:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANS= FORM=3Dfn/read/ref_PCollection_PCollection_20:0}: 0, 40write/Write/WriteImp= l/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_= time:start_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollectio= n_20:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker= :v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCollection_PCollecti= on_20}: 1, 19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pard= o_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollec= tion_PCollection_17:0}: 0, 6format.None/beam:env:docker:v1:0:beam:metric:pa= rdo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollec= tion_PCollection_17:0}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam= :env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {P= TRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/DoOnce/Map(decode)_= 32}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:= 1:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dfn/w= rite/ref_PCollection_PCollection_21:0}: 0, 6format.None/beam:env:docker:v1:= 0:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_= AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}: 17, 3= 6read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric= :pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCo= llection_PCollection_12:0}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/= beam:env:docker:v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PColle= ction_PCollection_20}: 1, 6format.None/beam:env:docker:v1:0:beam:metric:par= do_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransfor= m_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}: 0, 46write/Write/Writ= eImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptrans= form_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PC= ollection_27:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:en= v:docker:v1:1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRA= NSFORM=3Dfn/write/ref_PCollection_PCollection_21:0}: 0, 17read/Read/Impulse= .None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msec= s:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_2:0}: 0, 36read/Rea= d/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_ex= ecution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_= PCollection_9:0}: 0, 46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/= beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {= PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_28:0}: 0, 36read/Read/Res= huffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_executi= on_time:start_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollec= tion_9:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:dock= er:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFOR= M=3Dref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42}: 15, 6forma= t.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_mse= cs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/WriteBundle= s_34}: 22, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0= :beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/r= ead/ref_PCollection_PCollection_9:0}: 0, 17read/Read/Impulse.None/beam:env:= docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANS= FORM=3Dfn/read/ref_PCollection_PCollection_1:0}: 0, 36read/Read/Reshuffle/R= emoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:= start_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_12= :0}: 0, 17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_exe= cution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_P= Collection_1:0}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:do= cker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSF= ORM=3Dref_AppliedPTransform_write/Write/WriteImpl/DoOnce/Map(decode)_32}: 0= , 46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:= 0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn= /write/ref_PCollection_PCollection_28:0}: 0, 17read/Read/Impulse.None/beam:= env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTR= ANSFORM=3Dfn/read/ref_PCollection_PCollection_1:0}: 0, 40write/Write/WriteI= mpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_executio= n_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Wri= te/WriteImpl/InitializeWrite_33}: 0, 6format.None/beam:env:docker:v1:0:beam= :metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/= ref_PCollection_PCollection_17:0}: 0, 6format.None/beam:env:docker:v1:0:bea= m:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_Appli= edPTransform_write/Write/WriteImpl/WriteBundles_34}: 0, 36read/Read/Reshuff= le/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:element_count:v1 = {PCOLLECTION=3Dref_PCollection_PCollection_10}: 34, 46write/Write/WriteImpl= /GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execu= tion_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCo= llection_28:0}: 0, 19group/GroupByWindow.None/beam:env:docker:v1:0:beam:met= ric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCol= lection_PCollection_15:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).No= ne/beam:env:docker:v1:2:beam:metric:ptransform_execution_time:total_msecs:v= 1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_4= 3}: 889, 6format.None/beam:env:docker:v1:0:beam:metric:element_count:v1 {PC= OLLECTION=3Dref_PCollection_PCollection_24}: 2, 36read/Read/Reshuffle/Remov= eRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:fini= sh_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_split_17}: 0, 36read= /Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:elem= ent_count:v1 {PCOLLECTION=3Dref_PCollection_PCollection_11}: 131, 19group/G= roupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_tim= e:total_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_count_23}: 0, 6format.= None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_ms= ecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/WriteBundl= es_34}: 4, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0= :beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCollection_PCollection_12= }: 131, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:be= am:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dref_Ap= pliedPTransform_split_17}: 0, 17read/Read/Impulse.None/beam:env:docker:v1:0= :beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_A= ppliedPTransform_read/Read/Split_5}: 18, 46write/Write/WriteImpl/GroupByKey= /GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:s= tart_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_28:= 0}: 0, 17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_exec= ution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_read/= Read/Split_5}: 0, 19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metr= ic:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPT= ransform_count_23}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env= :docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRAN= SFORM=3Dfn/read/ref_PCollection_PCollection_18:0}: 0, 36read/Read/Reshuffle= /RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_tim= e:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_split_17}: 0, 6= format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_b= undle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/Wr= iteBundles_34}: 18, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:do= cker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1 {PTRANSFOR= M=3Dfn/read/ref_PCollection_PCollection_18:0}: 0, 6format.None/beam:env:doc= ker:v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCollection_PColle= ction_17}: 50, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:= v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3Dref= _AppliedPTransform_read/Read/ReadSplits_16}: 22, 19group/GroupByWindow.None= /beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v= 1 {PTRANSFORM=3Dref_AppliedPTransform_count_23}: 0, 36read/Read/Reshuffle/R= emoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:= process_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_= 12:0}: 0, 19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo= _execution_time:finish_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollecti= on_PCollection_17:0}: 0, 6format.None/beam:env:docker:v1:0:beam:metric:ptra= nsform_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection= _PCollection_24:0}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env= :docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFO= RM=3Dref_AppliedPTransform_write/Write/WriteImpl/DoOnce/FlatMap()_30}: 0, 19group/GroupByWindow.None/beam:env:docker:v1:0:beam= :metric:element_count:v1 {PCOLLECTION=3Dref_PCollection_PCollection_16}: 50= , 19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count= :v1 {PCOLLECTION=3Dref_PCollection_PCollection_15}: 50, 19group/GroupByWind= ow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle= _msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_count_23}: 0, 19group/GroupBy= Window.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bun= dle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_format_24}: 0, 19group/Gro= upByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 {PCOLLECT= ION=3Dref_PCollection_PCollection_17}: 50, 36read/Read/Reshuffle/RemoveRand= omKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:tota= l_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_split_17}: 0, 19group/GroupB= yWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bu= ndle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_17:0}: 0, = 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metri= c:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTr= ansform_write/Write/WriteImpl/DoOnce/FlatMap()_30}:= 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:be= am:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/rea= d/ref_PCollection_PCollection_20:0}: 0, 36read/Read/Reshuffle/RemoveRandomK= eys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_m= secs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_12:0}: 0, 36writ= e/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pard= o_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollect= ion_PCollection_18:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/b= eam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v= 1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_29:0}: 0, 40write/Writ= e/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_= execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollectio= n_PCollection_20:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/bea= m:env:docker:v1:1:beam:metric:ptransform_execution_time:total_msecs:v1 {PTR= ANSFORM=3Dfn/write/ref_PCollection_PCollection_21:0}: 0, 36read/Read/Reshuf= fle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execu= tion_time:total_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_pair_with_one_= 18}: 19, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:b= eam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/r= ef_PCollection_PCollection_18:0}: 0, 46write/Write/WriteImpl/GroupByKey/Gro= upByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finis= h_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl= /Extract_41}: 0, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docke= r:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM= =3Dref_AppliedPTransform_pair_with_one_18}: 8, 40write/Write/WriteImpl/DoOn= ce/Map(decode).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_t= ime:total_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImp= l/PreFinalize_42}: 615, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:en= v:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTR= ANSFORM=3Dfn/write/ref_PCollection_PCollection_20:0}: 0, 36read/Read/Reshuf= fle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_= time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_pair_with_on= e_18}: 11, 17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:ptrans= form_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PC= ollection_1:0}: 0, 36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:doc= ker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANSFOR= M=3Dfn/write/ref_PCollection_PCollection_20:0}: 0, 36write/Write/WriteImpl/= DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:f= inish_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/Write= Impl/DoOnce/FlatMap()_30}: 0, 36write/Write/WriteIm= pl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_executio= n_time:total_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/Write= Impl/DoOnce/Map(decode)_32}: 42, 36write/Write/WriteImpl/DoOnce/Impulse.Non= e/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:= v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollection_20:0}: 0, 36write/Wri= te/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_exe= cution_time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write= /Write/WriteImpl/DoOnce/FlatMap()_30}: 0, 46write/W= rite/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metr= ic:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPT= ransform_write/Write/WriteImpl/Extract_41}: 0, 46write/Write/WriteImpl/Grou= pByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_= time:start_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_write/Write/= WriteImpl/Extract_41}: 104, 36read/Read/Reshuffle/RemoveRandomKeys.None/bea= m:env:docker:v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCollecti= on_PCollection_9}: 1, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:= docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRANS= FORM=3Dref_AppliedPTransform_pair_with_one_18}: 0, 19group/GroupByWindow.No= ne/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msec= s:v1 {PTRANSFORM=3Dref_AppliedPTransform_format_24}: 0, 40write/Write/Write= Impl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:ptransform_ex= ecution_time:total_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollect= ion_29:0}: 0, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v= 1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3Dfn/r= ead/ref_PCollection_PCollection_9:0}: 0, 19group/GroupByWindow.None/beam:en= v:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1 {PTRA= NSFORM=3Dfn/read/ref_PCollection_PCollection_15:0}: 0, 19group/GroupByWindo= w.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_m= secs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollection_15:0}: 0, 19group= /GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:p= rocess_bundle_msecs:v1 {PTRANSFORM=3Dref_AppliedPTransform_format_24}: 0, 1= 7read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_ti= me:process_bundle_msecs:v1 {PTRANSFORM=3Dfn/write/ref_PCollection_PCollecti= on_2:0}: 0, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker= :v1:1:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM= =3Dfn/write/ref_PCollection_PCollection_21:0}: 0, 6format.None/beam:env:doc= ker:v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCollection_PColle= ction_23}: 2, 6format.None/beam:env:docker:v1:0:beam:metric:element_count:v= 1 {PCOLLECTION=3Dref_PCollection_PCollection_22}: 2, 17read/Read/Impulse.No= ne/beam:env:docker:v1:0:beam:metric:element_count:v1 {PCOLLECTION=3Dref_PCo= llection_PCollection_2}: 1, 40write/Write/WriteImpl/DoOnce/Map(decode).None= /beam:env:docker:v1:1:beam:metric:ptransform_execution_time:total_msecs:v1 = {PTRANSFORM=3Dref_AppliedPTransform_write/Write/WriteImpl/InitializeWrite_3= 3}: 83, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:= 0:beam:metric:pardo_execution_time:process_bundle_msecs:v1 {PTRANSFORM=3Dfn= /read/ref_PCollection_PCollection_20:0}: 0, 36read/Read/Reshuffle/RemoveRan= domKeys.None/beam:env:docker:v1:0:beam:metric:user {NAMESPACE=3D__main__.Wo= rdExtractingDoFn, PTRANSFORM=3Dref_AppliedPTransform_split_17, NAME=3Dwords= }: 131, 46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:dock= er:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3D= ref_AppliedPTransform_write/Write/WriteImpl/Extract_41}: 104, 17read/Read/I= mpulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1 {PCOLLECTION= =3Dref_PCollection_PCollection_1}: 1, 19group/GroupByWindow.None/beam:env:d= ocker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM= =3Dfn/write/ref_PCollection_PCollection_17:0}: 0, 6format.None/beam:env:doc= ker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM= =3Dfn/read/ref_PCollection_PCollection_17:0}: 0, 6format.None/beam:env:dock= er:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1 {PTRANSFORM=3D= ref_AppliedPTransform_write/Write/WriteImpl/Pair_35}: 0, 19group/GroupByWin= dow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bund= le_msecs:v1 {PTRANSFORM=3Dfn/read/ref_PCollection_PCollection_15:0}: 0)Dist= ributions(46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:do= cker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_P= Collection_27}: DistributionResult{sum=3D271, count=3D1, min=3D271, max=3D2= 71}, 46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:= v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PColle= ction_28}: DistributionResult{sum=3D276, count=3D2, min=3D138, max=3D138}, = 6format.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLEC= TION=3Dref_PCollection_PCollection_24}: DistributionResult{sum=3D278, count= =3D2, min=3D139, max=3D139}, 6format.None/beam:env:docker:v1:0:beam:metric:= sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_22}: Distri= butionResult{sum=3D276, count=3D2, min=3D138, max=3D138}, 6format.None/beam= :env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PColle= ction_PCollection_23}: DistributionResult{sum=3D278, count=3D2, min=3D139, = max=3D139}, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker= :v1:2:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PColl= ection_30}: DistributionResult{sum=3D106, count=3D2, min=3D53, max=3D53}, 3= 6write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric= :sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_20}: Distr= ibutionResult{sum=3D14, count=3D1, min=3D14, max=3D14}, 36read/Read/Reshuff= le/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:user_distribution= {NAMESPACE=3D__main__.WordExtractingDoFn, PTRANSFORM=3Dref_AppliedPTransfo= rm_split_17, NAME=3Dword_len_dist}: DistributionResult{sum=3D418, count=3D1= 31, min=3D0, max=3D10}, 19group/GroupByWindow.None/beam:env:docker:v1:0:bea= m:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_17= }: DistributionResult{sum=3D751, count=3D36, min=3D18, max=3D27}, 40write/W= rite/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:sam= pled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_20}: Distribut= ionResult{sum=3D15, count=3D1, min=3D15, max=3D15}, 19group/GroupByWindow.N= one/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dre= f_PCollection_PCollection_16}: DistributionResult{sum=3D628, count=3D33, mi= n=3D17, max=3D23}, 19group/GroupByWindow.None/beam:env:docker:v1:0:beam:met= ric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_15}: Di= stributionResult{sum=3D936, count=3D39, min=3D20, max=3D29}, 36write/Write/= WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte= _size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_18}: DistributionResult= {sum=3D13, count=3D1, min=3D13, max=3D13}, 36write/Write/WriteImpl/DoOnce/I= mpulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECT= ION=3Dref_PCollection_PCollection_19}: DistributionResult{sum=3D15, count= =3D1, min=3D15, max=3D15}, 17read/Read/Impulse.None/beam:env:docker:v1:0:be= am:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_2= }: DistributionResult{sum=3D684, count=3D1, min=3D684, max=3D684}, 17read/R= ead/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCO= LLECTION=3Dref_PCollection_PCollection_1}: DistributionResult{sum=3D13, cou= nt=3D1, min=3D13, max=3D13}, 6format.None/beam:env:docker:v1:0:beam:metric:= sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_17}: Distri= butionResult{sum=3D886, count=3D41, min=3D19, max=3D28}, 40write/Write/Writ= eImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:sampled_byte= _size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_21}: DistributionResult= {sum=3D81, count=3D1, min=3D81, max=3D81}, 40write/Write/WriteImpl/DoOnce/M= ap(decode).None/beam:env:docker:v1:1:beam:metric:sampled_byte_size:v1 {PCOL= LECTION=3Dref_PCollection_PCollection_20}: DistributionResult{sum=3D15, cou= nt=3D1, min=3D15, max=3D15}, 36read/Read/Reshuffle/RemoveRandomKeys.None/be= am:env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCol= lection_PCollection_10}: DistributionResult{sum=3D900, count=3D23, min=3D14= , max=3D84}, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docke= r:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCol= lection_29}: DistributionResult{sum=3D0, count=3D0, min=3D92233720368547758= 07, max=3D-9223372036854775808}, 36read/Read/Reshuffle/RemoveRandomKeys.Non= e/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_= PCollection_PCollection_11}: DistributionResult{sum=3D706, count=3D42, min= =3D14, max=3D23}, 40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:= docker:v1:2:beam:metric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection= _PCollection_20}: DistributionResult{sum=3D15, count=3D1, min=3D15, max=3D1= 5}, 36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:m= etric:sampled_byte_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_12}: = DistributionResult{sum=3D719, count=3D38, min=3D16, max=3D25}, 36read/Read/= Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:sampled_by= te_size:v1 {PCOLLECTION=3Dref_PCollection_PCollection_9}: DistributionResul= t{sum=3D686, count=3D1, min=3D686, max=3D686})) [flink-runner-job-invoker] INFO org.apache.beam.runners.fnexecution.artifac= t.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-s= taging/job_78abca1c-aee2-420e-bd97-fd78504d3454/MANIFEST has 1 artifact loc= ations [flink-runner-job-invoker] INFO org.apache.beam.runners.fnexecution.artifac= t.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-sta= ging/job_78abca1c-aee2-420e-bd97-fd78504d3454/ INFO:root:Job state changed to DONE FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':sdks:python:portableWordCountBatch'. > Process 'command 'sh'' finished with non-zero exit value 1 * Try: Run with --stacktrace option to get the stack trace. Run with --info or --d= ebug option to get more log output. Run with --scan to get full insights. =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D 2: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':sdks:python:test-suites:portable:py35:portableW= ordCountBatch'. > Process 'command 'sh'' finished with non-zero exit value 1 * Try: Run with --stacktrace option to get the stack trace. Run with --info or --d= ebug option to get more log output. Run with --scan to get full insights. =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible = with Gradle 6.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec= :command_line_warnings BUILD FAILED in 7m 19s 79 actionable tasks: 61 executed, 15 from cache, 3 up-to-date Publishing build scan... https://gradle.com/s/nk7zb2jb6qj2q Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org For additional commands, e-mail: builds-help@beam.apache.org