You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by "NickYoungPeng (via GitHub)" <gi...@apache.org> on 2023/05/23 05:44:08 UTC
[GitHub] [seatunnel] NickYoungPeng commented on issue #4809: [Bug] [seatunnel-connectors-v2] hive to hive is failed
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: commits-unsubscribe@seatunnel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org