ycjunhua commented on issue #3704:
URL: https://github.com/apache/hudi/issues/3704#issuecomment-925466739
10:34:04,886 INFO io.javalin.Javalin
- Starting Javalin ...
10:34:05,041 INFO io.javalin.Javalin
- Listening on http://localhost:65426/
10:34:05,042 INFO io.javalin.Javalin
- Javalin started in 160ms \o/
10:34:05,042 INFO org.apache.hudi.timeline.service.TimelineService
- Starting Timeline server on port :65426
10:34:05,042 INFO org.apache.hudi.client.embedded.EmbeddedTimelineService
- Started embedded timeline server at 0.0.0.0:65426
10:34:05,070 INFO org.apache.hudi.common.table.HoodieTableMetaClient
- Initializing
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area as hoodie table
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,096 INFO org.apache.hudi.common.table.HoodieTableMetaClient
- Loading HoodieTableMetaClient from
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,107 INFO org.apache.hudi.common.table.HoodieTableConfig
- Loading table properties from
file:/d:/yuou/dev/ods/mmt-new/router_configure/configure_area/.hoodie/hoodie.properties
10:34:05,113 INFO org.apache.hudi.common.table.HoodieTableMetaClient
- Finished Loading Table of type COPY_ON_WRITE(version=1,
baseFileFormat=PARQUET) from
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,114 INFO org.apache.hudi.common.table.HoodieTableMetaClient
- Finished initializing Table of type COPY_ON_WRITE from
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,114 INFO org.apache.hudi.util.StreamerUtil
- Table initialized under base path
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,114 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Starting scheduling with scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
10:34:05,115 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Job insert-into_default_catalog.default_database.configure_area
(63fd2fc9f76ebcbf9b7d3d47dabbdf38) switched from state CREATED to RUNNING.
10:34:05,124 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国', _UTF-16LE'0',
1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'', _UTF-16LE'ENABLE',
_UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj', 2021-09-18 16:48:00,
0 }]]) (1/1) (6a4bc3af8b2ff4a559b4ea525d82672f) switched from CREATED to
SCHEDULED.
10:34:05,124 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (1/8) (921bd3faa6059f2011630dc6c7cf6205) switched from
CREATED to SCHEDULED.
10:34:05,124 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (2/8) (2f7ff7feae62ead6c95de8adcbae446f) switched from
CREATED to SCHEDULED.
10:34:05,124 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (3/8) (f55cea56f6c92ae6431d74d60038df8d) switched from
CREATED to SCHEDULED.
10:34:05,124 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (4/8) (7d03b476ed15f492d5f2b3b6fd6d70a5) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (5/8) (7c2e16589f48980e9d1a98b2e7657812) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (6/8) (1167445b24e5d29a6b9ed39e64ae8b7b) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (7/8) (54a81f66851c0dd2941a3f803d219748) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (8/8) (4cbc4b54611bc044378ef998f3684352) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (1/8) (1377c78b753cc343c4d864a472276ed9) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (2/8) (991aeded53c2b1faea239c5f09c0f7ba) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (3/8) (84bcfbf44e9fa5c3877d1d4a9c0e40e1) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (4/8) (f2738a17abb5e3b94d2aa4afc3982bfb) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (5/8) (ba6f95731e0e4f8bf6748ce3cae87a70) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (6/8) (d4aeffa74f82b79361f229cb61dbc990) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (7/8) (cd6ba8fe96b84e26c7a0e9a0999a9e0c) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (8/8) (f55f88d3e637e42da3463df5ef5332a7) switched from
CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (1/4) (888768308836b8f4831890fa2934fe2c) switched
from CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (2/4) (d48422b9607bf34237abcaf9cbca24a2) switched
from CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (3/4) (ff5491c88ffc17a816e22c29b6da47be) switched
from CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (4/4) (5e2085d96585101e586a7ea47bc56a98) switched
from CREATED to SCHEDULED.
10:34:05,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Sink: clean_commits (1/1) (e46f7227496a98cb8360e4afa2fcdca1) switched
from CREATED to SCHEDULED.
10:34:05,139 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{8cabae95a0cc26237237c745f62b5fd4}]
10:34:05,142 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{4d7d73d1ad0a98376062a8d00ffcfe2c}]
10:34:05,142 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{3a96f5b7ee954f478c94e032ac8a4255}]
10:34:05,142 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{753d3ff5249b759c470280103571c7a6}]
10:34:05,143 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{176fb8ec4ea792945531ee45b5e6554d}]
10:34:05,143 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{f64a6edd16f8bafec0d0efbb24a6f8cb}]
10:34:05,143 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{035d934255cdf2a7c4e82c5bd739d3a3}]
10:34:05,143 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Cannot serve slot request, no ResourceManager connected. Adding as
pending request [SlotRequestId{eb76c87c540d933538f46f610219904d}]
10:34:05,151 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader
akka://flink/user/rpc/jobmanager_3 ,
session=4cbfe032-ce86-4978-a671-074d4eb6f1e0
10:34:05,151 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Connecting to ResourceManager
akka://flink/user/rpc/resourcemanager_1(8adbc1f5acdcf998575e8775440343d9)
10:34:05,155 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Resolved ResourceManager address, beginning registration
10:34:05,158 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registering job manager
a671074d4eb6f1e04cbfe032ce864978@akka://flink/user/rpc/jobmanager_3 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38.
10:34:05,166 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registered job manager
a671074d4eb6f1e04cbfe032ce864978@akka://flink/user/rpc/jobmanager_3 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38.
10:34:05,168 INFO org.apache.flink.runtime.jobmaster.JobMaster
- JobManager successfully registered at ResourceManager, leader id:
8adbc1f5acdcf998575e8775440343d9.
10:34:05,169 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{8cabae95a0cc26237237c745f62b5fd4}] and
profile ResourceProfile{UNKNOWN} with allocation id
764034c3267a443562b693e46aad20e5 from resource manager.
10:34:05,170 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
764034c3267a443562b693e46aad20e5.
10:34:05,170 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{4d7d73d1ad0a98376062a8d00ffcfe2c}] and
profile ResourceProfile{UNKNOWN} with allocation id
21a45995954d4f80f8e9559bd6c050c2 from resource manager.
10:34:05,170 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{3a96f5b7ee954f478c94e032ac8a4255}] and
profile ResourceProfile{UNKNOWN} with allocation id
4a41e5491be9026da0456dd23f0709e4 from resource manager.
10:34:05,171 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{753d3ff5249b759c470280103571c7a6}] and
profile ResourceProfile{UNKNOWN} with allocation id
bc89ec13c8cfe5f30f33b9b92894ad6d from resource manager.
10:34:05,171 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{176fb8ec4ea792945531ee45b5e6554d}] and
profile ResourceProfile{UNKNOWN} with allocation id
3b5cadd7193ba9bd4dc2cf7ccc9667b2 from resource manager.
10:34:05,171 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{f64a6edd16f8bafec0d0efbb24a6f8cb}] and
profile ResourceProfile{UNKNOWN} with allocation id
69e4facaa72255fa4011ad886be6e830 from resource manager.
10:34:05,172 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{035d934255cdf2a7c4e82c5bd739d3a3}] and
profile ResourceProfile{UNKNOWN} with allocation id
45b2be58c17c46712a1f99ffb71124c0 from resource manager.
10:34:05,172 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
- Requesting new slot [SlotRequestId{eb76c87c540d933538f46f610219904d}] and
profile ResourceProfile{UNKNOWN} with allocation id
f738d448f48642d75b3bf69475df9c0a from resource manager.
10:34:05,174 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request 764034c3267a443562b693e46aad20e5 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,176 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
21a45995954d4f80f8e9559bd6c050c2.
10:34:05,176 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
4a41e5491be9026da0456dd23f0709e4.
10:34:05,176 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
bc89ec13c8cfe5f30f33b9b92894ad6d.
10:34:05,178 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
3b5cadd7193ba9bd4dc2cf7ccc9667b2.
10:34:05,178 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
69e4facaa72255fa4011ad886be6e830.
10:34:05,179 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
45b2be58c17c46712a1f99ffb71124c0.
10:34:05,179 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{UNKNOWN} for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 with allocation id
f738d448f48642d75b3bf69475df9c0a.
10:34:05,183 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for 764034c3267a443562b693e46aad20e5.
10:34:05,185 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Add job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 for job leader monitoring.
10:34:05,188 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Try to
register at job manager akka://flink/user/rpc/jobmanager_3 with leader id
4cbfe032-ce86-4978-a671-074d4eb6f1e0.
10:34:05,189 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request 21a45995954d4f80f8e9559bd6c050c2 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,189 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for 21a45995954d4f80f8e9559bd6c050c2.
10:34:05,190 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request 4a41e5491be9026da0456dd23f0709e4 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,190 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for 4a41e5491be9026da0456dd23f0709e4.
10:34:05,190 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request bc89ec13c8cfe5f30f33b9b92894ad6d for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,190 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for bc89ec13c8cfe5f30f33b9b92894ad6d.
10:34:05,190 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request 3b5cadd7193ba9bd4dc2cf7ccc9667b2 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,190 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Resolved
JobManager address, beginning registration
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for 3b5cadd7193ba9bd4dc2cf7ccc9667b2.
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request 69e4facaa72255fa4011ad886be6e830 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for 69e4facaa72255fa4011ad886be6e830.
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request 45b2be58c17c46712a1f99ffb71124c0 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for 45b2be58c17c46712a1f99ffb71124c0.
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Receive slot request f738d448f48642d75b3bf69475df9c0a for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38 from resource manager with leader id
8adbc1f5acdcf998575e8775440343d9.
10:34:05,191 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Allocated slot for f738d448f48642d75b3bf69475df9c0a.
10:34:05,195 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Successful
registration at job manager akka://flink/user/rpc/jobmanager_3 for job
63fd2fc9f76ebcbf9b7d3d47dabbdf38.
10:34:05,196 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Establish JobManager connection for job 63fd2fc9f76ebcbf9b7d3d47dabbdf38.
10:34:05,200 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Offer reserved slots to the leader of job
63fd2fc9f76ebcbf9b7d3d47dabbdf38.
10:34:05,213 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国', _UTF-16LE'0',
1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'', _UTF-16LE'ENABLE',
_UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj', 2021-09-18 16:48:00,
0 }]]) (1/1) (6a4bc3af8b2ff4a559b4ea525d82672f) switched from SCHEDULED to
DEPLOYING.
10:34:05,216 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国',
_UTF-16LE'0', 1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'',
_UTF-16LE'ENABLE', _UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj',
2021-09-18 16:48:00, 0 }]]) (1/1) (attempt #0) with attempt id
6a4bc3af8b2ff4a559b4ea525d82672f to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 21a45995954d4f80f8e9559bd6c050c2
10:34:05,222 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (1/8) (921bd3faa6059f2011630dc6c7cf6205) switched from
SCHEDULED to DEPLOYING.
10:34:05,223 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (1/8) (attempt #0) with attempt id
921bd3faa6059f2011630dc6c7cf6205 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 21a45995954d4f80f8e9559bd6c050c2
10:34:05,224 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
21a45995954d4f80f8e9559bd6c050c2.
10:34:05,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (2/8) (2f7ff7feae62ead6c95de8adcbae446f) switched from
SCHEDULED to DEPLOYING.
10:34:05,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (2/8) (attempt #0) with attempt id
2f7ff7feae62ead6c95de8adcbae446f to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 69e4facaa72255fa4011ad886be6e830
10:34:05,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (3/8) (f55cea56f6c92ae6431d74d60038df8d) switched from
SCHEDULED to DEPLOYING.
10:34:05,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (3/8) (attempt #0) with attempt id
f55cea56f6c92ae6431d74d60038df8d to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id f738d448f48642d75b3bf69475df9c0a
10:34:05,226 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (4/8) (7d03b476ed15f492d5f2b3b6fd6d70a5) switched from
SCHEDULED to DEPLOYING.
10:34:05,226 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (4/8) (attempt #0) with attempt id
7d03b476ed15f492d5f2b3b6fd6d70a5 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 764034c3267a443562b693e46aad20e5
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (5/8) (7c2e16589f48980e9d1a98b2e7657812) switched from
SCHEDULED to DEPLOYING.
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (5/8) (attempt #0) with attempt id
7c2e16589f48980e9d1a98b2e7657812 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 3b5cadd7193ba9bd4dc2cf7ccc9667b2
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (6/8) (1167445b24e5d29a6b9ed39e64ae8b7b) switched from
SCHEDULED to DEPLOYING.
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (6/8) (attempt #0) with attempt id
1167445b24e5d29a6b9ed39e64ae8b7b to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 45b2be58c17c46712a1f99ffb71124c0
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (7/8) (54a81f66851c0dd2941a3f803d219748) switched from
SCHEDULED to DEPLOYING.
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (7/8) (attempt #0) with attempt id
54a81f66851c0dd2941a3f803d219748 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id bc89ec13c8cfe5f30f33b9b92894ad6d
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (8/8) (4cbc4b54611bc044378ef998f3684352) switched from
SCHEDULED to DEPLOYING.
10:34:05,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Filter -> Map (8/8) (attempt #0) with attempt id
4cbc4b54611bc044378ef998f3684352 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 4a41e5491be9026da0456dd23f0709e4
10:34:05,228 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (1/8) (1377c78b753cc343c4d864a472276ed9) switched from
SCHEDULED to DEPLOYING.
10:34:05,228 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (1/8) (attempt #0) with attempt id
1377c78b753cc343c4d864a472276ed9 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 21a45995954d4f80f8e9559bd6c050c2
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (2/8) (991aeded53c2b1faea239c5f09c0f7ba) switched from
SCHEDULED to DEPLOYING.
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (2/8) (attempt #0) with attempt id
991aeded53c2b1faea239c5f09c0f7ba to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 69e4facaa72255fa4011ad886be6e830
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (3/8) (84bcfbf44e9fa5c3877d1d4a9c0e40e1) switched from
SCHEDULED to DEPLOYING.
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (3/8) (attempt #0) with attempt id
84bcfbf44e9fa5c3877d1d4a9c0e40e1 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id f738d448f48642d75b3bf69475df9c0a
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (4/8) (f2738a17abb5e3b94d2aa4afc3982bfb) switched from
SCHEDULED to DEPLOYING.
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (4/8) (attempt #0) with attempt id
f2738a17abb5e3b94d2aa4afc3982bfb to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 764034c3267a443562b693e46aad20e5
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (5/8) (ba6f95731e0e4f8bf6748ce3cae87a70) switched from
SCHEDULED to DEPLOYING.
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (5/8) (attempt #0) with attempt id
ba6f95731e0e4f8bf6748ce3cae87a70 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 3b5cadd7193ba9bd4dc2cf7ccc9667b2
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (6/8) (d4aeffa74f82b79361f229cb61dbc990) switched from
SCHEDULED to DEPLOYING.
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (6/8) (attempt #0) with attempt id
d4aeffa74f82b79361f229cb61dbc990 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 45b2be58c17c46712a1f99ffb71124c0
10:34:05,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (7/8) (cd6ba8fe96b84e26c7a0e9a0999a9e0c) switched from
SCHEDULED to DEPLOYING.
10:34:05,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (7/8) (attempt #0) with attempt id
cd6ba8fe96b84e26c7a0e9a0999a9e0c to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id bc89ec13c8cfe5f30f33b9b92894ad6d
10:34:05,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (8/8) (f55f88d3e637e42da3463df5ef5332a7) switched from
SCHEDULED to DEPLOYING.
10:34:05,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying bucket_assigner (8/8) (attempt #0) with attempt id
f55f88d3e637e42da3463df5ef5332a7 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 4a41e5491be9026da0456dd23f0709e4
10:34:05,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (1/4) (888768308836b8f4831890fa2934fe2c) switched
from SCHEDULED to DEPLOYING.
10:34:05,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying hoodie_stream_write (1/4) (attempt #0) with attempt id
888768308836b8f4831890fa2934fe2c to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 21a45995954d4f80f8e9559bd6c050c2
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (2/4) (d48422b9607bf34237abcaf9cbca24a2) switched
from SCHEDULED to DEPLOYING.
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying hoodie_stream_write (2/4) (attempt #0) with attempt id
d48422b9607bf34237abcaf9cbca24a2 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 69e4facaa72255fa4011ad886be6e830
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (3/4) (ff5491c88ffc17a816e22c29b6da47be) switched
from SCHEDULED to DEPLOYING.
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying hoodie_stream_write (3/4) (attempt #0) with attempt id
ff5491c88ffc17a816e22c29b6da47be to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id f738d448f48642d75b3bf69475df9c0a
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (4/4) (5e2085d96585101e586a7ea47bc56a98) switched
from SCHEDULED to DEPLOYING.
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying hoodie_stream_write (4/4) (attempt #0) with attempt id
5e2085d96585101e586a7ea47bc56a98 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 764034c3267a443562b693e46aad20e5
10:34:05,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Sink: clean_commits (1/1) (e46f7227496a98cb8360e4afa2fcdca1) switched
from SCHEDULED to DEPLOYING.
10:34:05,232 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Deploying Sink: clean_commits (1/1) (attempt #0) with attempt id
e46f7227496a98cb8360e4afa2fcdca1 to a6e88966-162b-44b4-b2fd-39461a1a440c @
127.0.0.1 (dataPort=-1) with allocation id 21a45995954d4f80f8e9559bd6c050c2
10:34:05,249 INFO org.apache.hudi.table.HoodieTableFactory
- Table option [hoodie.datasource.write.keygenerator.class] is reset to
org.apache.hudi.keygen.NonpartitionedAvroKeyGenerator because this is a
non-partitioned table
10:34:05,283 INFO org.apache.hudi.common.table.HoodieTableMetaClient
- Loading HoodieTableMetaClient from
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,300 INFO org.apache.hudi.common.table.HoodieTableConfig
- Loading table properties from
file:/d:/yuou/dev/ods/mmt-new/router_configure/configure_area/.hoodie/hoodie.properties
10:34:05,303 INFO org.apache.hudi.common.table.HoodieTableMetaClient
- Finished Loading Table of type COPY_ON_WRITE(version=1,
baseFileFormat=PARQUET) from
file:///d:/yuou/dev/ods/mmt-new/router_configure/configure_area
10:34:05,306 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国',
_UTF-16LE'0', 1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'',
_UTF-16LE'ENABLE', _UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj',
2021-09-18 16:48:00, 0 }]]) (1/1)#0 (6a4bc3af8b2ff4a559b4ea525d82672f), deploy
into slot with allocation id 21a45995954d4f80f8e9559bd6c050c2.
10:34:05,307 INFO org.apache.flink.runtime.taskmanager.Task
- Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国', _UTF-16LE'0',
1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'', _UTF-16LE'ENABLE',
_UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj', 2021-09-18 16:48:00,
0 }]]) (1/1)#0 (6a4bc3af8b2ff4a559b4ea525d82672f) switched from CREATED to
DEPLOYING.
10:34:05,310 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
21a45995954d4f80f8e9559bd6c050c2.
10:34:05,316 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Source: Values(tuples=[[{ 1, _UTF-16LE'1',
_UTF-16LE'中国', _UTF-16LE'0', 1, _UTF-16LE'中国', _UTF-16LE'sap_area',
_UTF-16LE'', _UTF-16LE'ENABLE', _UTF-16LE'zhangsan', 2021-09-18 16:48:00,
_UTF-16LE'ayj', 2021-09-18 16:48:00, 0 }]]) (1/1)#0
(6a4bc3af8b2ff4a559b4ea525d82672f) [DEPLOYING].
10:34:05,318 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Source: Values(tuples=[[{ 1, _UTF-16LE'1',
_UTF-16LE'中国', _UTF-16LE'0', 1, _UTF-16LE'中国', _UTF-16LE'sap_area',
_UTF-16LE'', _UTF-16LE'ENABLE', _UTF-16LE'zhangsan', 2021-09-18 16:48:00,
_UTF-16LE'ayj', 2021-09-18 16:48:00, 0 }]]) (1/1)#0
(6a4bc3af8b2ff4a559b4ea525d82672f) [DEPLOYING].
10:34:05,320 INFO org.apache.hadoop.conf.Configuration.deprecation
- mapred.job.map.memory.mb is deprecated. Instead, use
mapreduce.map.memory.mb
10:34:05,328 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (1/8)#0 (921bd3faa6059f2011630dc6c7cf6205),
deploy into slot with allocation id 21a45995954d4f80f8e9559bd6c050c2.
10:34:05,328 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (1/8)#0 (921bd3faa6059f2011630dc6c7cf6205) switched from
CREATED to DEPLOYING.
10:34:05,329 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
69e4facaa72255fa4011ad886be6e830.
10:34:05,329 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (1/8)#0
(921bd3faa6059f2011630dc6c7cf6205) [DEPLOYING].
10:34:05,331 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (1/8)#0
(921bd3faa6059f2011630dc6c7cf6205) [DEPLOYING].
10:34:05,334 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (2/8)#0 (2f7ff7feae62ead6c95de8adcbae446f),
deploy into slot with allocation id 69e4facaa72255fa4011ad886be6e830.
10:34:05,335 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
f738d448f48642d75b3bf69475df9c0a.
10:34:05,335 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (2/8)#0 (2f7ff7feae62ead6c95de8adcbae446f) switched from
CREATED to DEPLOYING.
10:34:05,336 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (2/8)#0
(2f7ff7feae62ead6c95de8adcbae446f) [DEPLOYING].
10:34:05,337 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (2/8)#0
(2f7ff7feae62ead6c95de8adcbae446f) [DEPLOYING].
10:34:05,339 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (3/8)#0 (f55cea56f6c92ae6431d74d60038df8d),
deploy into slot with allocation id f738d448f48642d75b3bf69475df9c0a.
10:34:05,340 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (3/8)#0 (f55cea56f6c92ae6431d74d60038df8d) switched from
CREATED to DEPLOYING.
10:34:05,340 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
764034c3267a443562b693e46aad20e5.
10:34:05,341 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (3/8)#0
(f55cea56f6c92ae6431d74d60038df8d) [DEPLOYING].
10:34:05,342 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (3/8)#0
(f55cea56f6c92ae6431d74d60038df8d) [DEPLOYING].
10:34:05,345 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (4/8)#0 (7d03b476ed15f492d5f2b3b6fd6d70a5),
deploy into slot with allocation id 764034c3267a443562b693e46aad20e5.
10:34:05,345 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (4/8)#0 (7d03b476ed15f492d5f2b3b6fd6d70a5) switched from
CREATED to DEPLOYING.
10:34:05,346 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (4/8)#0
(7d03b476ed15f492d5f2b3b6fd6d70a5) [DEPLOYING].
10:34:05,346 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
3b5cadd7193ba9bd4dc2cf7ccc9667b2.
10:34:05,347 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (4/8)#0
(7d03b476ed15f492d5f2b3b6fd6d70a5) [DEPLOYING].
10:34:05,351 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (5/8)#0 (7c2e16589f48980e9d1a98b2e7657812),
deploy into slot with allocation id 3b5cadd7193ba9bd4dc2cf7ccc9667b2.
10:34:05,352 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
45b2be58c17c46712a1f99ffb71124c0.
10:34:05,352 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (5/8)#0 (7c2e16589f48980e9d1a98b2e7657812) switched from
CREATED to DEPLOYING.
10:34:05,353 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (5/8)#0
(7c2e16589f48980e9d1a98b2e7657812) [DEPLOYING].
10:34:05,354 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (5/8)#0
(7c2e16589f48980e9d1a98b2e7657812) [DEPLOYING].
10:34:05,359 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (6/8)#0 (1167445b24e5d29a6b9ed39e64ae8b7b),
deploy into slot with allocation id 45b2be58c17c46712a1f99ffb71124c0.
10:34:05,360 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
bc89ec13c8cfe5f30f33b9b92894ad6d.
10:34:05,361 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (6/8)#0 (1167445b24e5d29a6b9ed39e64ae8b7b) switched from
CREATED to DEPLOYING.
10:34:05,362 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (6/8)#0
(1167445b24e5d29a6b9ed39e64ae8b7b) [DEPLOYING].
10:34:05,363 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (6/8)#0
(1167445b24e5d29a6b9ed39e64ae8b7b) [DEPLOYING].
10:34:05,365 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (7/8)#0 (54a81f66851c0dd2941a3f803d219748),
deploy into slot with allocation id bc89ec13c8cfe5f30f33b9b92894ad6d.
10:34:05,366 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
4a41e5491be9026da0456dd23f0709e4.
10:34:05,366 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (7/8)#0 (54a81f66851c0dd2941a3f803d219748) switched from
CREATED to DEPLOYING.
10:34:05,367 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (7/8)#0
(54a81f66851c0dd2941a3f803d219748) [DEPLOYING].
10:34:05,368 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (7/8)#0
(54a81f66851c0dd2941a3f803d219748) [DEPLOYING].
10:34:05,371 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task Filter -> Map (8/8)#0 (4cbc4b54611bc044378ef998f3684352),
deploy into slot with allocation id 4a41e5491be9026da0456dd23f0709e4.
10:34:05,371 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
21a45995954d4f80f8e9559bd6c050c2.
10:34:05,373 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,373 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (1/8)#0 (1377c78b753cc343c4d864a472276ed9),
deploy into slot with allocation id 21a45995954d4f80f8e9559bd6c050c2.
10:34:05,373 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
69e4facaa72255fa4011ad886be6e830.
10:34:05,374 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (1/8)#0 (1377c78b753cc343c4d864a472276ed9) switched from
CREATED to DEPLOYING.
10:34:05,373 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,375 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (1/8)#0
(1377c78b753cc343c4d864a472276ed9) [DEPLOYING].
10:34:05,375 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (8/8)#0 (4cbc4b54611bc044378ef998f3684352) switched from
CREATED to DEPLOYING.
10:34:05,376 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Filter -> Map (8/8)#0
(4cbc4b54611bc044378ef998f3684352) [DEPLOYING].
10:34:05,377 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,377 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,376 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,377 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,378 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (1/8)#0
(1377c78b753cc343c4d864a472276ed9) [DEPLOYING].
10:34:05,378 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Filter -> Map (8/8)#0
(4cbc4b54611bc044378ef998f3684352) [DEPLOYING].
10:34:05,378 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,376 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,380 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,379 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (2/8)#0 (991aeded53c2b1faea239c5f09c0f7ba),
deploy into slot with allocation id 69e4facaa72255fa4011ad886be6e830.
10:34:05,380 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
f738d448f48642d75b3bf69475df9c0a.
10:34:05,378 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,384 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (3/8)#0 (84bcfbf44e9fa5c3877d1d4a9c0e40e1),
deploy into slot with allocation id f738d448f48642d75b3bf69475df9c0a.
10:34:05,385 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,385 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,385 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
764034c3267a443562b693e46aad20e5.
10:34:05,385 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,386 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,382 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (2/8)#0 (991aeded53c2b1faea239c5f09c0f7ba) switched from
CREATED to DEPLOYING.
10:34:05,386 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (4/8)#0 (f2738a17abb5e3b94d2aa4afc3982bfb),
deploy into slot with allocation id 764034c3267a443562b693e46aad20e5.
10:34:05,387 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (2/8)#0
(991aeded53c2b1faea239c5f09c0f7ba) [DEPLOYING].
10:34:05,388 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (3/8)#0 (84bcfbf44e9fa5c3877d1d4a9c0e40e1) switched from
CREATED to DEPLOYING.
10:34:05,388 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (4/8)#0 (f2738a17abb5e3b94d2aa4afc3982bfb) switched from
CREATED to DEPLOYING.
10:34:05,388 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
3b5cadd7193ba9bd4dc2cf7ccc9667b2.
10:34:05,388 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (4/8)#0
(f2738a17abb5e3b94d2aa4afc3982bfb) [DEPLOYING].
10:34:05,388 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (3/8)#0
(84bcfbf44e9fa5c3877d1d4a9c0e40e1) [DEPLOYING].
10:34:05,389 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (2/8)#0
(991aeded53c2b1faea239c5f09c0f7ba) [DEPLOYING].
10:34:05,391 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (3/8)#0
(84bcfbf44e9fa5c3877d1d4a9c0e40e1) [DEPLOYING].
10:34:05,393 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (4/8)#0
(f2738a17abb5e3b94d2aa4afc3982bfb) [DEPLOYING].
10:34:05,394 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (5/8)#0 (ba6f95731e0e4f8bf6748ce3cae87a70),
deploy into slot with allocation id 3b5cadd7193ba9bd4dc2cf7ccc9667b2.
10:34:05,395 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,395 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,395 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,395 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,395 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,395 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,396 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
45b2be58c17c46712a1f99ffb71124c0.
10:34:05,397 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (5/8)#0 (ba6f95731e0e4f8bf6748ce3cae87a70) switched from
CREATED to DEPLOYING.
10:34:05,398 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (5/8)#0
(ba6f95731e0e4f8bf6748ce3cae87a70) [DEPLOYING].
10:34:05,398 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (5/8)#0
(ba6f95731e0e4f8bf6748ce3cae87a70) [DEPLOYING].
10:34:05,401 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (1/8)#0 (921bd3faa6059f2011630dc6c7cf6205) switched from
DEPLOYING to RUNNING.
10:34:05,401 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (6/8)#0 (d4aeffa74f82b79361f229cb61dbc990),
deploy into slot with allocation id 45b2be58c17c46712a1f99ffb71124c0.
10:34:05,401 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (2/8)#0 (2f7ff7feae62ead6c95de8adcbae446f) switched from
DEPLOYING to RUNNING.
10:34:05,402 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (8/8)#0 (4cbc4b54611bc044378ef998f3684352) switched from
DEPLOYING to RUNNING.
10:34:05,403 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (6/8)#0 (d4aeffa74f82b79361f229cb61dbc990) switched from
CREATED to DEPLOYING.
10:34:05,401 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,404 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,404 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (5/8)#0 (ba6f95731e0e4f8bf6748ce3cae87a70) switched from
DEPLOYING to RUNNING.
10:34:05,404 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
bc89ec13c8cfe5f30f33b9b92894ad6d.
10:34:05,405 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (4/8)#0 (7d03b476ed15f492d5f2b3b6fd6d70a5) switched from
DEPLOYING to RUNNING.
10:34:05,405 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (4/8)#0 (f2738a17abb5e3b94d2aa4afc3982bfb) switched from
DEPLOYING to RUNNING.
10:34:05,404 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (3/8)#0 (f55cea56f6c92ae6431d74d60038df8d) switched from
DEPLOYING to RUNNING.
10:34:05,404 INFO org.apache.flink.runtime.taskmanager.Task
- Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国', _UTF-16LE'0',
1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'', _UTF-16LE'ENABLE',
_UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj', 2021-09-18 16:48:00,
0 }]]) (1/1)#0 (6a4bc3af8b2ff4a559b4ea525d82672f) switched from DEPLOYING to
RUNNING.
10:34:05,404 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (6/8)#0
(d4aeffa74f82b79361f229cb61dbc990) [DEPLOYING].
10:34:05,407 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (7/8)#0 (cd6ba8fe96b84e26c7a0e9a0999a9e0c),
deploy into slot with allocation id bc89ec13c8cfe5f30f33b9b92894ad6d.
10:34:05,407 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (7/8)#0 (cd6ba8fe96b84e26c7a0e9a0999a9e0c) switched from
CREATED to DEPLOYING.
10:34:05,406 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (6/8)#0 (1167445b24e5d29a6b9ed39e64ae8b7b) switched from
DEPLOYING to RUNNING.
10:34:05,405 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (5/8)#0 (7c2e16589f48980e9d1a98b2e7657812) switched from
DEPLOYING to RUNNING.
10:34:05,405 INFO org.apache.flink.runtime.taskmanager.Task
- Filter -> Map (7/8)#0 (54a81f66851c0dd2941a3f803d219748) switched from
DEPLOYING to RUNNING.
10:34:05,405 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (3/8)#0 (84bcfbf44e9fa5c3877d1d4a9c0e40e1) switched from
DEPLOYING to RUNNING.
10:34:05,408 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (1/8)#0 (1377c78b753cc343c4d864a472276ed9) switched from
DEPLOYING to RUNNING.
10:34:05,409 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (1/8) (921bd3faa6059f2011630dc6c7cf6205) switched from
DEPLOYING to RUNNING.
10:34:05,408 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (2/8)#0 (991aeded53c2b1faea239c5f09c0f7ba) switched from
DEPLOYING to RUNNING.
10:34:05,409 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (2/8) (2f7ff7feae62ead6c95de8adcbae446f) switched from
DEPLOYING to RUNNING.
10:34:05,408 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (7/8)#0
(cd6ba8fe96b84e26c7a0e9a0999a9e0c) [DEPLOYING].
10:34:05,407 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (6/8)#0
(d4aeffa74f82b79361f229cb61dbc990) [DEPLOYING].
10:34:05,410 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (7/8)#0
(cd6ba8fe96b84e26c7a0e9a0999a9e0c) [DEPLOYING].
10:34:05,407 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
4a41e5491be9026da0456dd23f0709e4.
10:34:05,409 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (8/8) (4cbc4b54611bc044378ef998f3684352) switched from
DEPLOYING to RUNNING.
10:34:05,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (5/8) (ba6f95731e0e4f8bf6748ce3cae87a70) switched from
DEPLOYING to RUNNING.
10:34:05,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (4/8) (f2738a17abb5e3b94d2aa4afc3982bfb) switched from
DEPLOYING to RUNNING.
10:34:05,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (4/8) (7d03b476ed15f492d5f2b3b6fd6d70a5) switched from
DEPLOYING to RUNNING.
10:34:05,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (3/8) (f55cea56f6c92ae6431d74d60038df8d) switched from
DEPLOYING to RUNNING.
10:34:05,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Source: Values(tuples=[[{ 1, _UTF-16LE'1', _UTF-16LE'中国', _UTF-16LE'0',
1, _UTF-16LE'中国', _UTF-16LE'sap_area', _UTF-16LE'', _UTF-16LE'ENABLE',
_UTF-16LE'zhangsan', 2021-09-18 16:48:00, _UTF-16LE'ayj', 2021-09-18 16:48:00,
0 }]]) (1/1) (6a4bc3af8b2ff4a559b4ea525d82672f) switched from DEPLOYING to
RUNNING.
10:34:05,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (6/8) (1167445b24e5d29a6b9ed39e64ae8b7b) switched from
DEPLOYING to RUNNING.
10:34:05,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (5/8) (7c2e16589f48980e9d1a98b2e7657812) switched from
DEPLOYING to RUNNING.
10:34:05,414 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,415 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,415 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (6/8)#0 (d4aeffa74f82b79361f229cb61dbc990) switched from
DEPLOYING to RUNNING.
10:34:05,415 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,415 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,415 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (7/8)#0 (cd6ba8fe96b84e26c7a0e9a0999a9e0c) switched from
DEPLOYING to RUNNING.
10:34:05,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Filter -> Map (7/8) (54a81f66851c0dd2941a3f803d219748) switched from
DEPLOYING to RUNNING.
10:34:05,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (3/8) (84bcfbf44e9fa5c3877d1d4a9c0e40e1) switched from
DEPLOYING to RUNNING.
10:34:05,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (1/8) (1377c78b753cc343c4d864a472276ed9) switched from
DEPLOYING to RUNNING.
10:34:05,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (2/8) (991aeded53c2b1faea239c5f09c0f7ba) switched from
DEPLOYING to RUNNING.
10:34:05,417 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task bucket_assigner (8/8)#0 (f55f88d3e637e42da3463df5ef5332a7),
deploy into slot with allocation id 4a41e5491be9026da0456dd23f0709e4.
10:34:05,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (6/8) (d4aeffa74f82b79361f229cb61dbc990) switched from
DEPLOYING to RUNNING.
10:34:05,417 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
21a45995954d4f80f8e9559bd6c050c2.
10:34:05,417 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (8/8)#0 (f55f88d3e637e42da3463df5ef5332a7) switched from
CREATED to DEPLOYING.
10:34:05,418 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task bucket_assigner (8/8)#0
(f55f88d3e637e42da3463df5ef5332a7) [DEPLOYING].
10:34:05,418 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: bucket_assigner (8/8)#0
(f55f88d3e637e42da3463df5ef5332a7) [DEPLOYING].
10:34:05,420 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (7/8) (cd6ba8fe96b84e26c7a0e9a0999a9e0c) switched from
DEPLOYING to RUNNING.
10:34:05,421 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task hoodie_stream_write (1/4)#0
(888768308836b8f4831890fa2934fe2c), deploy into slot with allocation id
21a45995954d4f80f8e9559bd6c050c2.
10:34:05,422 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
69e4facaa72255fa4011ad886be6e830.
10:34:05,423 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task hoodie_stream_write (2/4)#0
(d48422b9607bf34237abcaf9cbca24a2), deploy into slot with allocation id
69e4facaa72255fa4011ad886be6e830.
10:34:05,423 INFO org.apache.flink.runtime.taskmanager.Task
- hoodie_stream_write (1/4)#0 (888768308836b8f4831890fa2934fe2c) switched
from CREATED to DEPLOYING.
10:34:05,424 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task hoodie_stream_write (1/4)#0
(888768308836b8f4831890fa2934fe2c) [DEPLOYING].
10:34:05,424 INFO org.apache.flink.runtime.taskmanager.Task
- hoodie_stream_write (2/4)#0 (d48422b9607bf34237abcaf9cbca24a2) switched
from CREATED to DEPLOYING.
10:34:05,424 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
f738d448f48642d75b3bf69475df9c0a.
10:34:05,427 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task hoodie_stream_write (3/4)#0
(ff5491c88ffc17a816e22c29b6da47be), deploy into slot with allocation id
f738d448f48642d75b3bf69475df9c0a.
10:34:05,427 INFO org.apache.flink.runtime.taskmanager.Task
- hoodie_stream_write (3/4)#0 (ff5491c88ffc17a816e22c29b6da47be) switched
from CREATED to DEPLOYING.
10:34:05,428 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task hoodie_stream_write (3/4)#0
(ff5491c88ffc17a816e22c29b6da47be) [DEPLOYING].
10:34:05,425 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task hoodie_stream_write (2/4)#0
(d48422b9607bf34237abcaf9cbca24a2) [DEPLOYING].
10:34:05,428 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: hoodie_stream_write (3/4)#0
(ff5491c88ffc17a816e22c29b6da47be) [DEPLOYING].
10:34:05,429 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: hoodie_stream_write (2/4)#0
(d48422b9607bf34237abcaf9cbca24a2) [DEPLOYING].
10:34:05,427 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
764034c3267a443562b693e46aad20e5.
10:34:05,427 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,433 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,434 INFO org.apache.flink.runtime.taskmanager.Task
- bucket_assigner (8/8)#0 (f55f88d3e637e42da3463df5ef5332a7) switched from
DEPLOYING to RUNNING.
10:34:05,434 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,434 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,434 INFO org.apache.flink.runtime.taskmanager.Task
- hoodie_stream_write (2/4)#0 (d48422b9607bf34237abcaf9cbca24a2) switched
from DEPLOYING to RUNNING.
10:34:05,432 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: hoodie_stream_write (1/4)#0
(888768308836b8f4831890fa2934fe2c) [DEPLOYING].
10:34:05,435 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- bucket_assigner (8/8) (f55f88d3e637e42da3463df5ef5332a7) switched from
DEPLOYING to RUNNING.
10:34:05,430 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,437 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,438 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- hoodie_stream_write (2/4) (d48422b9607bf34237abcaf9cbca24a2) switched
from DEPLOYING to RUNNING.
10:34:05,439 INFO org.apache.flink.runtime.taskmanager.Task
- hoodie_stream_write (3/4)#0 (ff5491c88ffc17a816e22c29b6da47be) switched
from DEPLOYING to RUNNING.
10:34:05,440 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using job/cluster config to configure application-defined state backend:
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: UNDEFINED,
maxStateSize: 5242880)
10:34:05,440 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
- Using application-defined state backend: MemoryStateBackend (data in heap
memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null',
asynchronous: TRUE, maxStateSize: 5242880)
10:34:05,440 INFO org.apache.flink.runtime.taskmanager.Task
- hoodie_stream_write (1/4)#0 (888768308836b8f4831890fa2934fe2c) switched
from DEPLOYING to RUNNING.
10:34:05,439 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Received task hoodie_stream_write (4/4)#0
(5e2085d96585101e586a7ea47bc56a98), deploy into slot with allocation id
764034c3267a443562b693e46aad20e5.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
