[Bug] [seatunnel-connectors-v2] hive to hive is failed

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened
hive to hive ，the tartget table don't have data

SeaTunnel Version
2.3.1-release
SeaTunnel Config
`env {
  execution.parallelism = 2
  job.mode = "BATCH"
}

source {
  Hive {
    table_name = "default.test3"
    metastore_uri = "thrift://<IP_ADDRESS>:9083"
    result_table_name = "user"
  }
}

transform {
  Replace {
    source_table_name = "user"
    result_table_name = "user_1"
    replace_field = "emails"
    pattern = "qq"
    replacement = "163"
    is_regex = true
  }
}

sink {
  Hive {
    source_table_name = "user_1"
    table_name = "db_test_dev.test3"
    metastore_uri = "thrift://<IP_ADDRESS>:9083"
  }
}`

Running Command
run org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample.main()

Error Exception
not error Exception

Flink or Spark Version
No response
Java or Scala Version
No response
Screenshots
No response
Are you willing to submit PR?

[ ] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

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://<IP_ADDRESS>: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://<IP_ADDRESS>: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://<IP_ADDRESS>: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://<IP_ADDRESS>: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,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, 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, 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 <IP_ADDRESS>: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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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, 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<PHONE_NUMBER>88 bytes), taskOffHeapMemory=512.000gb<PHONE_NUMBER>88 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<PHONE_NUMBER>88 bytes), taskOffHeapMemory=512.000gb<PHONE_NUMBER>88 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 <IP_ADDRESS>:49872
2023-05-23 13:42:54,555 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
`

Can you provide details of the creation statement and test data?

Can you provide details of the creation statement and test data?

create table db_test_dev.test3
(
name   string,
age    int,
emails array,
phones map<string,string>,
org    structcode:string,name:string,tel:string
)
lisi,12,"[""zhangsan@qq.com"",""lisi@sohu.com"",""wangwu@sina.com""]","{""home"":""13987167117"",""office"":""15178968888""}","{""code"":""110000"",""name"":""中国银行北京分公司"",""tel"":""010-86678888""}"
lisi,12,"[""zhangsan@qq.com"",""lisi@sohu.com"",""wangwu@sina.com""]","{""home"":""13987167117"",""office"":""15178968888""}","{""code"":""110000"",""name"":""中国银行北京分公司"",""tel"":""010-86678888""}"

when I don't use 'result_table_name ' ,'transform','source_table_name '   .  it is ok

Can you provide details of the creation statement and test data?

create table db_test_dev.test3 ( name string, age int, emails array, phones map<string,string>, org structcode:string,name:string,tel:string )
lisi,12,"[""zhangsan@qq.com"",""lisi@sohu.com"",""wangwu@sina.com""]","{""home"":""13987167117"",""office"":""15178968888""}","{""code"":""110000"",""name"":""中国银行北京分公司"",""tel"":""010-86678888""}" lisi,12,"[""zhangsan@qq.com"",""lisi@sohu.com"",""wangwu@sina.com""]","{""home"":""13987167117"",""office"":""15178968888""}","{""code"":""110000"",""name"":""中国银行北京分公司"",""tel"":""010-86678888""}"

Can you convert to insert statement It looks so messy

> > Can you provide details of the creation statement and test data?
>
> create table db_test_dev.test3 ( name string, age int, emails array, phones map<string,string>, org structcode:string,name:string,tel:string )
>
> lisi,12,"[""[zhangsan@qq.com](mailto:zhangsan@qq.com)"",""[lisi@sohu.com](mailto:lisi@sohu.com)"",""[wangwu@sina.com](mailto:wangwu@sina.com)""]","{""home"":""13987167117"",""office"":""15178968888""}","{""code"":""110000"",""name"":""中国银行北京分公司"",""tel"":""010-86678888""}" lisi,12,"[""[zhangsan@qq.com](mailto:zhangsan@qq.com)"",""[lisi@sohu.com](mailto:lisi@sohu.com)"",""[wangwu@sina.com](mailto:wangwu@sina.com)""]","{""home"":""13987167117"",""office"":""15178968888""}","{""code"":""110000"",""name"":""中国银行北京分公司"",""tel"":""010-86678888""}"

Can you convert to insert statement It looks so messy
/
INSERT INTO db_test_dev.test3
select 'lisi',
12,
<EMAIL_ADDRESS><EMAIL_ADDRESS><EMAIL_ADDRESS>,
map("home", "13987167117", "office", "15178968888"),
named_struct('code', '110000', 'name', '中国银行北京分公司', 'tel',
'010-86678888')
from dummy_TBL
limit 1;

Can you provide a clearer creation sql DDL ?

Can you provide a clearer creation sql DDL ?

CREATE TABLE `default.test3`(
`name` string,
`age` int,
`emails` array<string>,
`phones` map<string,string>,
`org` struct<code:string,name:string,tel:string>)；

CREATE TABLE `db_test_dev.test3`(
`name` string,
`age` int,
`emails` array<string>,
`phones` map<string,string>,
`org` struct<code:string,name:string,tel:string>)；

just hava  result_table_name source_table_name is failed，like
{
env {
  execution.parallelism = 2
  job.mode = "BATCH"
}

source {
  Hive {
    table_name = "default.user1"
    metastore_uri = "thrift://<IP_ADDRESS>:9083"
  }
}
sink {
  Hive {
    source_table_name = "user"
    table_name = "db_test_dev.user2"
    metastore_uri = "thrift://<IP_ADDRESS>:9083"
  }
}

I'm trying to fix it,Please give me a moment


docs: do_lock ccn

Will squash and merge because a comment in issue #8 says it is resolved in this branch.


Odd setting in _grid.scss

Hey man,
I spotted this the other day, had a little look into it today and cannot work out why we have this. Possibly part of the sweeping changes made when mixinising everything.
In the grid.scss file we have settings for the grid and the last one is $mediumBreakpoint: m
That's linked to an @include media($mediumBreakpoint) which all seems super weird. Have you got any idea at all why we have this, or is it a mistake (i think it is, but unsure what it should be)
Cheers!

solved it! we are using it to change gutters etc. for tablets and up


Calling C Functions

In my opinion, the following typescript should transpile to the following C
TS:
printf("hello world\n");

C:
#include <stdio.h>

int main(void) {
    printf("hello world\n");
    return 0;
}

You may ask, why? well, That's because sometimes people will need/prefer to use functions from C (such as printf or file saving)

I agree!
With ts2c, you can actually create "target" projects that are tailored to a specific hardware target and contain all necessary definitions for this target, including printf or any other functions that exist on the target platform.
Example target project: https://github.com/andrei-markeev/ts2c-target-esp-idf
I don't think this behaviour should be "by default" because it's not a given that printf references the stdio.h function and not some js function from your code.


Added EMPD2 samples contributed by Jiménez-Moreno

Hi! I'm your friendly automated EMPD-admin bot!
Thank you very much for your data submission! I will now run some tests on your data.
In the meantime: please review your test data on the EMPD viewer using
this link: https://EMPD2.github.io/?repo=EMPD2/EMPD-data&branch=Jiménez-Moreno&meta="Jim\303\251nez-Moreno.tsv"
This bot is helping you merging your data. I am checking for common issues and I can fix your climate, country or elevation data.
Type @EMPD-admin help in a new comment in this PR for usage information.
Make sure, that all the commands for the @EMPD-admin are on one single line and nothing else. Only
@EMPD-admin help
will work, not something like
<other words> @EMPD-admin help
or
@EMPD-admin help <other words>
Note that you can also run these tests on your local machine with
pytest.

Hi! I'm your friendly automated EMPD-admin bot!
I found some errors in your data submission. You may fix some of them using the @EMPD-admin fix command.
Please ping @Chilipp if you have difficulties with your submission.
Critical tests..FAILED
Apparently the pytest command failed!
Full test report
============================= test session starts ==============================
platform linux -- Python 3.7.2, pytest-4.3.1, py-1.8.0, pluggy-0.9.0
rootdir: /opt/conda/lib/python3.7/site-packages/empd_admin/data/tests, inifile: pytest.ini
collected 37 items / 34 deselected / 3 selected
/opt/conda/lib/python3.7/site-packages/empd_admin/data/tests/test_critical.py EEE                          Traceback (most recent call last):
File "/opt/test-env/bin/pytest", line 11, in <module>
sys.exit(main())
File "/opt/test-env/lib/python3.7/site-packages/_pytest/config/__init__.py", line 79, in main
return config.hook.pytest_cmdline_main(config=config)
File "/opt/test-env/lib/python3.7/site-packages/pluggy/hooks.py", line 289, in __call__
return self._hookexec(self, self.get_hookimpls(), kwargs)
File "/opt/test-env/lib/python3.7/site-packages/pluggy/manager.py", line 68, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "/opt/test-env/lib/python3.7/site-packages/pluggy/manager.py", line 62, in <lambda>
firstresult=hook.spec.opts.get("firstresult") if hook.spec else False,
File "/opt/test-env/lib/python3.7/site-packages/pluggy/callers.py", line 208, in _multicall
return outcome.get_result()
File "/opt/test-env/lib/python3.7/site-packages/pluggy/callers.py", line 80, in get_result
raise ex[1].with_traceback(ex[2])
File "/opt/test-env/lib/python3.7/site-packages/pluggy/callers.py", line 187, in _multicall
res = hook_impl.function(*args)
File "/opt/test-env/lib/python3.7/site-packages/_pytest/main.py", line 242, in pytest_cmdline_main
return wrap_session(config, _main)
File "/opt/test-env/lib/python3.7/site-packages/_pytest/main.py", line 235, in wrap_session
session=session, exitstatus=session.exitstatus
File "/opt/test-env/lib/python3.7/site-packages/pluggy/hooks.py", line 289, in __call__
return self._hookexec(self, self.get_hookimpls(), kwargs)
File "/opt/test-env/lib/python3.7/site-packages/pluggy/manager.py", line 68, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "/opt/test-env/lib/python3.7/site-packages/pluggy/manager.py", line 62, in <lambda>
firstresult=hook.spec.opts.get("firstresult") if hook.spec else False,
File "/opt/test-env/lib/python3.7/site-packages/pluggy/callers.py", line 203, in _multicall
gen.send(outcome)
File "/opt/test-env/lib/python3.7/site-packages/_pytest/terminal.py", line 650, in pytest_sessionfinish
outcome.get_result()
File "/opt/test-env/lib/python3.7/site-packages/pluggy/callers.py", line 80, in get_result
raise ex[1].with_traceback(ex[2])
File "/opt/test-env/lib/python3.7/site-packages/pluggy/callers.py", line 187, in _multicall
res = hook_impl.function(*args)
File "/opt/conda/lib/python3.7/site-packages/empd_admin/data/tests/conftest.py", line 289, in pytest_sessionfinish
meta = _meta()
File "/opt/conda/lib/python3.7/site-packages/empd_admin/data/tests/conftest.py", line 29, in _meta
ret = pd.read_csv(str(fname), sep='\t', index_col='SampleName')
File "/opt/test-env/lib/python3.7/site-packages/pandas/io/parsers.py", line 702, in parser_f
return _read(filepath_or_buffer, kwds)
File "/opt/test-env/lib/python3.7/site-packages/pandas/io/parsers.py", line 429, in _read
parser = TextFileReader(filepath_or_buffer, **kwds)
File "/opt/test-env/lib/python3.7/site-packages/pandas/io/parsers.py", line 895, in __init__
self._make_engine(self.engine)
File "/opt/test-env/lib/python3.7/site-packages/pandas/io/parsers.py", line 1122, in _make_engine
self._engine = CParserWrapper(self.f, **self.options)
File "/opt/test-env/lib/python3.7/site-packages/pandas/io/parsers.py", line 1853, in __init__
self._reader = parsers.TextReader(src, **kwds)
File "pandas/_libs/parsers.pyx", line 387, in pandas._libs.parsers.TextReader.__cinit__
File "pandas/_libs/parsers.pyx", line 705, in pandas._libs.parsers.TextReader._setup_parser_source
FileNotFoundError: [Errno 2] File b'data/"Jim\\303\\251nez-Moreno.tsv"' does not exist: b'data/"Jim\\303\\251nez-Moreno.tsv"'

Hi! I'm your friendly automated EMPD-admin bot!
Thank you very much for your data submission! I will now run some tests on your data.
In the meantime: please review your test data on the EMPD viewer using
this link: https://EMPD2.github.io/?repo=EMPD2/EMPD-data&branch=Jiménez-Moreno&meta=Jimenez-Moreno.tsv
This bot is helping you merging your data. I am checking for common issues and I can fix your climate, country or elevation data.
Type @EMPD-admin help in a new comment in this PR for usage information.
Make sure, that all the commands for the @EMPD-admin are on one single line and nothing else. Only
@EMPD-admin help
will work, not something like
<other words> @EMPD-admin help
or
@EMPD-admin help <other words>
Note that you can also run these tests on your local machine with
pytest.

Hi! I'm your friendly automated EMPD-admin bot!
This is just to inform you that I tested your data submission in your PR (Jimenez-Moreno.tsv) and found it in an excellent condition!

@EMPD-admin finish --commit

Hi! I'm your friendly automated EMPD-admin bot!
I processed your command and hope that I can help you!

finish --commit

Finished the PR!
You may want to have a final look into the viewer (https://EMPD2.github.io/?repo=EMPD2/EMPD-data&branch=Jiménez-Moreno) and then merge it.


Call to download() results in zero sized files

Hello!
When using the latest version of easywebdav,
easywebdav 1.0.7
requests 1.1.0
webdav server: mod_dav, apache2
ubuntu 12.10
I have a problem using downloading files. When doing a download (by calling the download() method), the file is created on the local machine with the correct name, but the file is empty (zero size).
When looking at the code I can see response.raw is used as an input to shutil.copyfileobj(). However, I think that the documentation for requests states that 'stream=True' must be used in the call to session.request for .raw to be valid (http://docs.python-requests.org/en/latest/api/):
"raw = None
File-like object representation of response (for advanced usage).
Requires that 'stream=True' on the request."
I have tried setting stream=True (line 77 in client.py). and the received file then contains data! However, when looking at the header I can see that my webdav server gzip'ing the files, so the files downloaded have to be unszipped.

*** client-new.py	2013-02-20 08:27:29.941967542 +0100
--- client-org.py	2013-02-18 14:17:59.114443000 +0100
***************
*** 76,78 ****
          url = self._get_url(path)
!         response = self.session.request(method, url, allow_redirects=False, stream=True, **kwargs)
          if isinstance(expected_code, Number) and response.status_code != expected_code \
--- 76,78 ----
          url = self._get_url(path)
!         response = self.session.request(method, url, allow_redirects=False, **kwargs)
          if isinstance(expected_code, Number) and response.status_code != expected_code \

To get around this problem I have just uncommented the 'f.write(response.content)' on line 126 in client.py (and added a comment to 'shutil.copyfileobj(response.raw, f)' on line 127).
As far as I can see using response.raw and something like shutil.copyfileobj() is however necessary to be able to download really large files.

Works for me with
requests==2.7.0
easywebdav==1.2.0
python==2.7.10

This worked for me:
            response.raw.decode_content = True
            shutil.copyfileobj(response.raw, out_file)

because
 the response.raw file-like object will not, by default, decode compressed responses (with GZIP or deflate). You can force it to decompress for you anyway by setting the decode_content attribute to True

ref:
https://www.codementor.io/tips/3443978201/how-to-download-image-using-requests-in-python


fix(example): move python code into main

python multiprocessing code need to run in __main__

in what case does this change something?

https://stackoverflow.com/questions/74530990/how-to-run-multiprocessing-pool-code-in-python-without-mentioning-main-envir apparently that's useful only in windows
I don't think img2dataset really works in windows anyway
do you have another use case?

Have you tested that on Linux? I run this example script on Linux and got the error seems like https://github.com/rom1504/img2dataset/issues/176. After I put this code snippet into __main__, it works.

Yes it works for me.
What distribution are you using?
On Sun, Oct 8, 2023, 12:22 PM Junjie @.***> wrote:

Have you tested that on Linux? I run this example script on Linux and got
the error seems like #176
https://github.com/rom1504/img2dataset/issues/176. After I put this
code snippet into main, it works.
—
Reply to this email directly, view it on GitHub
https://github.com/rom1504/img2dataset/pull/350#issuecomment-1751916133,
or unsubscribe
https://github.com/notifications/unsubscribe-auth/AAR437STCVV37HHWEG2BJLDX6ITAXAVCNFSM6AAAAAA5HDPYXGVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHMYTONJRHEYTMMJTGM
.
You are receiving this because you commented.Message ID:
@.***>

default multiprocessing

ah I meant what linux distribution

Ubuntu 18.04.3 LTS


PoH - Reserve Space

Problem

In transaction processing, one of the main bottlenecks for simple transactions (such as in bench-tps) is recording transactions into PoH.
The reason this is slow is because of the communication pattern between execution and poh threads:

execution thread sends message to poh thread
poh thread, occasionally checks channel for messages from execution threads
records any messages from execution threads in order and sends messages back

The slowness mainly comes from the fact that the poh thread does not constantly check the channel from execution threads. It only does so at specific intervals between hash batches. By default the poh thread will do 64 hashes between each checking of the channel (only hashing if channel is empty).

Assuming cluster average hash-rate of 10M hashes/sec. This means the interval of checking the channel is around 6.4us.
Proposed Solution

Create a mechanism for execution threads to "reserve" poh space.
Reserve should not fail if there is still time left in the block, poh wise.
Before the block ends, poh thread will "flip a bit" to prevent any further reservations, and then record all messages before the last tick is inserted.
This will allow execution threads to more quickly move on, since they do not need to wait for the actual recording into poh to occur - just the "reserve" operation.

Need to compare alternate implementations:

Atomic using CAS for reserve mechanism
Mutex for reserve mechanism

oh, i think this can be solved more elegantly just with https://github.com/crossbeam-rs/crossbeam/pull/959 (cc @behzadnouri; he also came up with the similar idea: https://github.com/crossbeam-rs/crossbeam/issues/861)
the idea is that we can guarantee block insertion just just from the simple fact of succeeding in (one-sided) sending to the poh thread. so, no need to wait replies from the poh thread.
that said, that upstream pr is kind of stale. we can patch the crossbeam-channel or just wrap the crossbeam channel with mutex (ugh).

the idea is that we can guarantee block insertion just just from the simple fact of succeeding in (one-sided) sending to the poh thread. so, no need to wait replies from the poh thread.

Exactly, the whole point of this issue is to have this guarantee.
If we can achieve that in another than suggested, I'm happy.
I'm not sure I understand the suggestion w/ crossbeam though. At least currently we use the same channel to send to poh thread throughout the lifetime; do you mean use the disconnect approach, and need to swap out channels for every new slot?

do you mean use the disconnect approach, and need to swap out channels for every new slot?

exactly. so that senders can be notified about end of slots.

Yeah that seems like an approach that'd work.
I think Mutex-wrapping the channels is not an option.
Is there any expected timeline on those upstream PRs? they seem to have been there for quite a long time.

I think Mutex-wrapping the channels is not an option.

Well, I think we need some bench to preclude that. Now that Mutex is futex-based, it's not so different from having another crossbeam channel. I'm not saying this is a permanent solution, though. Also, come to think of it, RwLock could be used to mitigate contentions among the external (i.e. tx-sending) threads, because it's guaranteed that there's the single receiver.

Is there any expected timeline on those upstream PRs? they seem to have been there for quite a long time.

Sadly, none. Seems the maintainer is too busy... I'm replying as fast as i can.
At this moment, i think patching or forking makes sense.
So, ultimately, which solution (reserve, Mutex, or disconnect) to be taken could largely depends on the enginener's preference, i guess. Fortunately, this isn't consensus change and the change is quite localized. so, relatively easy to switch the solutions.

Also, come to think of it, RwLock could be used to mitigate contentions among the external (i.e. tx-sending) threads, because it's guaranteed that there's the single receiver.

My main contention with mutex was blocking of execution threads by other execution threads.
However, even with using a RwLock the execution threads will be blocked by the recording thread.
I guess I'm also not quite sure how this approach would work. In crossbeam the Sender and Receiver are separate objects/types - a lock around the Receiver would not affect the Sender afaik - unless we do some sort of Channel wrapper that holds the lock around both.

However, even with using a RwLock the execution threads will be blocked by the recording thread.

recording thread will only write-lock at the end of slots. But as said below, use of RwLock is awkward.

I guess I'm also not quite sure how this approach would work. In crossbeam the Sender and Receiver are separate objects/types

ohh, true.

a lock around the Receiver would not affect the Sender afaik

this is true as well

unless we do some sort of Channel wrapper that holds the lock around both.

Yeah, that works. but it's odd even more. Instead, I think we need is_reached_max_height: Arc<RwLock<bool>> besides senders/receivers. i.e. an indirect way to create a critical section by accompanying this synchronization along with them at the cost of losing type safety to some extent. this is like insert_shreds_lock: Mutex<()> in solana-ledger.

Instead, I think we need is_reached_max_height: Arc<RwLock<bool>> besides senders/receivers. i.e. an indirect way to create a critical section by accompanying this synchronization along with them

I created such a wrapper: https://gist.github.com/ryoqun/80adbd49c1658812b47fcf35bacb058f

further update: I created revamped pr upstream: https://github.com/crossbeam-rs/crossbeam/pull/1114

Reviewing this, I think we still need/want some reserve method instead. We currently return the transaction index w/ the result of recording which the worker threads use for something(?).
I'm imaginging we could do something like having a Mutex<Option<usize>> or AtomicI64.
Use lock or CAS to get the current index for the batch we're recording, if it's None or negative then we consider the recording to fail.

The slowness mainly comes from the fact that the poh thread does not constantly check the channel from execution threads. It only does so at specific intervals between hash batches. By default the poh thread will do 64 hashes between each checking of the channel (only hashing if channel is empty).

I think the slowness comes from the fact that when the poh thread sends results back, the banking threads are always sleeping so it needs to syscall to wake them up. Ban syscalls.

I think the slowness comes from the fact that when the poh thread sends results back, the banking threads are always sleeping so it needs to syscall to wake them up. Ban syscalls.

Yeah. those threads are always sleeping.
Communication should be "largely" one way. Workers send to stuff to PoH, but get back immediately as part of send process the info it needs to continue.
No messages from PoH, just something to flag the end of slot so banks dont' record past end of slot.

This sounds like a fixed capacity ringbuffer with head and tail that can advance independently without contention

This sounds like a fixed capacity ringbuffer with head and tail that can advance independently without contention

yeah ideally we could have some sort of ring-buffer, large enough we expect to never fail to insert.
still need a way to communicate "slot is over" to workers, as well as the transaction_index stuff that's used for something.


Add support for .NET 9 and support for disabling IMDS v1

Issue #, if available:
https://github.com/aws/aws-dotnet-deploy/issues/877
Description of changes:
EC2 made a change that new accounts created after Oct 1 2024. This means today if an account created after Oct 1st tries to deploy to Beanstalk using our tooling it will fail because it can't create a LaunchConfiguration.
To force Beanstalk you need to set one of the following 4 settings.

RootVolumeType
BlockDeviceMappings
DisableIMDSv1 -> true
EnableSpot
(For reference the Beantalk Developer Guide: https://docs.aws.amazon.com/elasticbeanstalk/latest/dg/environments-cfg-autoscaling-launch-templates.html)

None of these setting are currently settable in the tooling. Ideally we should add support for now I added DisableIMDSv1. The other settings require more settings to be set when enabled and there isn't an obvious default.
The  DisableIMDSv1 is a boolean property but we have to be careful not to automatically set this to true on existing environments when users do a redeployment. That could break environments. The compromise I did was modeled the property as 3 state value: Enabled, Disabled and Default.
The Default value is the the default for the new setting in the recipe. Using Default means in the CDK project to set DisableIMDSv1 for new deployments but for redeployments leave the setting alone. That way existing users when they upgrade to the new version of the tooling no change will be made to their environments when they redeploy. This required adding metadata being passed into the CDK project whether it was being run for a new deployment or not.
I decided to make the changes to add .NET 9 support while I was waiting for test deployments to finish. The change was just to add the .NET 9 target in the recipe rules files and update the docker manifest.
Testing
I have run all of the unit and integ tests. Before making any changes I created a new AWS account and reproduced the failure situation. After making the changes I was able to do deployments and redeployments with both my old account and new account. I also ran through .NET 9 deployments.
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

Could you also add a change file to this PR?


Crossing over some days causes number of days to be a decimal

Describe the bug
When showing the number of days it shows a decimal number of days over March 8th-9th 2019.
To Reproduce
Steps to reproduce the behaviour:

Go to https://wakirin.github.io/Litepicker/
Click on the date picker on the right.
Navigate until you see March 2020
Select March 8th as the start date and mouse over March 9th
See error

Expected behaviour
The days should show 2 days not 1.95 days
Screenshot
https://prnt.sc/q6n7w8

Hi,
check v1.0.16.
Math.round added to the diff function if the unit is days.
https://github.com/wakirin/Litepicker/blob/c5c5a92a7f251c8d52bcba2a7fc1da0f138c5c54/src/datetime.ts#L308


Pothos::Archive does not portably encode size_t

The new Pothos::Archive system doesn't explicitly specify the length of size_t. This causes issues when networking across 32-bit and 64-bit platforms (e.g. between an AMD64 Windows PothosGui instance and an ARMv7 Linux PothosUtil proxy).
Notably, attempting to open a PothosGui instance that has a cached connection to an incompatible server will cause it to crash with the message "Exception: invalid map<K, T> key" due to the following sequence of events:

Line 37 of gui\HostExplorer\HostSelectionTable.cpp attempts to call Pothos::System::HostInfo::get on the remote server
Line 45 of lib\System\HostInfo.cpp attempts to deserialize the 4-byte size_t processorCount field of the HostInfo object received from the server as an 8-byte number, due to the different size of size_t on ARMv7 (32-bit) and AMD64 (64-bit).
The remainder of the serialized data is incorrectly parsed. Importantly, the 'tid' field follows the serialized object in the archive and is thus lost.
Line 82 of lib\Remote\RemoteProxy.cpp attempts to access the 'tid' argument of the deserialized RPC response, causing an std::out_of_range exception to be emitted.
The exception block surrounding Line 37 of gui\HostExplorer\HostSelectionTable.cpp does not catch this exception, and it bubbles to the Qt library where it causes a hard crash.

I'm unsure how to solve this without making breaking changes to Pothos::Archive, as I don't know of a way to differentiate size_t from it's implementing integer type via template magic (it appears to be typedef unsigned int size_t on ARMv7 GCC). I'm currently working around this by serializing all integers as 64-bit, but that's clearly not a good solution.

Yikes. So I was aware of this because I patched the old archive stuff with the boost portable archive from eos. In this rewrite, I always serialize long types as 64-bits because they can vary in size. I also thought that I was safe here for size_t because long or long long was always used for size_t. In this case its int on arm! whoops... so thanks for catching that.
Theres no way to actually check that the api user is passing in a size_t or an actual number thats of the same typedef. Because at the end of the day you just want to match it up with the same type or struct running on another machine.
I can think of two fixes off the top of my head. Serialize all ints as 64-bits like you said, or record the number of bytes in the number as part of the serialization data for all int, long, and long long types. That way the destination always knows exactly how many bytes to read out. Using an extra byte to communicate the size of the number isnt too bad, but I might want to review the std::vector<number> implementation so we arent wasting a lot of overhead packing the size in bytes for every element. Just thinking out loud..


Fix Jenkins CI shared lib regression

The timeoutMinutes was removed as part of the PR https://github.com/microsoft/openenclave/pull/1867.

bors r+


T1 Firearm Manufacturing

About the PR

Adds a new T1 technology to the Arsenal science discipline, which costs 8,000 points and enables fabrication of MK-58 and Inspector security sidearms to the security techfab, or to an emagged protolathe. MK-58 costs 15 steel, and five plastic, while the Inspector costs 10 steel, 5 plastic, 5 wood.
Why / Balance

Currently, MK-58s are only found through roundstart spawns or cargo's pistols crate, and the detective's Inspector cannot be recovered outside of roundstart. This technology will allow recovery of Detective's signature weapon, an alternative sidearm to the MK-58 later into the round, and an additional way to acquire more MK-58s outside of cargo. (Of course, this requires materials which can be more easily gained from cargo than a complete pistol crate, or from salvaging maints, and the willingness of Science to actually research the technology.) The point is a new source for Security's faithful sidearm and a way to get more revolvers.
Technical details

Slightly changed MK-58's description to match the fact that science can make them now
Added recipes for mk-58 and inspector
Added mk-58 and inspector recipes to security techfab and emagged protolathe
Updated technologies.ftl with name for tech
Added the actual technology into arsenal.yml
Media

Requirements

[x] I have read and am following the Pull Request and Changelog Guidelines.
[x] I have added media to this PR or it does not require an ingame showcase.

Breaking changes

Shouldn't be any, just YML changes
Changelog

:cl: Onezero0

add: Added T1 Firearm Manufacturing, which enables fabrication of MK-58 and Inspectors for Security!

In my opinion now we have pretty interesting choice between ways of refill of weapons. Cargo - for order letal weapons that uses ammo. R&D - for creating more situational but not less useful weapons such as lasers, grenades and shields. Adding MK in secfab ruins this balance.

In my opinion now we have pretty interesting choice between ways of refill of weapons. Cargo - for order letal weapons that uses ammo. R&D - for creating more situational but not less useful weapons such as lasers, grenades and shields. Adding MK in secfab ruins this balance.

Not necessarily, because both roads lead to cargo. The way Security actually makes science’s weapons is through materials (gained from cargo one way or another during SOP, save for scrapping maints, which is much less effective.) Thus letting security make mk-58s through fabrication just lets science help sec get new sidearms more easily by asking cargo for materials, rather than asking for a specific weapons box repeatedly for (sometimes) half a shift.
(Don’t forget that cargo can also purchase the laser crate, which draws a nice parallel with this tech)

personally I think the inspector should be roundstart only, and let det keep their unique gun

Ah, true, this seems to be heading in the Svalinn direction - I will leave the PR open but I doubt it will be merged, considering these arguments. Thanks for the feedback!

I think shifting crews guns to be MORE kinetic instead of lasers makes it harder for syndicate and nukies to counter and creates a balance issue


404 when trying to send traces to apollo server

Hi
I've successfully enabled the gem, I'll probably add a PR to update the readme with small changes to make it easy to integrate, specially which environment variables to use.
Secondly, when I try to send traces to the apollo studio, I see a 404. I know I'm doing everything right. Pasting the code snippet which I used to enable the plugin.
in the context
apollo_tracing_enabled: true,
apollo_client_name: "test",
apollo_client_version: "1.0",

As part of the schema
use(ApolloStudioTracing, compress: true, debug_reports: true)

The environment variables I've set
ENGINE_API_KEY=service:****
ENGINE_SCHEMA_TAG=****@****

This is the response I get
[Apollo Studio Tracing] Failed to send trace report: Not Found (404) - 404: Not Found

An update on this, I tried create a very small server on node.js using the same keys, and the data is being sent without any errors. I think there something wrong with the report encoding part. I would highly appreciate if could get some help with this.

Hey @talal7860 - 404 (not found) indicates to me that it's (likely) not a malformed request. Are you sure your Ruby server and Node server have the same connectivity? Is your Ruby server sending any other requests that are successful?
Can you intercept the outgoing requests for both servers and compare them (with something like HTTP toolkit and share the results here?

Also which gem are you using? This fork appears to be unmaintained for multiple years now, whereas the original repo has seen updates in the last month. Does the issue belong over there / have you tried using the other gem?
https://github.com/Gusto/apollo-federation-ruby

@trevor-scheer you're right, I had no idea that the federation gem supported tracing, I'm going to try that but to give you an update on what was actually going wrong with this gem.

The proto file was outdated
Tried updating it with the latest proto file, but it has some dependencies which became a blocker to generate the ruby file.
Long story short, this gem doesn't work anymore.

I don't think the federation gem was designed to send traces to apollo-studio, they have enabled it so that the graphql-gateway can read that and send traces. I don't think so there's anything built for ruby to send traces directly to the studio. I'll try to play around with this gem, as this is the closest I'm looking for. The proto.rb file used in the federation gem is exactly what's being used in this gem. So it was kind of an extension to send traces directly to apollo studio. Either ways, thanks for your help @trevor-scheer


Incorporate creation of NuGet packages right into the build process

Review #731 once implemented.

To create NuGet package, all that is required as of v1.11 is to build the Solution in Release mode.
The .nupkg files will be automatically generated and added to the projects /bin/Release/ folder.


[bug]SubscribedClientsChanged，this callback function in Some Win10 Device did not work,for help

[在此处输入反馈]
[bug]SubscribedClientsChanged，this callback function in Some Win10 Device did not work,for help
but i use c# uwp it can work well, i dont know why

文档详细信息
⚠ 请勿编辑此部分。 docs.microsoft.com ➟ GitHub 问题链接必须具有此部分。

ID: b2b538d1-3288-1784-c8b0-f04989c2c1ea
Version Independent ID: 54774b5b-a1ec-d852-f51d-4f73f2c61579
Content: GattLocalCharacteristic.SubscribedClientsChanged Event (Windows.Devices.Bluetooth.GenericAttributeProfile) - Windows UWP applications
Content Source: winrt-api-build/xml/Windows.Devices.Bluetooth.GenericAttributeProfile/GattLocalCharacteristic.xml
Product: uwp
Technology: winrt-reference
GitHub Login: @stevewhims
Microsoft Alias: stwhi

Hi, @ShiverZm, and thanks for filing this issue. This doesn't sound like something I can help with by changing the information in this topic.
The feedback channel you're using here (Send feedback about > This page) is for feedback about the documentation in this topic. For example, if you believe that the documentation in this topic is incorrect, or that info needed to succeed with a common scenario is missing.
For questions (or requests for help) regarding a support-related matter, like this, one option is to click Send feedback about > This product, and you'll be taken to Microsoft Q&A (more info about that below).
Here are all of the developer support resources, for completeness.

Microsoft Q&A is the right place to lobby for a change or a new feature, to make a suggestion, or to ask a product question.
For community assistance with development questions, there are our forums, and StackOverflow.
The Windows developer support site explains other support options.
The Visual Studio developer community is available, and responsive. The former User Voice feature is now there on the Suggest a feature tab, if you want to lobby for a change, a feature, or to make a suggestion.
For developer issues, or suspected product bugs, there's Microsoft Support; a support engineer will look at the repro and see whether the issue is a Microsoft product bug, or something else. If it's a bug with a Microsoft product then the ticket will be free of charge.

I'll go ahead and close this issue now, since there's no action I can see to take in the documentation. You can always reply to a closed issue, or even re-open it if you feel it's been closed in error.
Thanks!
-Steve


You forgot to add your name to the license :)

Not a real issue, but you might want to add your name to the license file.
https://github.com/lloesche/valheim-server-docker/blob/main/LICENSE#L189

Thanks :)


Sample insufficiency in Sudan

While doing the research, I find that the number of samples chosen from Sudan was not sufficient and there was a lack of detailed description of the natural resources. I am confused about how to conduct an in-depth analysis into that.

I have to admit that the amount of data is only a few dozen cases in some years, but in the investigation of the consequences, I refer to more literature instead of just inferring from the data (because the detailed description of some samples is not enough. Information), and in the collection of documents, many documents about Sudan are enough to make some reasonable speculations. For example, In the research of Chad R. Wells et al, they claim A large number of conflicts have affected the prevention and control of local epidemics.

I think that for the exploration of data resulting from conflicts, if the database does not supplement the detailed description later, it is one of the most effective methods to check the relevant literature.