NickYoungPeng commented on issue #4809:
URL: https://github.com/apache/seatunnel/issues/4809#issuecomment-1558562991
2023-05-23 13:42:46,592 INFO
org.apache.seatunnel.core.starter.utils.ConfigBuilder - Loading config file
from path:
D:\code\youngp\incubator-seatunnel\seatunnel-examples\seatunnel-flink-connector-v2-example\target\classes\examples\hive_to_console2.conf
2023-05-23 13:42:46,659 INFO
org.apache.seatunnel.core.starter.utils.ConfigShadeUtils - Load config shade
spi: [base64]
2023-05-23 13:42:46,884 INFO
org.apache.seatunnel.core.starter.utils.ConfigBuilder - Parsed config file: {
"env" : {
"execution.parallelism" : 2,
"job.mode" : "BATCH"
},
"source" : [
{
"metastore_uri" : "thrift://192.168.112.127:9083",
"result_table_name" : "user",
"plugin_name" : "Hive",
"table_name" : "default.test3"
}
],
"transform" : [
{
"replace_field" : "emails",
"pattern" : "qq",
"is_regex" : true,
"source_table_name" : "user",
"result_table_name" : "user_1",
"plugin_name" : "Replace",
"replacement" : "163"
}
],
"sink" : [
{
"source_table_name" : "user_1",
"metastore_uri" : "thrift://192.168.112.127:9083",
"plugin_name" : "Hive",
"table_name" : "db_test_dev.test3"
}
]
}
2023-05-23 13:42:47,138 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load
SeaTunnelSource Plugin from
D:\code\youngp\incubator-seatunnel\seatunnel-common\connectors\seatunnel
2023-05-23 13:42:47,156 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin:
PluginIdentifier{engineType='seatunnel', pluginType='source',
pluginName='Hive'} from classpath
2023-05-23 13:42:47,193 INFO org.apache.hadoop.hive.conf.HiveConf - Found
configuration file null
2023-05-23 13:42:47,560 INFO hive.metastore - Trying to connect to
metastore with URI thrift://192.168.112.127:9083
2023-05-23 13:42:47,581 INFO hive.metastore - Opened a connection to
metastore, current connections: 1
2023-05-23 13:42:47,674 INFO hive.metastore - Connected to metastore.
2023-05-23 13:42:47,924 INFO hive.metastore - Closed a connection to
metastore, current connections: 0
2023-05-23 13:42:47,954 WARN
org.apache.seatunnel.connectors.seatunnel.file.sink.util.FileSystemUtils -
Principal [null] or keytabPath [null] is empty, it will skip kerberos
authentication
2023-05-23 13:42:48,793 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load
SeaTunnelTransform Plugin from
D:\code\youngp\incubator-seatunnel\seatunnel-common\lib
2023-05-23 13:42:48,800 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin:
PluginIdentifier{engineType='seatunnel', pluginType='transform',
pluginName='Replace'} from classpath
2023-05-23 13:42:48,801 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load
SeaTunnelSink Plugin from
D:\code\youngp\incubator-seatunnel\seatunnel-common\connectors\seatunnel
2023-05-23 13:42:48,807 INFO
org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin:
PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Hive'}
from classpath
2023-05-23 13:42:48,845 INFO hive.metastore - Trying to connect to
metastore with URI thrift://192.168.112.127:9083
2023-05-23 13:42:48,850 INFO hive.metastore - Opened a connection to
metastore, current connections: 1
2023-05-23 13:42:48,856 INFO hive.metastore - Connected to metastore.
2023-05-23 13:42:49,062 INFO hive.metastore - Closed a connection to
metastore, current connections: 0
2023-05-23 13:42:49,063 WARN
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution - Remove
invalid jar when inject jars into config:
file:/D:/code/youngp/incubator-seatunnel/seatunnel-common/starter/seatunnel-flink-13-starter.jar
2023-05-23 13:42:49,064 WARN
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution - Remove
invalid jar when inject jars into config:
file:/D:/code/youngp/incubator-seatunnel/seatunnel-common/starter/seatunnel-flink-13-starter.jar
2023-05-23 13:42:51,302 INFO
org.apache.seatunnel.transform.common.SingleFieldOutputTransform - Changed
input row type: ROW<name STRING,age INT,emails ARRAY<STRING>,phones Map<STRING,
STRING>,org ROW<CODE STRING,NAME STRING,TEL STRING>> to output row type:
ROW<name STRING,age INT,emails STRING,phones Map<STRING, STRING>,org ROW<CODE
STRING,NAME STRING,TEL STRING>>
2023-05-23 13:42:51,578 INFO
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution - Flink
Execution Plan: {
"nodes" : [ {
"id" : 1,
"type" : "Source: SeaTunnel HiveSource",
"pact" : "Data Source",
"contents" : "Source: SeaTunnel HiveSource",
"parallelism" : 2
}, {
"id" : 3,
"type" : "DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false)",
"pact" : "Operator",
"contents" :
"DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false)",
"parallelism" : 2,
"predecessors" : [ {
"id" : 1,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 4,
"type" : "SinkConversionToRow",
"pact" : "Operator",
"contents" : "SinkConversionToRow",
"parallelism" : 2,
"predecessors" : [ {
"id" : 3,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 5,
"type" : "Flat Map",
"pact" : "Operator",
"contents" : "Flat Map",
"parallelism" : 2,
"predecessors" : [ {
"id" : 4,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 7,
"type" :
"DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false)",
"pact" : "Operator",
"contents" :
"DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false)",
"parallelism" : 2,
"predecessors" : [ {
"id" : 5,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 8,
"type" : "SinkConversionToRow",
"pact" : "Operator",
"contents" : "SinkConversionToRow",
"parallelism" : 2,
"predecessors" : [ {
"id" : 7,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 10,
"type" : "Sink Writer: Hive",
"pact" : "Operator",
"contents" : "Sink Writer: Hive",
"parallelism" : 2,
"predecessors" : [ {
"id" : 8,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 11,
"type" : "Sink Global Committer: Hive",
"pact" : "Operator",
"contents" : "Sink Global Committer: Hive",
"parallelism" : 1,
"predecessors" : [ {
"id" : 10,
"ship_strategy" : "REBALANCE",
"side" : "second"
} ]
} ]
}
2023-05-23 13:42:51,578 INFO
org.apache.seatunnel.core.starter.flink.execution.FlinkExecution - Flink job
name: SeaTunnel
2023-05-23 13:42:51,694 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The
configuration option taskmanager.cpu.cores required for local execution is not
set, setting it to the maximal possible value.
2023-05-23 13:42:51,694 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The
configuration option taskmanager.memory.task.heap.size required for local
execution is not set, setting it to the maximal possible value.
2023-05-23 13:42:51,694 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The
configuration option taskmanager.memory.task.off-heap.size required for local
execution is not set, setting it to the maximal possible value.
2023-05-23 13:42:51,695 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The
configuration option taskmanager.memory.network.min required for local
execution is not set, setting it to its default value 64 mb.
2023-05-23 13:42:51,695 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The
configuration option taskmanager.memory.network.max required for local
execution is not set, setting it to its default value 64 mb.
2023-05-23 13:42:51,695 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The
configuration option taskmanager.memory.managed.size required for local
execution is not set, setting it to its default value 128 mb.
2023-05-23 13:42:51,698 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
2023-05-23 13:42:51,701 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
2023-05-23 13:42:51,733 INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter
configured, no metrics will be exposed/reported.
2023-05-23 13:42:51,733 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
2023-05-23 13:42:51,749 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Trying to start local
actor system
2023-05-23 13:42:52,015 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger
started
2023-05-23 13:42:52,192 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Actor system started at
akka://flink
2023-05-23 13:42:52,204 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Trying to start local
actor system
2023-05-23 13:42:52,213 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger
started
2023-05-23 13:42:52,227 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Actor system started at
akka://flink-metrics
2023-05-23 13:42:52,245 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.metrics.dump.MetricQueryService at
akka://flink-metrics/user/rpc/MetricQueryService .
2023-05-23 13:42:52,264 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability
services
2023-05-23 13:42:52,277 INFO org.apache.flink.runtime.blob.BlobServer -
Created BLOB server storage directory
C:\Users\YANGPENG\AppData\Local\Temp\blobStore-ec0e374b-0b20-4855-847c-020354d30f58
2023-05-23 13:42:52,285 INFO org.apache.flink.runtime.blob.BlobServer -
Started BLOB server at 0.0.0.0:49872 - max concurrent requests: 50 - max
backlog: 1000
2023-05-23 13:42:52,289 INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage
directory
C:\Users\YANGPENG\AppData\Local\Temp\blobStore-1b22df82-0d9d-442a-a61d-d8b9587997f2
2023-05-23 13:42:52,291 INFO
org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage
directory
C:\Users\YANGPENG\AppData\Local\Temp\blobStore-126efc22-26b0-4726-b1a9-3e0e046036b7
2023-05-23 13:42:52,291 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
2023-05-23 13:42:52,296 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager
with ResourceID: 752e7786-e966-4665-99c2-84b515a1d840
2023-05-23 13:42:52,323 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file
directory 'C:\Users\YANGPENG\AppData\Local\Temp': total 315 GB, usable 74 GB
(23.49% usable)
2023-05-23 13:42:52,347 INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager
uses directory
C:\Users\YANGPENG\AppData\Local\Temp\flink-io-af6b9277-7b75-4eba-8fa2-651a323777ff
for spill files.
2023-05-23 13:42:52,357 INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager
uses directory
C:\Users\YANGPENG\AppData\Local\Temp\flink-netty-shuffle-d9e98fdb-11dd-46f7-a48b-5762aa07b022
for spill files.
2023-05-23 13:42:52,398 INFO
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 64 MB
for network buffer pool (number of memory segments: 2048, bytes per segment:
32768).
2023-05-23 13:42:52,408 INFO
org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Starting the
network environment and its components.
2023-05-23 13:42:52,410 INFO
org.apache.flink.runtime.taskexecutor.KvStateService - Starting the kvState
service and its components.
2023-05-23 13:42:52,434 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.taskexecutor.TaskExecutor at
akka://flink/user/rpc/taskmanager_0 .
2023-05-23 13:42:52,449 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Start job
leader service.
2023-05-23 13:42:52,451 INFO org.apache.flink.runtime.filecache.FileCache -
User file cache uses directory
C:\Users\YANGPENG\AppData\Local\Temp\flink-dist-cache-c109e3c1-29f8-4881-a49b-fb1f76f40eb5
2023-05-23 13:42:52,511 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest
endpoint.
2023-05-23 13:42:52,610 WARN
org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment
variable 'log.file' is not set.
2023-05-23 13:42:52,610 WARN
org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are
unavailable in the web dashboard. Log file location not found in environment
variable 'log.file' or configuration key 'web.log.path'.
2023-05-23 13:42:53,111 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint
listening at localhost:49907
2023-05-23 13:42:53,112 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender http://localhost:49907
2023-05-23 13:42:53,114 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend
listening at http://localhost:49907.
2023-05-23 13:42:53,114 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint -
http://localhost:49907 was granted leadership with
leaderSessionID=d8eb23af-be13-42b1-b0c1-a6295348e24f
2023-05-23 13:42:53,115 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader http://localhost:49907 ,
session=d8eb23af-be13-42b1-b0c1-a6295348e24f
2023-05-23 13:42:53,137 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
akka://flink/user/rpc/resourcemanager_1 .
2023-05-23 13:42:53,151 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
2023-05-23 13:42:53,152 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Starting
the resource manager.
2023-05-23 13:42:53,152 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender LeaderContender: StandaloneResourceManager
2023-05-23 13:42:53,152 INFO
org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner -
DefaultDispatcherRunner was granted leadership with leader id
439210a6-ea50-41b1-8977-b5c83f14e2b5. Creating new DispatcherLeaderProcess.
2023-05-23 13:42:53,154 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
ResourceManager akka://flink/user/rpc/resourcemanager_1 was granted leadership
with fencing token ae5a3d9103f0ae3e09ec7f3f29db4644
2023-05-23 13:42:53,156 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started
successfully
2023-05-23 13:42:53,158 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess -
Start SessionDispatcherLeaderProcess.
2023-05-23 13:42:53,160 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess -
Recover all persisted job graphs.
2023-05-23 13:42:53,160 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess -
Successfully recovered 0 persisted job graphs.
2023-05-23 13:42:53,164 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader
akka://flink/user/rpc/resourcemanager_1 ,
session=09ec7f3f-29db-4644-ae5a-3d9103f0ae3e
2023-05-23 13:42:53,166 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to
ResourceManager
akka://flink/user/rpc/resourcemanager_1(ae5a3d9103f0ae3e09ec7f3f29db4644).
2023-05-23 13:42:53,169 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
akka://flink/user/rpc/dispatcher_2 .
2023-05-23 13:42:53,174 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader
akka://flink/user/rpc/dispatcher_2 ,
session=439210a6-ea50-41b1-8977-b5c83f14e2b5
2023-05-23 13:42:53,186 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager
address, beginning registration
2023-05-23 13:42:53,190 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registering TaskManager with ResourceID 752e7786-e966-4665-99c2-84b515a1d840
(akka://flink/user/rpc/taskmanager_0) at ResourceManager
2023-05-23 13:42:53,192 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at
resource manager akka://flink/user/rpc/resourcemanager_1 under registration id
012165a0584f7b19985d4618ab19282d.
2023-05-23 13:42:53,193 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Received JobGraph
submission c945b7989c0dec2a47540914a4224add (SeaTunnel).
2023-05-23 13:42:53,194 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job
c945b7989c0dec2a47540914a4224add (SeaTunnel).
2023-05-23 13:42:53,209 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender LeaderContender:
JobMasterServiceLeadershipRunner
2023-05-23 13:42:53,221 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.jobmaster.JobMaster at
akka://flink/user/rpc/jobmanager_3 .
2023-05-23 13:42:53,227 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Initializing job SeaTunnel (c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:53,249 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Using restart back off time strategy NoRestartBackoffTimeStrategy for SeaTunnel
(c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:53,281 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Running initialization on master for job SeaTunnel
(c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:53,282 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Successfully ran initialization on master in 0 ms.
2023-05-23 13:42:53,297 INFO
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology - Built 1
pipelined regions in 1 ms
2023-05-23 13:42:53,308 INFO org.apache.flink.runtime.jobmaster.JobMaster -
No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@7879ae7
2023-05-23 13:42:53,309 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Checkpoint storage is set to 'jobmanager'
2023-05-23 13:42:53,328 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - No checkpoint found
during restore.
2023-05-23 13:42:53,336 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Using failover strategy
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@74a008ed
for SeaTunnel (c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:53,345 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader
akka://flink/user/rpc/jobmanager_3 ,
session=586b5f4e-3416-41e8-a8cd-1d403ae1ffe3
2023-05-23 13:42:53,348 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Starting execution of job SeaTunnel (c945b7989c0dec2a47540914a4224add) under
job master id a8cd1d403ae1ffe3586b5f4e341641e8.
2023-05-23 13:42:53,349 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Starting scheduling with scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
2023-05-23 13:42:53,350 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job SeaTunnel
(c945b7989c0dec2a47540914a4224add) switched from state CREATED to RUNNING.
2023-05-23 13:42:53,354 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2) (31359d2ed974bb20cead85704a64edad) switched from CREATED to SCHEDULED.
2023-05-23 13:42:53,354 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2) (4b5a302f6e0b123846bf1e85b928484c) switched from CREATED to SCHEDULED.
2023-05-23 13:42:53,354 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink Global Committer:
Hive (1/1) (66e840af77041a0bf46fcb8f45152738) switched from CREATED to
SCHEDULED.
2023-05-23 13:42:53,374 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Connecting to ResourceManager
akka://flink/user/rpc/resourcemanager_1(ae5a3d9103f0ae3e09ec7f3f29db4644)
2023-05-23 13:42:53,376 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Resolved ResourceManager address, beginning registration
2023-05-23 13:42:53,378 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registering job manager
a8cd1d403ae1ffe3586b5f4e341641e8@akka://flink/user/rpc/jobmanager_3 for job
c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:53,383 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered
job manager a8cd1d403ae1ffe3586b5f4e341641e8@akka://flink/user/rpc/jobmanager_3
for job c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:53,387 INFO org.apache.flink.runtime.jobmaster.JobMaster -
JobManager successfully registered at ResourceManager, leader id:
ae5a3d9103f0ae3e09ec7f3f29db4644.
2023-05-23 13:42:53,389 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager -
Received resource requirements from job c945b7989c0dec2a47540914a4224add:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=2}]
2023-05-23 13:42:53,393 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request
a5dd28c25246b436b2fca7dcc4c0ae19 for job c945b7989c0dec2a47540914a4224add from
resource manager with leader id ae5a3d9103f0ae3e09ec7f3f29db4644.
2023-05-23 13:42:53,401 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for
a5dd28c25246b436b2fca7dcc4c0ae19.
2023-05-23 13:42:53,402 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Add job
c945b7989c0dec2a47540914a4224add for job leader monitoring.
2023-05-23 13:42:53,405 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Try to register
at job manager akka://flink/user/rpc/jobmanager_3 with leader id
586b5f4e-3416-41e8-a8cd-1d403ae1ffe3.
2023-05-23 13:42:53,405 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request
754c9cbc71bf538f13150ed2fe05f47d for job c945b7989c0dec2a47540914a4224add from
resource manager with leader id ae5a3d9103f0ae3e09ec7f3f29db4644.
2023-05-23 13:42:53,405 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for
754c9cbc71bf538f13150ed2fe05f47d.
2023-05-23 13:42:53,406 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Resolved
JobManager address, beginning registration
2023-05-23 13:42:53,410 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Successful
registration at job manager akka://flink/user/rpc/jobmanager_3 for job
c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:53,411 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager
connection for job c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:53,417 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to
the leader of job c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:53,425 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2) (31359d2ed974bb20cead85704a64edad) switched from SCHEDULED to DEPLOYING.
2023-05-23 13:42:53,425 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source:
SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2) (attempt #0) with attempt id 31359d2ed974bb20cead85704a64edad to
752e7786-e966-4665-99c2-84b515a1d840 @ kubernetes.docker.internal (dataPort=-1)
with allocation id 754c9cbc71bf538f13150ed2fe05f47d
2023-05-23 13:42:53,430 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2) (4b5a302f6e0b123846bf1e85b928484c) switched from SCHEDULED to DEPLOYING.
2023-05-23 13:42:53,430 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source:
SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2) (attempt #0) with attempt id 4b5a302f6e0b123846bf1e85b928484c to
752e7786-e966-4665-99c2-84b515a1d840 @ kubernetes.docker.internal (dataPort=-1)
with allocation id a5dd28c25246b436b2fca7dcc4c0ae19
2023-05-23 13:42:53,430 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
754c9cbc71bf538f13150ed2fe05f47d.
2023-05-23 13:42:53,431 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink Global Committer:
Hive (1/1) (66e840af77041a0bf46fcb8f45152738) switched from SCHEDULED to
DEPLOYING.
2023-05-23 13:42:53,431 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink Global
Committer: Hive (1/1) (attempt #0) with attempt id
66e840af77041a0bf46fcb8f45152738 to 752e7786-e966-4665-99c2-84b515a1d840 @
kubernetes.docker.internal (dataPort=-1) with allocation id
754c9cbc71bf538f13150ed2fe05f47d
2023-05-23 13:42:53,459 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source:
SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad), deploy into slot with allocation id
754c9cbc71bf538f13150ed2fe05f47d.
2023-05-23 13:42:53,460 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad) switched from CREATED to DEPLOYING.
2023-05-23 13:42:53,461 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
a5dd28c25246b436b2fca7dcc4c0ae19.
2023-05-23 13:42:53,464 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source:
SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c), deploy into slot with allocation id
a5dd28c25246b436b2fca7dcc4c0ae19.
2023-05-23 13:42:53,464 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
754c9cbc71bf538f13150ed2fe05f47d.
2023-05-23 13:42:53,464 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c) switched from CREATED to DEPLOYING.
2023-05-23 13:42:53,467 INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c) [DEPLOYING].
2023-05-23 13:42:53,467 INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad) [DEPLOYING].
2023-05-23 13:42:53,476 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Sink Global
Committer: Hive (1/1)#0 (66e840af77041a0bf46fcb8f45152738), deploy into slot
with allocation id 754c9cbc71bf538f13150ed2fe05f47d.
2023-05-23 13:42:53,476 INFO org.apache.flink.runtime.taskmanager.Task -
Sink Global Committer: Hive (1/1)#0 (66e840af77041a0bf46fcb8f45152738) switched
from CREATED to DEPLOYING.
2023-05-23 13:42:53,476 INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task Sink Global Committer: Hive (1/1)#0
(66e840af77041a0bf46fcb8f45152738) [DEPLOYING].
2023-05-23 13:42:53,477 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
a5dd28c25246b436b2fca7dcc4c0ae19.
2023-05-23 13:42:53,477 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot
754c9cbc71bf538f13150ed2fe05f47d.
2023-05-23 13:42:53,497 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@1b0578ae
2023-05-23 13:42:53,497 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - Checkpoint storage is set
to 'jobmanager'
2023-05-23 13:42:53,497 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@75d1d496
2023-05-23 13:42:53,497 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@1341c2a0
2023-05-23 13:42:53,497 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - Checkpoint storage is set
to 'jobmanager'
2023-05-23 13:42:53,497 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - Checkpoint storage is set
to 'jobmanager'
2023-05-23 13:42:53,508 INFO org.apache.flink.runtime.taskmanager.Task -
Sink Global Committer: Hive (1/1)#0 (66e840af77041a0bf46fcb8f45152738) switched
from DEPLOYING to INITIALIZING.
2023-05-23 13:42:53,508 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad) switched from DEPLOYING to
INITIALIZING.
2023-05-23 13:42:53,508 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c) switched from DEPLOYING to
INITIALIZING.
2023-05-23 13:42:53,510 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2) (31359d2ed974bb20cead85704a64edad) switched from DEPLOYING to
INITIALIZING.
2023-05-23 13:42:53,511 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2) (4b5a302f6e0b123846bf1e85b928484c) switched from DEPLOYING to
INITIALIZING.
2023-05-23 13:42:53,511 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink Global Committer:
Hive (1/1) (66e840af77041a0bf46fcb8f45152738) switched from DEPLOYING to
INITIALIZING.
2023-05-23 13:42:53,619 WARN org.apache.flink.metrics.MetricGroup - The
operator name DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) exceeded the 80 characters length limit and was
truncated.
2023-05-23 13:42:53,619 WARN org.apache.flink.metrics.MetricGroup - The
operator name DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) exceeded the 80 characters length limit and was
truncated.
2023-05-23 13:42:53,636 WARN org.apache.flink.metrics.MetricGroup - The
operator name DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) exceeded the 80 characters length limit and was
truncated.
2023-05-23 13:42:53,640 WARN org.apache.flink.metrics.MetricGroup - The
operator name DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) exceeded the 80 characters length limit and was
truncated.
2023-05-23 13:42:53,694 INFO
org.apache.seatunnel.translation.flink.source.BaseSeaTunnelSourceFunction -
Consumer subtask 0 has no restore state.
2023-05-23 13:42:53,694 INFO
org.apache.seatunnel.translation.flink.source.BaseSeaTunnelSourceFunction -
Consumer subtask 1 has no restore state.
2023-05-23 13:42:53,695 INFO org.apache.flink.runtime.taskmanager.Task -
Sink Global Committer: Hive (1/1)#0 (66e840af77041a0bf46fcb8f45152738) switched
from INITIALIZING to RUNNING.
2023-05-23 13:42:53,695 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink Global Committer:
Hive (1/1) (66e840af77041a0bf46fcb8f45152738) switched from INITIALIZING to
RUNNING.
2023-05-23 13:42:53,702 INFO
org.apache.seatunnel.connectors.seatunnel.file.source.split.FileSourceSplitEnumerator
- SubTask 0 is assigned to []
2023-05-23 13:42:53,702 INFO
org.apache.seatunnel.connectors.seatunnel.file.source.split.FileSourceSplitEnumerator
- SubTask 1 is assigned to
[hdfs://dbnode1:8020/user/hive/warehouse/test3/000000_0,hdfs://dbnode1:8020/user/hive/warehouse/test3/000000_0_copy_1]
2023-05-23 13:42:53,702 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad) switched from INITIALIZING to
RUNNING.
2023-05-23 13:42:53,702 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c) switched from INITIALIZING to
RUNNING.
2023-05-23 13:42:53,702 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2) (31359d2ed974bb20cead85704a64edad) switched from INITIALIZING to RUNNING.
2023-05-23 13:42:53,703 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2) (4b5a302f6e0b123846bf1e85b928484c) switched from INITIALIZING to RUNNING.
2023-05-23 13:42:53,707 INFO
org.apache.seatunnel.connectors.seatunnel.file.source.BaseFileSourceReader -
Closed the bounded File source
2023-05-23 13:42:53,728 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad) switched from RUNNING to FINISHED.
2023-05-23 13:42:53,728 INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 (31359d2ed974bb20cead85704a64edad).
2023-05-23 13:42:53,729 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2)#0 31359d2ed974bb20cead85704a64edad.
2023-05-23 13:42:53,732 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(1/2) (31359d2ed974bb20cead85704a64edad) switched from RUNNING to FINISHED.
2023-05-23 13:42:54,111 WARN
org.apache.seatunnel.connectors.seatunnel.file.sink.util.FileSystemUtils -
Principal [null] or keytabPath [null] is empty, it will skip kerberos
authentication
2023-05-23 13:42:54,370 INFO
org.apache.seatunnel.connectors.seatunnel.file.source.BaseFileSourceReader -
Closed the bounded File source
2023-05-23 13:42:54,471 INFO org.apache.flink.runtime.taskmanager.Task -
Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c) switched from RUNNING to FINISHED.
2023-05-23 13:42:54,471 INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for Source: SeaTunnel HiveSource ->
DataSteamToTable(stream=default_catalog.default_database.user, type=ROW<`name`
STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING, STRING>, `org`
ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL, rowtime=false,
watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 (4b5a302f6e0b123846bf1e85b928484c).
2023-05-23 13:42:54,472 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2)#0 4b5a302f6e0b123846bf1e85b928484c.
2023-05-23 13:42:54,473 INFO org.apache.flink.runtime.taskmanager.Task -
Sink Global Committer: Hive (1/1)#0 (66e840af77041a0bf46fcb8f45152738) switched
from RUNNING to FINISHED.
2023-05-23 13:42:54,473 INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for Sink Global Committer: Hive (1/1)#0
(66e840af77041a0bf46fcb8f45152738).
2023-05-23 13:42:54,474 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task Sink Global
Committer: Hive (1/1)#0 66e840af77041a0bf46fcb8f45152738.
2023-05-23 13:42:54,474 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: SeaTunnel
HiveSource -> DataSteamToTable(stream=default_catalog.default_database.user,
type=ROW<`name` STRING, `age` INT, `emails` ARRAY<STRING>, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Flat Map ->
DataSteamToTable(stream=default_catalog.default_database.user_1,
type=ROW<`name` STRING, `age` INT, `emails` STRING, `phones` MAP<STRING,
STRING>, `org` ROW<`CODE` STRING, `NAME` STRING, `TEL` STRING>> NOT NULL,
rowtime=false, watermark=false) -> SinkConversionToRow -> Sink Writer: Hive
(2/2) (4b5a302f6e0b123846bf1e85b928484c) switched from RUNNING to FINISHED.
2023-05-23 13:42:54,476 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager -
Received resource requirements from job c945b7989c0dec2a47540914a4224add:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=1}]
2023-05-23 13:42:54,476 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink Global Committer:
Hive (1/1) (66e840af77041a0bf46fcb8f45152738) switched from RUNNING to FINISHED.
2023-05-23 13:42:54,476 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job SeaTunnel
(c945b7989c0dec2a47540914a4224add) switched from state RUNNING to FINISHED.
2023-05-23 13:42:54,476 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:54,477 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager -
Clearing resource requirements of job c945b7989c0dec2a47540914a4224add
2023-05-23 13:42:54,479 INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
2023-05-23 13:42:54,483 INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
2023-05-23 13:42:54,483 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
c945b7989c0dec2a47540914a4224add reached terminal state FINISHED.
2023-05-23 13:42:54,483 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/rpc/taskmanager_0.
2023-05-23 13:42:54,483 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close ResourceManager
connection 46d7e67272305b4c02eecb50b4d68e9f.
2023-05-23 13:42:54,483 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
2023-05-23 13:42:54,484 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Stopping the JobMaster for job SeaTunnel(c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:54,484 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job c945b7989c0dec2a47540914a4224add.
2023-05-23 13:42:54,485 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Closing
TaskExecutor connection 752e7786-e966-4665-99c2-84b515a1d840 because: The
TaskExecutor is shutting down.
2023-05-23 13:42:54,486 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Free slot
TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes),
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=64.000mb
(67108864 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId:
a5dd28c25246b436b2fca7dcc4c0ae19, jobId: c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:54,487 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Free slot
TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes),
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=64.000mb
(67108864 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId:
754c9cbc71bf538f13150ed2fe05f47d, jobId: c945b7989c0dec2a47540914a4224add).
2023-05-23 13:42:54,488 INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool -
Releasing slot [a5dd28c25246b436b2fca7dcc4c0ae19].
2023-05-23 13:42:54,489 INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool -
Releasing slot [754c9cbc71bf538f13150ed2fe05f47d].
2023-05-23 13:42:54,489 INFO org.apache.flink.runtime.jobmaster.JobMaster -
Close ResourceManager connection 46d7e67272305b4c02eecb50b4d68e9f: Stopping
JobMaster for job SeaTunnel(c945b7989c0dec2a47540914a4224add)..
2023-05-23 13:42:54,490 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Stop job leader
service.
2023-05-23 13:42:54,490 INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
2023-05-23 13:42:54,491 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a8cd1d403ae1ffe3586b5f4e341641e8@akka://flink/user/rpc/jobmanager_3
for job c945b7989c0dec2a47540914a4224add from the resource manager.
2023-05-23 13:42:54,502 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory C:\Users\YANGPENG\AppData\Local\Temp\flink-web-ui
2023-05-23 13:42:54,503 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
2023-05-23 13:42:54,504 INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager
removed spill file directory
C:\Users\YANGPENG\AppData\Local\Temp\flink-io-af6b9277-7b75-4eba-8fa2-651a323777ff
2023-05-23 13:42:54,504 INFO
org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Shutting down the
network environment and its components.
2023-05-23 13:42:54,506 INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager
removed spill file directory
C:\Users\YANGPENG\AppData\Local\Temp\flink-netty-shuffle-d9e98fdb-11dd-46f7-a48b-5762aa07b022
2023-05-23 13:42:54,506 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Shut down
cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
2023-05-23 13:42:54,506 INFO
org.apache.flink.runtime.taskexecutor.KvStateService - Shutting down the
kvState service and its components.
2023-05-23 13:42:54,506 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService - Stop job leader
service.
2023-05-23 13:42:54,506 INFO
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
- Closing components.
2023-05-23 13:42:54,506 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess -
Stopping SessionDispatcherLeaderProcess.
2023-05-23 13:42:54,506 INFO org.apache.flink.runtime.filecache.FileCache -
removed file cache directory
C:\Users\YANGPENG\AppData\Local\Temp\flink-dist-cache-c109e3c1-29f8-4881-a49b-fb1f76f40eb5
2023-05-23 13:42:54,507 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/rpc/dispatcher_2.
2023-05-23 13:42:54,507 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/rpc/taskmanager_0.
2023-05-23 13:42:54,507 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_2.
2023-05-23 13:42:54,507 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager -
Closing the slot manager.
2023-05-23 13:42:54,507 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager -
Suspending the slot manager.
2023-05-23 13:42:54,507 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/rpc/dispatcher_2.
2023-05-23 13:42:54,508 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
2023-05-23 13:42:54,538 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
2023-05-23 13:42:54,539 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
2023-05-23 13:42:54,553 INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
2023-05-23 13:42:54,553 INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
2023-05-23 13:42:54,555 INFO org.apache.flink.runtime.blob.BlobServer -
Stopped BLOB server at 0.0.0.0:49872
2023-05-23 13:42:54,555 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
`
--
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]
