See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1004/display/redirect>
Changes: ------------------------------------------ [...truncated 33.45 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (4/16)#0 (cf55ea2bca889d645cb1168e0d7159d6), deploy into slot with allocation id de35331f464d11cb7ce4328119fcdd6e. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (12/16) (attempt #0) with attempt id a8d6c6d4bc441f11633ea0aea02449b0 and vertex id 0d19d4b3dcddff300e2ff1a4dbbcc442_11 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 1fb8a61a2cd31abe4c4b6a1103719b82 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (4/16)#0 (cf55ea2bca889d645cb1168e0d7159d6) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot 4b6729db2970e5d017d0c95236b33ec7. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (13/16) (1e569de6b8d9df354d3604f7687b3e93) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (4/16)#0 (cf55ea2bca889d645cb1168e0d7159d6) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (13/16) (attempt #0) with attempt id 1e569de6b8d9df354d3604f7687b3e93 and vertex id 0d19d4b3dcddff300e2ff1a4dbbcc442_12 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 3b0780ff2b6157dc4214b80fba838285 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (14/16) (f5336169c3c6157837b4dec4c01614f6) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (4/16)#0 (cf55ea2bca889d645cb1168e0d7159d6) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (14/16) (attempt #0) with attempt id f5336169c3c6157837b4dec4c01614f6 and vertex id 0d19d4b3dcddff300e2ff1a4dbbcc442_13 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id f5946e052106a4302d52b9597464de25 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (4/16)#0 (cf55ea2bca889d645cb1168e0d7159d6) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (15/16) (1e0e7421c34fbaf16091e5ab37975260) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (15/16) (attempt #0) with attempt id 1e0e7421c34fbaf16091e5ab37975260 and vertex id 0d19d4b3dcddff300e2ff1a4dbbcc442_14 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 84d081060832bf6bac3f03b338de3049 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (16/16) (8fca496558ce6f9fc4113ee3c133235a) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (16/16) (attempt #0) with attempt id 8fca496558ce6f9fc4113ee3c133235a and vertex id 0d19d4b3dcddff300e2ff1a4dbbcc442_15 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 343f7fbd49230a04b48c1e9b128a85b7 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (5/16)#0 (8a4b64833ef69ae8b6ee621b7fbb7817), deploy into slot with allocation id 4b6729db2970e5d017d0c95236b33ec7. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (1/16) (774bf5dc8ad535e55c7085b80308c5fa) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (1/16) (attempt #0) with attempt id 774bf5dc8ad535e55c7085b80308c5fa and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_0 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 5d8c279e8476e00e1893e8d9388bf873 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (5/16)#0 (8a4b64833ef69ae8b6ee621b7fbb7817) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot e3dcab42cbcb6c8f2c3708edfec6a307. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (5/16)#0 (8a4b64833ef69ae8b6ee621b7fbb7817) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (2/16) (35be888c1188f1343e8076251b0f89bd) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (2/16) (attempt #0) with attempt id 35be888c1188f1343e8076251b0f89bd and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_1 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id a2747af8bb148808c98d25f160d89e4a INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (5/16)#0 (8a4b64833ef69ae8b6ee621b7fbb7817) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (6/16)#0 (cb23f0089a12b110473baa376318564b), deploy into slot with allocation id e3dcab42cbcb6c8f2c3708edfec6a307. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (3/16) (69c4700ff4539c09165c1dbb1933789a) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (5/16)#0 (8a4b64833ef69ae8b6ee621b7fbb7817) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (3/16) (attempt #0) with attempt id 69c4700ff4539c09165c1dbb1933789a and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_2 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 22e04d75c4c195d2ee4b903f0cc75a7e INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot c2cc3fb662c27e339846909707ae07bc. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (6/16)#0 (cb23f0089a12b110473baa376318564b) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (4/16) (e403702835c0691acde7b6c7196afd53) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (6/16)#0 (cb23f0089a12b110473baa376318564b) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (4/16) (attempt #0) with attempt id e403702835c0691acde7b6c7196afd53 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_3 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id de35331f464d11cb7ce4328119fcdd6e INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (6/16)#0 (cb23f0089a12b110473baa376318564b) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (7/16)#0 (3d749091db79ffe9bae741339e4610e2), deploy into slot with allocation id c2cc3fb662c27e339846909707ae07bc. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (6/16)#0 (cb23f0089a12b110473baa376318564b) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (5/16) (633beb75ce5c43cb14bf91b2aa501b0d) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (5/16) (attempt #0) with attempt id 633beb75ce5c43cb14bf91b2aa501b0d and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_4 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 4b6729db2970e5d017d0c95236b33ec7 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot a2f7799a47c675931239ca3761a6bfcb. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (7/16)#0 (3d749091db79ffe9bae741339e4610e2) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (7/16)#0 (3d749091db79ffe9bae741339e4610e2) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (6/16) (7fe48585a53963e7a8e1b0abd25d0a23) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (6/16) (attempt #0) with attempt id 7fe48585a53963e7a8e1b0abd25d0a23 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_5 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id e3dcab42cbcb6c8f2c3708edfec6a307 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (7/16) (c74f610df36be88b16e2f98567954e36) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (7/16)#0 (3d749091db79ffe9bae741339e4610e2) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (8/16)#0 (db799d6057fa07c9c23b14e7f1d533a9), deploy into slot with allocation id a2f7799a47c675931239ca3761a6bfcb. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (7/16) (attempt #0) with attempt id c74f610df36be88b16e2f98567954e36 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_6 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id c2cc3fb662c27e339846909707ae07bc INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (7/16)#0 (3d749091db79ffe9bae741339e4610e2) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (8/16) (aaee7e772ac0ae65ca2b21dab8619988) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (8/16)#0 (db799d6057fa07c9c23b14e7f1d533a9) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (8/16) (attempt #0) with attempt id aaee7e772ac0ae65ca2b21dab8619988 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_7 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id a2f7799a47c675931239ca3761a6bfcb INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot 32c24cbb9ef405f947c1264c32fbed58. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (9/16) (5da0fe9b1e4ed51eafc0b97879f6118a) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (9/16) (attempt #0) with attempt id 5da0fe9b1e4ed51eafc0b97879f6118a and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_8 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 32c24cbb9ef405f947c1264c32fbed58 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (9/16)#0 (358d9fec48019ac85e71b51ce96a4a5c), deploy into slot with allocation id 32c24cbb9ef405f947c1264c32fbed58. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (10/16) (c74b4dcf9097a81402e0f6fc25ffc8b3) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot f8c8b9b8e9e64e1c7774676db500d9cd. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (9/16)#0 (358d9fec48019ac85e71b51ce96a4a5c) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (9/16)#0 (358d9fec48019ac85e71b51ce96a4a5c) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (8/16)#0 (db799d6057fa07c9c23b14e7f1d533a9) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (9/16)#0 (358d9fec48019ac85e71b51ce96a4a5c) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (9/16)#0 (358d9fec48019ac85e71b51ce96a4a5c) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (8/16)#0 (db799d6057fa07c9c23b14e7f1d533a9) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (8/16)#0 (db799d6057fa07c9c23b14e7f1d533a9) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (10/16)#0 (b368dae592aaf16e918adc2bdb2f667f), deploy into slot with allocation id f8c8b9b8e9e64e1c7774676db500d9cd. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (10/16) (attempt #0) with attempt id c74b4dcf9097a81402e0f6fc25ffc8b3 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_9 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id f8c8b9b8e9e64e1c7774676db500d9cd INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (11/16) (6a987b2525efde4ca0352aba0fcf8192) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (11/16) (attempt #0) with attempt id 6a987b2525efde4ca0352aba0fcf8192 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_10 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 4d687207aab346a416effa64bd159463 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (12/16) (01e33feaf62865a71d31fbdf7e050f26) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot 4d687207aab346a416effa64bd159463. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (10/16)#0 (b368dae592aaf16e918adc2bdb2f667f) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (10/16)#0 (b368dae592aaf16e918adc2bdb2f667f) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (10/16)#0 (b368dae592aaf16e918adc2bdb2f667f) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (10/16)#0 (b368dae592aaf16e918adc2bdb2f667f) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (11/16)#0 (8d23bd7b4205d6ada24d5de28b77ae6d), deploy into slot with allocation id 4d687207aab346a416effa64bd159463. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (12/16) (attempt #0) with attempt id 01e33feaf62865a71d31fbdf7e050f26 and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_11 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 1fb8a61a2cd31abe4c4b6a1103719b82 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (11/16)#0 (8d23bd7b4205d6ada24d5de28b77ae6d) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot 1fb8a61a2cd31abe4c4b6a1103719b82. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (11/16)#0 (8d23bd7b4205d6ada24d5de28b77ae6d) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (13/16) (0b297b75f51c2d52eb4ad3d8921fe66d) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (13/16) (attempt #0) with attempt id 0b297b75f51c2d52eb4ad3d8921fe66d and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_12 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 3b0780ff2b6157dc4214b80fba838285 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (11/16)#0 (8d23bd7b4205d6ada24d5de28b77ae6d) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (11/16)#0 (8d23bd7b4205d6ada24d5de28b77ae6d) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (14/16) (cfd527253a2ba383b4661bf5208eb53a) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (12/16)#0 (a8d6c6d4bc441f11633ea0aea02449b0), deploy into slot with allocation id 1fb8a61a2cd31abe4c4b6a1103719b82. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (14/16) (attempt #0) with attempt id cfd527253a2ba383b4661bf5208eb53a and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_13 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id f5946e052106a4302d52b9597464de25 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (15/16) (4852069dda05da6175a5314a4b21124b) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (15/16) (attempt #0) with attempt id 4852069dda05da6175a5314a4b21124b and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_14 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 84d081060832bf6bac3f03b338de3049 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (12/16)#0 (a8d6c6d4bc441f11633ea0aea02449b0) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot 3b0780ff2b6157dc4214b80fba838285. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (12/16)#0 (a8d6c6d4bc441f11633ea0aea02449b0) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (16/16) (ad17985dc7aa8843615d32d4825b9a9a) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (16/16) (attempt #0) with attempt id ad17985dc7aa8843615d32d4825b9a9a and vertex id 181921bf8d745b26f5a7a7dfbdaa6543_15 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 343f7fbd49230a04b48c1e9b128a85b7 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (12/16)#0 (a8d6c6d4bc441f11633ea0aea02449b0) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (1/16) (7b430a6fb88f571d5f4c0de4e9600ff3) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (12/16)#0 (a8d6c6d4bc441f11633ea0aea02449b0) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (1/16) (attempt #0) with attempt id 7b430a6fb88f571d5f4c0de4e9600ff3 and vertex id ad72bd24e848bfbc6995eba35391c61a_0 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 5d8c279e8476e00e1893e8d9388bf873 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (2/16) (1255377bb7863736dce76cb929204cc6) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (2/16) (attempt #0) with attempt id 1255377bb7863736dce76cb929204cc6 and vertex id ad72bd24e848bfbc6995eba35391c61a_1 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id a2747af8bb148808c98d25f160d89e4a INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (3/16) (0764f00341a9a91e2d596b65d3ac213e) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (3/16) (attempt #0) with attempt id 0764f00341a9a91e2d596b65d3ac213e and vertex id ad72bd24e848bfbc6995eba35391c61a_2 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 22e04d75c4c195d2ee4b903f0cc75a7e INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (4/16) (885613e8036f32dfc39936fe2cd76d91) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (4/16) (attempt #0) with attempt id 885613e8036f32dfc39936fe2cd76d91 and vertex id ad72bd24e848bfbc6995eba35391c61a_3 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id de35331f464d11cb7ce4328119fcdd6e INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (5/16) (23aa4030914f7472474bfaedb3770d99) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (5/16) (attempt #0) with attempt id 23aa4030914f7472474bfaedb3770d99 and vertex id ad72bd24e848bfbc6995eba35391c61a_4 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 4b6729db2970e5d017d0c95236b33ec7 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (13/16)#0 (1e569de6b8d9df354d3604f7687b3e93), deploy into slot with allocation id 3b0780ff2b6157dc4214b80fba838285. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (6/16) (7788150e7a768f74b8fcc0a8234869a4) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (6/16) (attempt #0) with attempt id 7788150e7a768f74b8fcc0a8234869a4 and vertex id ad72bd24e848bfbc6995eba35391c61a_5 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id e3dcab42cbcb6c8f2c3708edfec6a307 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (13/16)#0 (1e569de6b8d9df354d3604f7687b3e93) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (13/16)#0 (1e569de6b8d9df354d3604f7687b3e93) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Activate slot f5946e052106a4302d52b9597464de25. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (7/16) (68e2581b7be6d61942002580f480c087) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (7/16) (attempt #0) with attempt id 68e2581b7be6d61942002580f480c087 and vertex id ad72bd24e848bfbc6995eba35391c61a_6 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id c2cc3fb662c27e339846909707ae07bc INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (13/16)#0 (1e569de6b8d9df354d3604f7687b3e93) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (13/16)#0 (1e569de6b8d9df354d3604f7687b3e93) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (8/16) (d27876e242a2f560c2430adb083e7ef9) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (8/16) (attempt #0) with attempt id d27876e242a2f560c2430adb083e7ef9 and vertex id ad72bd24e848bfbc6995eba35391c61a_7 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id a2f7799a47c675931239ca3761a6bfcb INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Received task DataSource (Impulse) (14/16)#0 (f5336169c3c6157837b4dec4c01614f6), deploy into slot with allocation id f5946e052106a4302d52b9597464de25. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (9/16) (1efe2da363140e88f091a48639e8381d) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Deploying DataSource (Impulse) (9/16) (attempt #0) with attempt id 1efe2da363140e88f091a48639e8381d and vertex id ad72bd24e848bfbc6995eba35391c61a_8 to 8e022257-3a0a-4fdd-bd42-5387459ef8a6 @ localhost (dataPort=-1) with allocation id 32c24cbb9ef405f947c1264c32fbed58 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (14/16)#0 (f5336169c3c6157837b4dec4c01614f6) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Loading JAR files for task DataSource (Impulse) (14/16)#0 (f5336169c3c6157837b4dec4c01614f6) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (10/16) (02505655f63373c2d2d68962ca2a1360) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 17, 2022 9:44:17 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: DataSource (Impulse) (14/16)#0 (f5336169c3c6157837b4dec4c01614f6) switched from DEPLOYING to INITIALIZING. Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
