nql语句查询失败

  • nebula 版本:
  • 部署方式:分布式
  • 安装方式:源码编译
  • 是否为线上版本:Y
  • 硬件信息
    • 磁盘( 推荐使用 SSD)
    • CPU、内存信息 96核 384G
  • 问题的具体描述:语句执行单独执行是可以的,但是在Java程序里面执行不成功
  • 相关的 meta / storage / graph info 日志信息(尽量使用文本形式方便检索)
    语句单独执行成功:

在Java程序中执行报错:

相关代码:

详细日志:
Log Type: stderr
Log Upload Time: Tue Sep 20 14:13:38 +0800 2022
Log Length: 236457
22/09/20 09:58:36 INFO executor.CoarseGrainedExecutorBackend: Started daemon with process name: 102008@cdp22-s10b0409.prd.qizhidao.com
22/09/20 09:58:36 INFO util.SignalUtils: Registered signal handler for TERM
22/09/20 09:58:36 INFO util.SignalUtils: Registered signal handler for HUP
22/09/20 09:58:36 INFO util.SignalUtils: Registered signal handler for INT
22/09/20 09:58:36 INFO spark.SecurityManager: Changing view acls to: bigdata03
22/09/20 09:58:36 INFO spark.SecurityManager: Changing modify acls to: bigdata03
22/09/20 09:58:36 INFO spark.SecurityManager: Changing view acls groups to:
22/09/20 09:58:36 INFO spark.SecurityManager: Changing modify acls groups to:
22/09/20 09:58:36 INFO spark.SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(bigdata03); groups with view permissions: Set(); users with modify permissions: Set(bigdata03); groups with modify permissions: Set()
22/09/20 09:58:37 INFO client.TransportClientFactory: Successfully created connection to cdp12-s07b0408.prd.qizhidao.com/172.18.0.14:5212 after 70 ms (0 ms spent in bootstraps)
22/09/20 09:58:37 INFO deploy.SparkHadoopUtil: Updating delegation tokens for current user.
22/09/20 09:58:37 INFO spark.SecurityManager: Changing view acls to: bigdata03
22/09/20 09:58:37 INFO spark.SecurityManager: Changing modify acls to: bigdata03
22/09/20 09:58:37 INFO spark.SecurityManager: Changing view acls groups to:
22/09/20 09:58:37 INFO spark.SecurityManager: Changing modify acls groups to:
22/09/20 09:58:37 INFO spark.SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(bigdata03); groups with view permissions: Set(); users with modify permissions: Set(bigdata03); groups with modify permissions: Set()
22/09/20 09:58:37 INFO client.TransportClientFactory: Successfully created connection to cdp12-s07b0408.prd.qizhidao.com/172.18.0.14:5212 after 1 ms (0 ms spent in bootstraps)
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/4/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-b5ba8717-3803-4d49-be13-f9d91ed84e98
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/7/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-d0cdeae2-4048-4461-8c55-434a5a43ed13
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/11/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-9cb1fedc-2a11-4ab6-9c14-09323cf4ad98
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/2/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-a49b4bc6-cc0f-483d-b224-d899967649aa
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/9/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-2746c557-149c-4f22-b69b-a656c3c54b9b
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/8/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-3f2bbb45-b92f-4667-baaf-e50bc3809442
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/10/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-8a35084e-5271-49bd-9929-51e1b7bb5977
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/3/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-4bd423ea-fdf8-4546-a456-cc090aeca29b
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/1/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-2aad9cb4-0cc8-4cfd-bfa4-06947ecc80f7
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/5/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-2a980b74-d1da-464e-bd2f-1218b22a0f43
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/0/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-c6650f1e-b9b8-4c95-82e5-ab1a2a835115
22/09/20 09:58:37 INFO storage.DiskBlockManager: Created local directory at /data/6/yarn/nm/usercache/bigdata03/appcache/application_1652781743111_449569/blockmgr-8e616852-8d5a-4efa-98f2-6aea6792cc00
22/09/20 09:58:37 INFO memory.MemoryStore: MemoryStore started with capacity 4.1 GB
22/09/20 09:58:37 INFO executor.CoarseGrainedExecutorBackend: Connecting to driver: spark://CoarseGrainedScheduler@cdp12-s07b0408.prd.qizhidao.com:5212
22/09/20 09:58:37 INFO executor.CoarseGrainedExecutorBackend: Successfully registered with driver
22/09/20 09:58:37 INFO executor.Executor: Starting executor ID 18 on host cdp22-s10b0409.prd.qizhidao.com
22/09/20 09:58:37 INFO util.Utils: Successfully started service ‘org.apache.spark.network.netty.NettyBlockTransferService’ on port 22492.
22/09/20 09:58:37 INFO netty.NettyBlockTransferService: Server created on cdp22-s10b0409.prd.qizhidao.com:22492
22/09/20 09:58:37 INFO storage.BlockManager: Using org.apache.spark.storage.RandomBlockReplicationPolicy for block replication policy
22/09/20 09:58:37 INFO storage.BlockManagerMaster: Registering BlockManager BlockManagerId(18, cdp22-s10b0409.prd.qizhidao.com, 22492, None)
22/09/20 09:58:37 INFO storage.BlockManagerMaster: Registered BlockManager BlockManagerId(18, cdp22-s10b0409.prd.qizhidao.com, 22492, None)
22/09/20 09:58:37 INFO storage.BlockManager: external shuffle service port = 7337
22/09/20 09:58:37 INFO storage.BlockManager: Registering executor with local external shuffle service.
22/09/20 09:58:37 INFO client.TransportClientFactory: Successfully created connection to cdp22-s10b0409.prd.qizhidao.com/172.18.0.24:7337 after 2 ms (0 ms spent in bootstraps)
22/09/20 09:58:37 INFO storage.BlockManager: Initialized BlockManager: BlockManagerId(18, cdp22-s10b0409.prd.qizhidao.com, 22492, None)
22/09/20 09:59:04 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1686
22/09/20 09:59:04 INFO executor.Executor: Running task 15.0 in stage 5.0 (TID 1686)
22/09/20 09:59:04 INFO spark.MapOutputTrackerWorker: Updating epoch to 3 and clearing cache
22/09/20 09:59:04 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 8
22/09/20 09:59:04 INFO client.TransportClientFactory: Successfully created connection to cdp12-s07b0408.prd.qizhidao.com/172.18.0.14:5861 after 1 ms (0 ms spent in bootstraps)
22/09/20 09:59:04 INFO memory.MemoryStore: Block broadcast_8_piece0 stored as bytes in memory (estimated size 7.6 KB, free 4.1 GB)
22/09/20 09:59:04 INFO broadcast.TorrentBroadcast: Reading broadcast variable 8 took 93 ms
22/09/20 09:59:04 INFO memory.MemoryStore: Block broadcast_8 stored as values in memory (estimated size 14.9 KB, free 4.1 GB)
22/09/20 09:59:05 INFO spark.MapOutputTrackerWorker: Don’t have map outputs for shuffle 3, fetching them
22/09/20 09:59:05 INFO spark.MapOutputTrackerWorker: Doing the fetch; tracker endpoint = NettyRpcEndpointRef(spark://MapOutputTracker@cdp12-s07b0408.prd.qizhidao.com:5212)
22/09/20 09:59:05 INFO spark.MapOutputTrackerWorker: Got the output locations
22/09/20 09:59:05 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:05 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 1 ms (0 ms spent in bootstraps)
22/09/20 09:59:05 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 17 ms
22/09/20 09:59:17 INFO codegen.CodeGenerator: Code generated in 240.116522 ms
22/09/20 09:59:17 INFO codegen.CodeGenerator: Code generated in 20.022492 ms
22/09/20 09:59:18 INFO codegen.CodeGenerator: Code generated in 61.741626 ms
22/09/20 09:59:18 INFO executor.Executor: Finished task 15.0 in stage 5.0 (TID 1686). 1834 bytes result sent to driver
22/09/20 09:59:18 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1734
22/09/20 09:59:18 INFO executor.Executor: Running task 63.0 in stage 5.0 (TID 1734)
22/09/20 09:59:18 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:18 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 09:59:20 INFO executor.Executor: Finished task 63.0 in stage 5.0 (TID 1734). 1748 bytes result sent to driver
22/09/20 09:59:20 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1738
22/09/20 09:59:20 INFO executor.Executor: Running task 67.0 in stage 5.0 (TID 1738)
22/09/20 09:59:20 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:20 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 09:59:23 INFO executor.Executor: Finished task 67.0 in stage 5.0 (TID 1738). 1748 bytes result sent to driver
22/09/20 09:59:23 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1748
22/09/20 09:59:23 INFO executor.Executor: Running task 77.0 in stage 5.0 (TID 1748)
22/09/20 09:59:23 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:23 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 09:59:25 INFO executor.Executor: Finished task 77.0 in stage 5.0 (TID 1748). 1748 bytes result sent to driver
22/09/20 09:59:25 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1753
22/09/20 09:59:25 INFO executor.Executor: Running task 82.0 in stage 5.0 (TID 1753)
22/09/20 09:59:26 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:26 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 09:59:41 INFO executor.Executor: Finished task 82.0 in stage 5.0 (TID 1753). 1791 bytes result sent to driver
22/09/20 09:59:41 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1770
22/09/20 09:59:41 INFO executor.Executor: Running task 99.0 in stage 5.0 (TID 1770)
22/09/20 09:59:41 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:41 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 2 ms
22/09/20 09:59:50 INFO executor.Executor: Finished task 99.0 in stage 5.0 (TID 1770). 1748 bytes result sent to driver
22/09/20 09:59:50 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1772
22/09/20 09:59:50 INFO executor.Executor: Running task 101.0 in stage 5.0 (TID 1772)
22/09/20 09:59:50 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 09:59:50 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:00:07 INFO executor.Executor: Finished task 101.0 in stage 5.0 (TID 1772). 1748 bytes result sent to driver
22/09/20 10:00:07 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1778
22/09/20 10:00:07 INFO executor.Executor: Running task 107.0 in stage 5.0 (TID 1778)
22/09/20 10:00:07 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:00:07 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:00:12 INFO executor.Executor: Finished task 107.0 in stage 5.0 (TID 1778). 1748 bytes result sent to driver
22/09/20 10:00:12 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1780
22/09/20 10:00:12 INFO executor.Executor: Running task 109.0 in stage 5.0 (TID 1780)
22/09/20 10:00:13 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:00:13 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:00:14 INFO executor.Executor: Finished task 109.0 in stage 5.0 (TID 1780). 1748 bytes result sent to driver
22/09/20 10:00:14 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1782
22/09/20 10:00:14 INFO executor.Executor: Running task 111.0 in stage 5.0 (TID 1782)
22/09/20 10:00:14 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:00:14 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:00:18 INFO executor.Executor: Finished task 111.0 in stage 5.0 (TID 1782). 1748 bytes result sent to driver
22/09/20 10:00:18 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1783
22/09/20 10:00:18 INFO executor.Executor: Running task 112.0 in stage 5.0 (TID 1783)
22/09/20 10:00:18 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:00:18 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:00:21 INFO executor.Executor: Finished task 112.0 in stage 5.0 (TID 1783). 1748 bytes result sent to driver
22/09/20 10:00:21 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1784
22/09/20 10:00:21 INFO executor.Executor: Running task 113.0 in stage 5.0 (TID 1784)
22/09/20 10:00:21 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:00:21 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:01:44 INFO executor.Executor: Finished task 113.0 in stage 5.0 (TID 1784). 1748 bytes result sent to driver
22/09/20 10:01:44 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1821
22/09/20 10:01:44 INFO executor.Executor: Running task 150.0 in stage 5.0 (TID 1821)
22/09/20 10:01:44 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:01:44 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:07:59 INFO executor.Executor: Finished task 150.0 in stage 5.0 (TID 1821). 1748 bytes result sent to driver
22/09/20 10:07:59 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1897
22/09/20 10:07:59 INFO executor.Executor: Running task 226.0 in stage 5.0 (TID 1897)
22/09/20 10:07:59 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:07:59 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:07:59 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 5 ms (0 ms spent in bootstraps)
22/09/20 10:07:59 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 7 ms
22/09/20 10:08:02 INFO executor.Executor: Finished task 226.0 in stage 5.0 (TID 1897). 1748 bytes result sent to driver
22/09/20 10:08:02 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1898
22/09/20 10:08:02 INFO executor.Executor: Running task 227.0 in stage 5.0 (TID 1898)
22/09/20 10:08:02 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:08:02 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:08:08 INFO executor.Executor: Finished task 227.0 in stage 5.0 (TID 1898). 1748 bytes result sent to driver
22/09/20 10:08:08 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 1902
22/09/20 10:08:08 INFO executor.Executor: Running task 231.0 in stage 5.0 (TID 1902)
22/09/20 10:08:09 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:08:09 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:15:29 INFO executor.Executor: Finished task 231.0 in stage 5.0 (TID 1902). 1748 bytes result sent to driver
22/09/20 10:15:29 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2023
22/09/20 10:15:29 INFO executor.Executor: Running task 352.0 in stage 5.0 (TID 2023)
22/09/20 10:15:29 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:15:29 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:15:29 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 2 ms (0 ms spent in bootstraps)
22/09/20 10:15:29 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 4 ms
22/09/20 10:17:20 INFO executor.Executor: Finished task 352.0 in stage 5.0 (TID 2023). 1791 bytes result sent to driver
22/09/20 10:17:20 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2043
22/09/20 10:17:20 INFO executor.Executor: Running task 372.0 in stage 5.0 (TID 2043)
22/09/20 10:17:20 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:17:20 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 2 ms
22/09/20 10:17:22 INFO executor.Executor: Finished task 372.0 in stage 5.0 (TID 2043). 1748 bytes result sent to driver
22/09/20 10:17:22 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2045
22/09/20 10:17:22 INFO executor.Executor: Running task 374.0 in stage 5.0 (TID 2045)
22/09/20 10:17:23 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:17:23 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 3 ms
22/09/20 10:17:24 INFO executor.Executor: Finished task 374.0 in stage 5.0 (TID 2045). 1791 bytes result sent to driver
22/09/20 10:17:24 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2046
22/09/20 10:17:24 INFO executor.Executor: Running task 375.0 in stage 5.0 (TID 2046)
22/09/20 10:17:25 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:17:25 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:17:27 INFO executor.Executor: Finished task 375.0 in stage 5.0 (TID 2046). 1748 bytes result sent to driver
22/09/20 10:17:27 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2048
22/09/20 10:17:27 INFO executor.Executor: Running task 377.0 in stage 5.0 (TID 2048)
22/09/20 10:17:27 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:17:27 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 2 ms
22/09/20 10:17:31 INFO executor.Executor: Finished task 377.0 in stage 5.0 (TID 2048). 1748 bytes result sent to driver
22/09/20 10:17:31 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2051
22/09/20 10:17:31 INFO executor.Executor: Running task 380.0 in stage 5.0 (TID 2051)
22/09/20 10:17:31 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:17:31 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:30:09 INFO executor.Executor: Finished task 380.0 in stage 5.0 (TID 2051). 1748 bytes result sent to driver
22/09/20 10:30:09 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2248
22/09/20 10:30:09 INFO executor.Executor: Running task 577.0 in stage 5.0 (TID 2248)
22/09/20 10:30:09 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:09 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:30:09 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 1 ms (0 ms spent in bootstraps)
22/09/20 10:30:09 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 3 ms
22/09/20 10:30:13 INFO executor.Executor: Finished task 577.0 in stage 5.0 (TID 2248). 1748 bytes result sent to driver
22/09/20 10:30:13 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2250
22/09/20 10:30:13 INFO executor.Executor: Running task 579.0 in stage 5.0 (TID 2250)
22/09/20 10:30:13 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:13 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:30:33 INFO executor.Executor: Finished task 579.0 in stage 5.0 (TID 2250). 1748 bytes result sent to driver
22/09/20 10:30:33 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2260
22/09/20 10:30:33 INFO executor.Executor: Running task 589.0 in stage 5.0 (TID 2260)
22/09/20 10:30:33 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:33 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:30:35 INFO executor.Executor: Finished task 589.0 in stage 5.0 (TID 2260). 1748 bytes result sent to driver
22/09/20 10:30:35 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2262
22/09/20 10:30:35 INFO executor.Executor: Running task 591.0 in stage 5.0 (TID 2262)
22/09/20 10:30:35 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:35 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:30:40 INFO executor.Executor: Finished task 591.0 in stage 5.0 (TID 2262). 1748 bytes result sent to driver
22/09/20 10:30:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2264
22/09/20 10:30:40 INFO executor.Executor: Running task 593.0 in stage 5.0 (TID 2264)
22/09/20 10:30:40 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:40 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:30:43 INFO executor.Executor: Finished task 593.0 in stage 5.0 (TID 2264). 1748 bytes result sent to driver
22/09/20 10:30:43 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2267
22/09/20 10:30:43 INFO executor.Executor: Running task 596.0 in stage 5.0 (TID 2267)
22/09/20 10:30:43 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:43 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:30:45 INFO executor.Executor: Finished task 596.0 in stage 5.0 (TID 2267). 1748 bytes result sent to driver
22/09/20 10:30:45 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2268
22/09/20 10:30:45 INFO executor.Executor: Running task 597.0 in stage 5.0 (TID 2268)
22/09/20 10:30:45 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:30:45 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:31:08 INFO executor.Executor: Finished task 597.0 in stage 5.0 (TID 2268). 1748 bytes result sent to driver
22/09/20 10:31:08 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2279
22/09/20 10:31:08 INFO executor.Executor: Running task 608.0 in stage 5.0 (TID 2279)
22/09/20 10:31:08 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:31:08 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:31:26 INFO executor.Executor: Finished task 608.0 in stage 5.0 (TID 2279). 1791 bytes result sent to driver
22/09/20 10:31:26 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2289
22/09/20 10:31:26 INFO executor.Executor: Running task 618.0 in stage 5.0 (TID 2289)
22/09/20 10:31:26 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:31:26 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:31:28 INFO executor.Executor: Finished task 618.0 in stage 5.0 (TID 2289). 1748 bytes result sent to driver
22/09/20 10:31:28 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2290
22/09/20 10:31:28 INFO executor.Executor: Running task 619.0 in stage 5.0 (TID 2290)
22/09/20 10:31:28 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:31:28 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:33:35 INFO executor.Executor: Finished task 619.0 in stage 5.0 (TID 2290). 1748 bytes result sent to driver
22/09/20 10:33:35 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2311
22/09/20 10:33:35 INFO executor.Executor: Running task 640.0 in stage 5.0 (TID 2311)
22/09/20 10:33:35 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:33:35 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:33:35 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 1 ms (0 ms spent in bootstraps)
22/09/20 10:33:35 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 3 ms
22/09/20 10:33:38 INFO executor.Executor: Finished task 640.0 in stage 5.0 (TID 2311). 1748 bytes result sent to driver
22/09/20 10:33:38 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2312
22/09/20 10:33:38 INFO executor.Executor: Running task 641.0 in stage 5.0 (TID 2312)
22/09/20 10:33:38 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:33:38 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:34:09 INFO executor.Executor: Finished task 641.0 in stage 5.0 (TID 2312). 1748 bytes result sent to driver
22/09/20 10:34:09 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2314
22/09/20 10:34:09 INFO executor.Executor: Running task 643.0 in stage 5.0 (TID 2314)
22/09/20 10:34:09 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:34:09 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:34:11 INFO executor.Executor: Finished task 643.0 in stage 5.0 (TID 2314). 1748 bytes result sent to driver
22/09/20 10:34:11 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2315
22/09/20 10:34:11 INFO executor.Executor: Running task 644.0 in stage 5.0 (TID 2315)
22/09/20 10:34:11 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:34:11 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:34:13 INFO executor.Executor: Finished task 644.0 in stage 5.0 (TID 2315). 1748 bytes result sent to driver
22/09/20 10:34:13 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2316
22/09/20 10:34:13 INFO executor.Executor: Running task 645.0 in stage 5.0 (TID 2316)
22/09/20 10:34:13 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:34:13 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:34:15 INFO executor.Executor: Finished task 645.0 in stage 5.0 (TID 2316). 1748 bytes result sent to driver
22/09/20 10:34:15 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2319
22/09/20 10:34:15 INFO executor.Executor: Running task 648.0 in stage 5.0 (TID 2319)
22/09/20 10:34:15 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:34:15 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:36:24 INFO executor.Executor: Finished task 648.0 in stage 5.0 (TID 2319). 1748 bytes result sent to driver
22/09/20 10:36:24 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2375
22/09/20 10:36:24 INFO executor.Executor: Running task 704.0 in stage 5.0 (TID 2375)
22/09/20 10:36:24 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:36:24 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:36:24 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 2 ms (0 ms spent in bootstraps)
22/09/20 10:36:24 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 12 ms
22/09/20 10:38:16 INFO executor.Executor: Finished task 704.0 in stage 5.0 (TID 2375). 1748 bytes result sent to driver
22/09/20 10:38:16 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2393
22/09/20 10:38:16 INFO executor.Executor: Running task 722.0 in stage 5.0 (TID 2393)
22/09/20 10:38:16 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:38:16 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:38:23 INFO executor.Executor: Finished task 722.0 in stage 5.0 (TID 2393). 1748 bytes result sent to driver
22/09/20 10:38:23 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2397
22/09/20 10:38:23 INFO executor.Executor: Running task 726.0 in stage 5.0 (TID 2397)
22/09/20 10:38:23 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:38:23 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:38:25 INFO executor.Executor: Finished task 726.0 in stage 5.0 (TID 2397). 1748 bytes result sent to driver
22/09/20 10:38:25 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2399
22/09/20 10:38:25 INFO executor.Executor: Running task 728.0 in stage 5.0 (TID 2399)
22/09/20 10:38:26 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:38:26 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:40:57 INFO executor.Executor: Finished task 728.0 in stage 5.0 (TID 2399). 1748 bytes result sent to driver
22/09/20 10:40:57 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2421
22/09/20 10:40:57 INFO executor.Executor: Running task 750.0 in stage 5.0 (TID 2421)
22/09/20 10:40:58 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:40:58 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:40:58 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 1 ms (0 ms spent in bootstraps)
22/09/20 10:40:58 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 3 ms
22/09/20 10:41:02 INFO executor.Executor: Finished task 750.0 in stage 5.0 (TID 2421). 1748 bytes result sent to driver
22/09/20 10:41:02 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2422
22/09/20 10:41:02 INFO executor.Executor: Running task 751.0 in stage 5.0 (TID 2422)
22/09/20 10:41:02 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:41:02 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:41:03 INFO executor.Executor: Finished task 751.0 in stage 5.0 (TID 2422). 1748 bytes result sent to driver
22/09/20 10:41:03 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2423
22/09/20 10:41:03 INFO executor.Executor: Running task 752.0 in stage 5.0 (TID 2423)
22/09/20 10:41:03 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:41:03 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:41:15 INFO executor.Executor: Finished task 752.0 in stage 5.0 (TID 2423). 1748 bytes result sent to driver
22/09/20 10:41:15 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2425
22/09/20 10:41:15 INFO executor.Executor: Running task 754.0 in stage 5.0 (TID 2425)
22/09/20 10:41:15 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:41:15 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:41:18 INFO executor.Executor: Finished task 754.0 in stage 5.0 (TID 2425). 1748 bytes result sent to driver
22/09/20 10:41:18 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2426
22/09/20 10:41:18 INFO executor.Executor: Running task 755.0 in stage 5.0 (TID 2426)
22/09/20 10:41:18 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:41:18 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:42:02 INFO executor.Executor: Finished task 755.0 in stage 5.0 (TID 2426). 1748 bytes result sent to driver
22/09/20 10:42:02 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2437
22/09/20 10:42:02 INFO executor.Executor: Running task 766.0 in stage 5.0 (TID 2437)
22/09/20 10:42:02 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:42:02 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:43:52 INFO executor.Executor: Finished task 766.0 in stage 5.0 (TID 2437). 1748 bytes result sent to driver
22/09/20 10:43:52 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2484
22/09/20 10:43:52 INFO executor.Executor: Running task 813.0 in stage 5.0 (TID 2484)
22/09/20 10:43:52 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:43:52 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:43:56 INFO executor.Executor: Finished task 813.0 in stage 5.0 (TID 2484). 1748 bytes result sent to driver
22/09/20 10:43:56 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2487
22/09/20 10:43:56 INFO executor.Executor: Running task 816.0 in stage 5.0 (TID 2487)
22/09/20 10:43:56 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:43:56 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:44:29 INFO executor.Executor: Finished task 816.0 in stage 5.0 (TID 2487). 1748 bytes result sent to driver
22/09/20 10:44:29 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2503
22/09/20 10:44:29 INFO executor.Executor: Running task 832.0 in stage 5.0 (TID 2503)
22/09/20 10:44:29 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:44:29 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:44:31 INFO executor.Executor: Finished task 832.0 in stage 5.0 (TID 2503). 1748 bytes result sent to driver
22/09/20 10:44:31 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2504
22/09/20 10:44:31 INFO executor.Executor: Running task 833.0 in stage 5.0 (TID 2504)
22/09/20 10:44:31 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:44:31 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:48:58 INFO executor.Executor: Finished task 833.0 in stage 5.0 (TID 2504). 1748 bytes result sent to driver
22/09/20 10:48:58 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2574
22/09/20 10:48:58 INFO executor.Executor: Running task 903.0 in stage 5.0 (TID 2574)
22/09/20 10:48:58 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:48:58 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 10:48:58 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 2 ms (0 ms spent in bootstraps)
22/09/20 10:48:58 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 4 ms
22/09/20 10:49:01 INFO executor.Executor: Finished task 903.0 in stage 5.0 (TID 2574). 1748 bytes result sent to driver
22/09/20 10:49:01 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2576
22/09/20 10:49:01 INFO executor.Executor: Running task 905.0 in stage 5.0 (TID 2576)
22/09/20 10:49:01 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:01 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 2 ms
22/09/20 10:49:18 INFO executor.Executor: Finished task 905.0 in stage 5.0 (TID 2576). 1748 bytes result sent to driver
22/09/20 10:49:18 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2582
22/09/20 10:49:18 INFO executor.Executor: Running task 911.0 in stage 5.0 (TID 2582)
22/09/20 10:49:19 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:19 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:49:20 INFO executor.Executor: Finished task 911.0 in stage 5.0 (TID 2582). 1748 bytes result sent to driver
22/09/20 10:49:20 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2585
22/09/20 10:49:20 INFO executor.Executor: Running task 914.0 in stage 5.0 (TID 2585)
22/09/20 10:49:20 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:20 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:49:24 INFO executor.Executor: Finished task 914.0 in stage 5.0 (TID 2585). 1748 bytes result sent to driver
22/09/20 10:49:24 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2588
22/09/20 10:49:24 INFO executor.Executor: Running task 917.0 in stage 5.0 (TID 2588)
22/09/20 10:49:24 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:24 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:49:27 INFO executor.Executor: Finished task 917.0 in stage 5.0 (TID 2588). 1791 bytes result sent to driver
22/09/20 10:49:27 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2590
22/09/20 10:49:27 INFO executor.Executor: Running task 919.0 in stage 5.0 (TID 2590)
22/09/20 10:49:27 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:27 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:49:34 INFO executor.Executor: Finished task 919.0 in stage 5.0 (TID 2590). 1748 bytes result sent to driver
22/09/20 10:49:34 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2592
22/09/20 10:49:34 INFO executor.Executor: Running task 921.0 in stage 5.0 (TID 2592)
22/09/20 10:49:34 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:34 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:49:38 INFO executor.Executor: Finished task 921.0 in stage 5.0 (TID 2592). 1748 bytes result sent to driver
22/09/20 10:49:38 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2594
22/09/20 10:49:38 INFO executor.Executor: Running task 923.0 in stage 5.0 (TID 2594)
22/09/20 10:49:38 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:38 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:49:41 INFO executor.Executor: Finished task 923.0 in stage 5.0 (TID 2594). 1791 bytes result sent to driver
22/09/20 10:49:41 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2595
22/09/20 10:49:41 INFO executor.Executor: Running task 924.0 in stage 5.0 (TID 2595)
22/09/20 10:49:41 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:41 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:49:59 INFO executor.Executor: Finished task 924.0 in stage 5.0 (TID 2595). 1748 bytes result sent to driver
22/09/20 10:49:59 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2599
22/09/20 10:49:59 INFO executor.Executor: Running task 928.0 in stage 5.0 (TID 2599)
22/09/20 10:49:59 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:49:59 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:50:42 INFO executor.Executor: Finished task 928.0 in stage 5.0 (TID 2599). 1748 bytes result sent to driver
22/09/20 10:50:42 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2610
22/09/20 10:50:42 INFO executor.Executor: Running task 939.0 in stage 5.0 (TID 2610)
22/09/20 10:50:42 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:50:42 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 10:50:47 INFO executor.Executor: Finished task 939.0 in stage 5.0 (TID 2610). 1705 bytes result sent to driver
22/09/20 10:50:47 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2611
22/09/20 10:50:47 INFO executor.Executor: Running task 940.0 in stage 5.0 (TID 2611)
22/09/20 10:50:47 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:50:47 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:50:49 INFO executor.Executor: Finished task 940.0 in stage 5.0 (TID 2611). 1748 bytes result sent to driver
22/09/20 10:50:49 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2612
22/09/20 10:50:49 INFO executor.Executor: Running task 941.0 in stage 5.0 (TID 2612)
22/09/20 10:50:49 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 10:50:49 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 10:57:58 INFO executor.Executor: Finished task 941.0 in stage 5.0 (TID 2612). 1748 bytes result sent to driver
22/09/20 11:24:53 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2685
22/09/20 11:24:53 INFO executor.Executor: Running task 13.0 in stage 9.0 (TID 2685)
22/09/20 11:24:53 INFO spark.MapOutputTrackerWorker: Updating epoch to 4 and clearing cache
22/09/20 11:24:53 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 10
22/09/20 11:24:53 INFO client.TransportClientFactory: Successfully created connection to cdp24-s12b0409.prd.qizhidao.com/172.18.0.26:6732 after 1 ms (0 ms spent in bootstraps)
22/09/20 11:24:53 INFO memory.MemoryStore: Block broadcast_10_piece0 stored as bytes in memory (estimated size 122.8 KB, free 4.1 GB)
22/09/20 11:24:53 INFO broadcast.TorrentBroadcast: Reading broadcast variable 10 took 12 ms
22/09/20 11:24:53 INFO memory.MemoryStore: Block broadcast_10 stored as values in memory (estimated size 400.5 KB, free 4.1 GB)
22/09/20 11:24:53 INFO spark.MapOutputTrackerWorker: Don’t have map outputs for shuffle 3, fetching them
22/09/20 11:24:53 INFO spark.MapOutputTrackerWorker: Doing the fetch; tracker endpoint = NettyRpcEndpointRef(spark://MapOutputTracker@cdp12-s07b0408.prd.qizhidao.com:5212)
22/09/20 11:24:53 INFO spark.MapOutputTrackerWorker: Got the output locations
22/09/20 11:24:53 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:24:53 INFO client.TransportClientFactory: Found inactive connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337, creating a new one.
22/09/20 11:24:53 INFO client.TransportClientFactory: Successfully created connection to cdp14-s09b0408.prd.qizhidao.com/172.18.0.16:7337 after 1 ms (0 ms spent in bootstraps)
22/09/20 11:24:53 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:24:56 INFO codegen.CodeGenerator: Code generated in 32.49977 ms
22/09/20 11:24:56 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:24:56 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:24:57 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000013_2685/part-00013-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:24:57 WARN ipc.Client: Exception encountered while connecting to the server : org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.ipc.StandbyException): Operation category READ is not supported in state standby. Visit https://s.apache.org/sbnn-error
22/09/20 11:24:57 INFO impl.OrcCodecPool: Got brand-new codec SNAPPY
22/09/20 11:24:57 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000013_2685/part-00013-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:24:57 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000013_2685’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:24:57 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000013_2685: Committed
22/09/20 11:24:57 INFO executor.Executor: Finished task 13.0 in stage 9.0 (TID 2685). 1782 bytes result sent to driver
22/09/20 11:24:57 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2712
22/09/20 11:24:57 INFO executor.Executor: Running task 40.0 in stage 9.0 (TID 2712)
22/09/20 11:24:57 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:24:57 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:24:58 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:24:58 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:24:58 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000040_2712/part-00040-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:24:58 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000040_2712/part-00040-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:24:58 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000040_2712’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:24:58 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000040_2712: Committed
22/09/20 11:24:58 INFO executor.Executor: Finished task 40.0 in stage 9.0 (TID 2712). 1696 bytes result sent to driver
22/09/20 11:24:58 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2719
22/09/20 11:24:58 INFO executor.Executor: Running task 47.0 in stage 9.0 (TID 2719)
22/09/20 11:24:59 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:24:59 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 0 ms
22/09/20 11:25:02 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:25:02 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:25:02 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000047_2719/part-00047-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:02 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000047_2719/part-00047-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:02 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000047_2719’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:25:02 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000047_2719: Committed
22/09/20 11:25:02 INFO executor.Executor: Finished task 47.0 in stage 9.0 (TID 2719). 1696 bytes result sent to driver
22/09/20 11:25:02 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2730
22/09/20 11:25:02 INFO executor.Executor: Running task 58.0 in stage 9.0 (TID 2730)
22/09/20 11:25:02 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:25:02 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:25:04 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:25:04 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:25:04 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000058_2730/part-00058-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:04 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000058_2730/part-00058-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:04 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000058_2730’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:25:04 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000058_2730: Committed
22/09/20 11:25:04 INFO executor.Executor: Finished task 58.0 in stage 9.0 (TID 2730). 1696 bytes result sent to driver
22/09/20 11:25:04 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2736
22/09/20 11:25:04 INFO executor.Executor: Running task 64.0 in stage 9.0 (TID 2736)
22/09/20 11:25:04 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:25:04 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:25:07 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:25:07 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:25:07 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000064_2736/part-00064-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:07 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000064_2736/part-00064-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:07 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000064_2736’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:25:07 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000064_2736: Committed
22/09/20 11:25:07 INFO executor.Executor: Finished task 64.0 in stage 9.0 (TID 2736). 1696 bytes result sent to driver
22/09/20 11:25:07 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2746
22/09/20 11:25:07 INFO executor.Executor: Running task 74.0 in stage 9.0 (TID 2746)
22/09/20 11:25:08 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:25:08 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:25:10 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:25:10 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:25:10 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000074_2746/part-00074-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:10 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000074_2746/part-00074-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:11 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000074_2746’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:25:11 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000074_2746: Committed
22/09/20 11:25:11 INFO executor.Executor: Finished task 74.0 in stage 9.0 (TID 2746). 1696 bytes result sent to driver
22/09/20 11:25:11 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2752
22/09/20 11:25:11 INFO executor.Executor: Running task 80.0 in stage 9.0 (TID 2752)
22/09/20 11:25:11 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:25:11 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:25:21 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:25:21 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:25:21 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000080_2752/part-00080-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:21 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000080_2752/part-00080-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:21 INFO output.FileOutputCommitter: Saved output of task ‘attempt_20220920112453_0009_m_000080_2752’ to hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list
22/09/20 11:25:21 INFO mapred.SparkHadoopMapRedUtil: attempt_20220920112453_0009_m_000080_2752: Committed
22/09/20 11:25:21 INFO executor.Executor: Finished task 80.0 in stage 9.0 (TID 2752). 1696 bytes result sent to driver
22/09/20 11:25:21 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2768
22/09/20 11:25:21 INFO executor.Executor: Running task 96.0 in stage 9.0 (TID 2768)
22/09/20 11:25:21 INFO storage.ShuffleBlockFetcherIterator: Getting 1 non-empty blocks including 0 local blocks and 1 remote blocks
22/09/20 11:25:21 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 1 ms
22/09/20 11:25:38 INFO output.FileOutputCommitter: File Output Committer Algorithm version is 2
22/09/20 11:25:38 INFO output.FileOutputCommitter: FileOutputCommitter skip cleanup _temporary folders under output directory:false, ignore cleanup failures: false
22/09/20 11:25:38 INFO impl.PhysicalFsWriter: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000096_2768/part-00096-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144
22/09/20 11:25:38 INFO impl.WriterImpl: ORC writer created for path: hdfs://nameservice1/dtb-dev/101/dev_bigdata_application/warehouse/external/ads_qxb_enterprise_base_codes_names_beneficiary_sh_list/_temporary/0/_temporary/attempt_20220920112453_0009_m_000096_2768/part-00096-f6e95af3-7a27-4125-838a-6a9d9f7723cf-c000.snappy.orc with stripeSize: 67108864 blockSize: 268435456 compression: SNAPPY bufferSize: 262144

execute() try catch 一下

浙ICP备20010487号