======5)=== SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/u01/hbase/tmp/nm-local-dir/usercache/hbase/filecache/652/spark-assembly-1.6.0-hadoop2.5.0-cdh5.3.0.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/u01/hbase/hadoop-2.5.0-cdh5.3.0/share/hadoop/common/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] 16/08/17 09:28:10 INFO executor.CoarseGrainedExecutorBackend: Registered signal handlers for [TERM, HUP, INT] 16/08/17 09:28:11 INFO spark.SecurityManager: Changing view acls to: hbase 16/08/17 09:28:11 INFO spark.SecurityManager: Changing modify acls to: hbase 16/08/17 09:28:11 INFO spark.SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(hbase); users with modify permissions: Set(hbase) 16/08/17 09:28:12 INFO spark.SecurityManager: Changing view acls to: hbase 16/08/17 09:28:12 INFO spark.SecurityManager: Changing modify acls to: hbase 16/08/17 09:28:12 INFO spark.SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(hbase); users with modify permissions: Set(hbase) 16/08/17 09:28:12 INFO slf4j.Slf4jLogger: Slf4jLogger started 16/08/17 09:28:12 INFO Remoting: Starting remoting 16/08/17 09:28:13 INFO Remoting: Remoting started; listening on addresses :[akka.tcp://sparkExecutorActorSystem@xxx:46368] 16/08/17 09:28:13 INFO util.Utils: Successfully started service 'sparkExecutorActorSystem' on port 46368. 16/08/17 09:28:13 INFO storage.DiskBlockManager: Created local directory at /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/blockmgr-8f0bd302-1f10-4f03-b639-e5a38341e80c 16/08/17 09:28:13 INFO storage.MemoryStore: MemoryStore started with capacity 10.3 GB 16/08/17 09:28:13 INFO executor.CoarseGrainedExecutorBackend: Connecting to driver: spark://CoarseGrainedScheduler@yyy:64381 16/08/17 09:28:13 INFO executor.CoarseGrainedExecutorBackend: Successfully registered with driver 16/08/17 09:28:13 INFO executor.Executor: Starting executor ID 5 on host xxxx 16/08/17 09:28:13 INFO util.Utils: Successfully started service 'org.apache.spark.network.netty.NettyBlockTransferService' on port 9012. 16/08/17 09:28:13 INFO netty.NettyBlockTransferService: Server created on 9012 16/08/17 09:28:13 INFO storage.BlockManagerMaster: Trying to register BlockManager 16/08/17 09:28:13 INFO storage.BlockManagerMaster: Registered BlockManager 16/08/17 09:28:17 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 0 16/08/17 09:28:17 INFO executor.Executor: Running task 0.0 in stage 0.0 (TID 0) 16/08/17 09:28:17 INFO executor.Executor: Fetching http://xxx:64443/jars/spark_zmqpull_engine841.jar with timestamp 1471397276248 16/08/17 09:28:17 INFO util.Utils: Fetching http://xxx:64443/jars/spark_zmqpull_engine841.jar to /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/spark-47ab6a3d-0286-492c-b9d1-fd5bd52ec80d/fetchFileTemp1877526252998936286.tmp 16/08/17 09:28:23 INFO util.Utils: Copying /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/spark-47ab6a3d-0286-492c-b9d1-fd5bd52ec80d/15389795251471397276248_cache to /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/container_1455892346017_5248_01_000007/./spark_zmqpull_engine841.jar 16/08/17 09:28:24 INFO executor.Executor: Adding file:/u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/container_1455892346017_5248_01_000007/./spark_zmqpull_engine841.jar to class loader 16/08/17 09:28:24 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 0 16/08/17 09:28:24 INFO storage.MemoryStore: Block broadcast_0_piece0 stored as bytes in memory (estimated size 1571.0 B, free 1571.0 B) 16/08/17 09:28:24 INFO broadcast.TorrentBroadcast: Reading broadcast variable 0 took 144 ms 16/08/17 09:28:24 INFO storage.MemoryStore: Block broadcast_0 stored as values in memory (estimated size 1608.0 B, free 3.1 KB) 16/08/17 09:28:26 INFO internal.IgniteKernal:
>>> __________ ________________ >>> / _/ ___/ |/ / _/_ __/ __/ >>> _/ // (7 7 // / / / / _/ >>> /___/\___/_/|_/___/ /_/ /___/ >>> >>> ver. 1.6.0#20160518-sha1:0b22c45b >>> 2016 Copyright(C) Apache Software Foundation >>> >>> Ignite documentation: http://ignite.apache.org 16/08/17 09:28:26 INFO internal.IgniteKernal: Config URL: n/a 16/08/17 09:28:26 INFO internal.IgniteKernal: Daemon mode: off 16/08/17 09:28:26 INFO internal.IgniteKernal: OS: Linux 2.6.32-220.23.2.ali878.el6.x86_64 amd64 16/08/17 09:28:26 INFO internal.IgniteKernal: OS user: hbase 16/08/17 09:28:26 INFO internal.IgniteKernal: Language runtime: Java Platform API Specification ver. 1.7 16/08/17 09:28:26 INFO internal.IgniteKernal: VM information: Java(TM) SE Runtime Environment 1.7.0_79-b15 Oracle Corporation OpenJDK (Alibaba) 64-Bit Server VM 24.79-b02-internal 16/08/17 09:28:26 INFO internal.IgniteKernal: VM total memory: 14.0GB 16/08/17 09:28:26 INFO internal.IgniteKernal: Remote Management [restart: off, REST: on, JMX (remote: off)] 16/08/17 09:28:26 INFO internal.IgniteKernal: IGNITE_HOME=null 16/08/17 09:28:26 INFO internal.IgniteKernal: VM arguments: [-XX:OnOutOfMemoryError=kill %p, -Xms15000m, -Xmx15000m, -XX:MaxPermSize=256M, -Djava.io.tmpdir=/u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/container_1455892346017_5248_01_000007/tmp, -Dspark.driver.port=64381, -Dspark.yarn.app.container.log.dir=/u01/hbase/hadoop-2.5.0-cdh5.3.0/logs/userlogs/application_1455892346017_5248/container_1455892346017_5248_01_000007, -XX:MaxPermSize=256m] 16/08/17 09:28:26 INFO internal.IgniteKernal: Configured caches ['ignite-marshaller-sys-cache', 'ignite-sys-cache', 'ignite-atomics-sys-cache'] 16/08/17 09:28:26 INFO internal.IgniteKernal: Non-loopback local IPs: xxx 16/08/17 09:28:26 INFO internal.IgniteKernal: Enabled local MACs: 283152A81C10 16/08/17 09:28:26 INFO plugin.IgnitePluginProcessor: Configured plugins: 16/08/17 09:28:26 INFO plugin.IgnitePluginProcessor: ^-- None 16/08/17 09:28:26 INFO plugin.IgnitePluginProcessor: 16/08/17 09:28:26 INFO tcp.TcpCommunicationSpi: IPC shared memory server endpoint started [port=48100, tokDir=/u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/container_1455892346017_5248_01_000007/tmp/ignite/work/ipc/shmem/150c335f-9127-4771-a035-25ac29a286a9-65424] 16/08/17 09:28:26 INFO tcp.TcpCommunicationSpi: Successfully bound shared memory communication to TCP port [port=48100, locHost=0.0.0.0/0.0.0.0] 16/08/17 09:28:26 INFO tcp.TcpCommunicationSpi: Successfully bound to TCP port [port=47100, locHost=0.0.0.0/0.0.0.0] 16/08/17 09:28:26 WARN noop.NoopCheckpointSpi: Checkpoints are disabled (to enable configure any GridCheckpointSpi implementation) 16/08/17 09:28:26 WARN collision.GridCollisionManager: Collision resolution is disabled (all jobs will be activated upon arrival). 16/08/17 09:28:26 WARN noop.NoopSwapSpaceSpi: Swap space is disabled. To enable use FileSwapSpaceSpi. 16/08/17 09:28:26 INFO internal.IgniteKernal: Security status [authentication=off, tls/ssl=off] 16/08/17 09:28:27 INFO tcp.GridTcpRestProtocol: Command protocol successfully started [name=TCP binary, host=0.0.0.0/0.0.0.0, port=11211] 16/08/17 09:28:27 INFO tcp.TcpDiscoverySpi: Successfully bound to TCP port [port=47500, localHost=0.0.0.0/0.0.0.0] 16/08/17 09:28:27 WARN multicast.TcpDiscoveryMulticastIpFinder: TcpDiscoveryMulticastIpFinder has no pre-configured addresses (it is recommended in production to specify at least one address in TcpDiscoveryMulticastIpFinder.getAddresses() configuration property) 16/08/17 09:28:28 INFO cache.GridCacheProcessor: Started cache [name=ignite-marshaller-sys-cache, mode=REPLICATED] 16/08/17 09:28:28 INFO cache.GridCacheProcessor: Started cache [name=ignite-atomics-sys-cache, mode=PARTITIONED] 16/08/17 09:28:28 INFO cache.GridCacheProcessor: Started cache [name=ignite-sys-cache, mode=REPLICATED] 16/08/17 09:28:29 INFO cache.GridCachePartitionExchangeManager: Cache rebalancing scheduled: [cache=ignite-sys-cache, waitList=[]] 16/08/17 09:28:29 INFO cache.GridCachePartitionExchangeManager: Cache rebalancing scheduled: [cache=ignite-marshaller-sys-cache, waitList=[]] 16/08/17 09:28:29 INFO cache.GridCachePartitionExchangeManager: Cache rebalancing scheduled: [cache=ignite-atomics-sys-cache, waitList=[ignite-sys-cache, ignite-marshaller-sys-cache]] 16/08/17 09:28:29 INFO cache.GridCachePartitionExchangeManager: Rebalancing required [top=AffinityTopologyVersion [topVer=2, minorTopVer=0], evt=NODE_JOINED, node=150c335f-9127-4771-a035-25ac29a286a9] 16/08/17 09:28:29 INFO preloader.GridDhtPartitionDemander: <ignite-marshaller-sys-cache> Starting rebalancing [cache=ignite-marshaller-sys-cache, mode=SYNC, fromNode=bc7e0b69-22f1-499b-8363-4291fff4a50e, partitionsCount=20, topology=AffinityTopologyVersion [topVer=2, minorTopVer=0], updateSeq=1] 16/08/17 09:28:29 INFO preloader.GridDhtPartitionDemander: <ignite-sys-cache> Starting rebalancing [cache=ignite-sys-cache, mode=SYNC, fromNode=bc7e0b69-22f1-499b-8363-4291fff4a50e, partitionsCount=100, topology=AffinityTopologyVersion [topVer=2, minorTopVer=0], updateSeq=1] 16/08/17 09:28:29 INFO preloader.GridDhtPartitionDemander: <ignite-marshaller-sys-cache> Completed (final) rebalancing [cache=ignite-marshaller-sys-cache, fromNode=bc7e0b69-22f1-499b-8363-4291fff4a50e, topology=AffinityTopologyVersion [topVer=2, minorTopVer=0], time=20 ms] 16/08/17 09:28:29 INFO preloader.GridDhtPartitionDemander: <ignite-sys-cache> Completed (final) rebalancing [cache=ignite-sys-cache, fromNode=bc7e0b69-22f1-499b-8363-4291fff4a50e, topology=AffinityTopologyVersion [topVer=2, minorTopVer=0], time=30 ms] 16/08/17 09:28:29 INFO preloader.GridDhtPartitionDemander: <ignite-atomics-sys-cache> Starting rebalancing [cache=ignite-atomics-sys-cache, mode=SYNC, fromNode=bc7e0b69-22f1-499b-8363-4291fff4a50e, partitionsCount=504, topology=AffinityTopologyVersion [topVer=2, minorTopVer=0], updateSeq=1] 16/08/17 09:28:29 INFO preloader.GridDhtPartitionDemander: <ignite-atomics-sys-cache> Completed (final) rebalancing [cache=ignite-atomics-sys-cache, fromNode=bc7e0b69-22f1-499b-8363-4291fff4a50e, topology=AffinityTopologyVersion [topVer=2, minorTopVer=0], time=50 ms] 16/08/17 09:28:29 INFO internal.IgniteKernal: To start Console Management & Monitoring run ignitevisorcmd.{sh|bat} 16/08/17 09:28:29 INFO internal.IgniteKernal: 16/08/17 09:28:29 INFO internal.IgniteKernal: >>> +----------------------------------------------------------------------+ >>> Ignite ver. 1.6.0#20160518-sha1:0b22c45bb9b97692208fd0705ddf8045ff34a031 >>> +----------------------------------------------------------------------+ >>> OS name: Linux 2.6.32-220.23.2.ali878.el6.x86_64 amd64 >>> CPU(s): 24 >>> Heap: 15.0GB >>> VM name: 65424@xxxx >>> Local node [ID=150C335F-9127-4771-A035-25AC29A286A9, order=2, >>> clientMode=false] >>> Local node addresses: [xxxx, /127.0.0.1] >>> Local ports: TCP:11211 TCP:47100 UDP:47400 TCP:47500 TCP:48100 16/08/17 09:28:29 INFO discovery.GridDiscoveryManager: Topology snapshot [ver=2, servers=2, clients=0, CPUs=48, heap=29.0GB] 16/08/17 09:28:29 INFO executor.Executor: Finished task 0.0 in stage 0.0 (TID 0). 903 bytes result sent to driver 16/08/17 09:28:31 INFO cache.GridCachePartitionExchangeManager: Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion [topVer=2, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT, node=bc7e0b69-22f1-499b-8363-4291fff4a50e] 16/08/17 09:28:33 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 6 16/08/17 09:28:33 INFO executor.Executor: Running task 1.0 in stage 1.0 (TID 6) 16/08/17 09:28:33 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 11 16/08/17 09:28:33 INFO executor.Executor: Running task 6.0 in stage 1.0 (TID 11) 16/08/17 09:28:33 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 1 16/08/17 09:28:33 INFO storage.MemoryStore: Block broadcast_1_piece0 stored as bytes in memory (estimated size 1845.0 B, free 1845.0 B) 16/08/17 09:28:33 INFO broadcast.TorrentBroadcast: Reading broadcast variable 1 took 83 ms 16/08/17 09:28:33 INFO storage.MemoryStore: Block broadcast_1 stored as values in memory (estimated size 1888.0 B, free 3.6 KB) 16/08/17 09:28:33 INFO executor.Executor: Finished task 1.0 in stage 1.0 (TID 6). 905 bytes result sent to driver 16/08/17 09:28:33 INFO executor.Executor: Finished task 6.0 in stage 1.0 (TID 11). 905 bytes result sent to driver 16/08/17 09:28:34 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 16 16/08/17 09:28:34 INFO executor.Executor: Running task 1.0 in stage 2.0 (TID 16) 16/08/17 09:28:34 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 21 16/08/17 09:28:34 INFO executor.Executor: Running task 6.0 in stage 2.0 (TID 21) 16/08/17 09:28:34 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 2 16/08/17 09:28:34 INFO storage.MemoryStore: Block broadcast_2_piece0 stored as bytes in memory (estimated size 2.9 KB, free 6.6 KB) 16/08/17 09:28:34 INFO broadcast.TorrentBroadcast: Reading broadcast variable 2 took 53 ms 16/08/17 09:28:34 INFO storage.MemoryStore: Block broadcast_2 stored as values in memory (estimated size 3.0 KB, free 9.5 KB) 16/08/17 09:28:34 INFO cache.GridCacheProcessor: Started cache [name=sharedBaselineCacheRDD, mode=PARTITIONED] 16/08/17 09:28:34 INFO cache.GridCachePartitionExchangeManager: Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion [topVer=2, minorTopVer=2], evt=DISCOVERY_CUSTOM_EVT, node=bc7e0b69-22f1-499b-8363-4291fff4a50e] 16/08/17 09:28:35 INFO executor.Executor: Finished task 6.0 in stage 2.0 (TID 21). 903 bytes result sent to driver 16/08/17 09:28:35 INFO executor.Executor: Finished task 1.0 in stage 2.0 (TID 16). 903 bytes result sent to driver 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2073 16/08/17 09:28:40 INFO executor.Executor: Running task 0.0 in stage 5.0 (TID 2073) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2078 16/08/17 09:28:40 INFO executor.Executor: Running task 5.0 in stage 5.0 (TID 2078) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2083 16/08/17 09:28:40 INFO executor.Executor: Running task 10.0 in stage 5.0 (TID 2083) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2088 16/08/17 09:28:40 INFO executor.Executor: Running task 15.0 in stage 5.0 (TID 2088) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2093 16/08/17 09:28:40 INFO executor.Executor: Running task 20.0 in stage 5.0 (TID 2093) 16/08/17 09:28:40 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 5 16/08/17 09:28:40 INFO storage.MemoryStore: Block broadcast_5_piece0 stored as bytes in memory (estimated size 2.7 KB, free 12.2 KB) 16/08/17 09:28:40 INFO broadcast.TorrentBroadcast: Reading broadcast variable 5 took 13 ms 16/08/17 09:28:40 INFO storage.MemoryStore: Block broadcast_5 stored as values in memory (estimated size 2.7 KB, free 15.0 KB) 16/08/17 09:28:40 INFO executor.Executor: Finished task 15.0 in stage 5.0 (TID 2088). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 10.0 in stage 5.0 (TID 2083). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 20.0 in stage 5.0 (TID 2093). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 5.0 in stage 5.0 (TID 2078). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 0.0 in stage 5.0 (TID 2073). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2126 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2131 16/08/17 09:28:40 INFO executor.Executor: Running task 11.0 in stage 6.0 (TID 2131) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2136 16/08/17 09:28:40 INFO executor.Executor: Running task 6.0 in stage 6.0 (TID 2126) 16/08/17 09:28:40 INFO executor.Executor: Running task 16.0 in stage 6.0 (TID 2136) 16/08/17 09:28:40 INFO spark.MapOutputTrackerWorker: Updating epoch to 1 and clearing cache 16/08/17 09:28:40 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 6 16/08/17 09:28:40 INFO storage.MemoryStore: Block broadcast_6_piece0 stored as bytes in memory (estimated size 2.5 KB, free 17.5 KB) 16/08/17 09:28:40 INFO broadcast.TorrentBroadcast: Reading broadcast variable 6 took 12 ms 16/08/17 09:28:40 INFO storage.MemoryStore: Block broadcast_6 stored as values in memory (estimated size 2.6 KB, free 20.0 KB) 16/08/17 09:28:40 INFO spark.MapOutputTrackerWorker: Don't have map outputs for shuffle 0, fetching them 16/08/17 09:28:40 INFO spark.MapOutputTrackerWorker: Don't have map outputs for shuffle 0, fetching them 16/08/17 09:28:40 INFO spark.MapOutputTrackerWorker: Don't have map outputs for shuffle 0, fetching them 16/08/17 09:28:40 INFO spark.MapOutputTrackerWorker: Doing the fetch; tracker endpoint = NettyRpcEndpointRef(spark://MapOutputTracker@10.194.70.26:64381) 16/08/17 09:28:40 INFO spark.MapOutputTrackerWorker: Got the output locations 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Getting 2 non-empty blocks out of 50 blocks 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Getting 3 non-empty blocks out of 50 blocks 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Getting 2 non-empty blocks out of 50 blocks 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 9 ms 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 8 ms 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 10 ms 16/08/17 09:28:40 INFO executor.Executor: Finished task 6.0 in stage 6.0 (TID 2126). 1172 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 11.0 in stage 6.0 (TID 2131). 1166 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 16.0 in stage 6.0 (TID 2136). 1166 bytes result sent to driver 16/08/17 09:28:42 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2148 16/08/17 09:28:42 INFO executor.Executor: Running task 0.0 in stage 12.0 (TID 2148) 16/08/17 09:28:42 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 12 16/08/17 09:28:42 INFO storage.MemoryStore: Block broadcast_12_piece0 stored as bytes in memory (estimated size 62.4 KB, free 82.4 KB) 16/08/17 09:28:42 INFO broadcast.TorrentBroadcast: Reading broadcast variable 12 took 13 ms 16/08/17 09:28:42 INFO storage.MemoryStore: Block broadcast_12 stored as values in memory (estimated size 62.4 KB, free 144.8 KB) 16/08/17 09:28:42 INFO util.RecurringTimer: Started timer for BlockGenerator at time 1471397324000 16/08/17 09:28:42 INFO receiver.BlockGenerator: Started BlockGenerator 16/08/17 09:28:42 INFO receiver.BlockGenerator: Started block pushing thread 16/08/17 09:28:42 INFO receiver.ReceiverSupervisorImpl: Starting receiver 16/08/17 09:28:42 INFO receiver.ReceiverSupervisorImpl: Called receiver onStart 16/08/17 09:28:42 INFO receiver.ReceiverSupervisorImpl: Waiting for receiver to be stopped 16/08/17 09:28:43 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2151 16/08/17 09:28:43 INFO executor.Executor: Running task 0.0 in stage 15.0 (TID 2151) 16/08/17 09:28:43 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 15 16/08/17 09:28:43 INFO storage.MemoryStore: Block broadcast_15_piece0 stored as bytes in memory (estimated size 62.4 KB, free 207.2 KB) 16/08/17 09:28:43 INFO broadcast.TorrentBroadcast: Reading broadcast variable 15 took 12 ms 16/08/17 09:28:43 INFO storage.MemoryStore: Block broadcast_15 stored as values in memory (estimated size 62.4 KB, free 269.6 KB) 16/08/17 09:28:43 INFO util.RecurringTimer: Started timer for BlockGenerator at time 1471397324000 16/08/17 09:28:43 INFO receiver.BlockGenerator: Started BlockGenerator 16/08/17 09:28:43 INFO receiver.BlockGenerator: Started block pushing thread 16/08/17 09:28:43 INFO receiver.ReceiverSupervisorImpl: Starting receiver 16/08/17 09:28:43 INFO receiver.ReceiverSupervisorImpl: Called receiver onStart 16/08/17 09:28:43 INFO receiver.ReceiverSupervisorImpl: Waiting for receiver to be stopped 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 30 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 29 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 28 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 18 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 19 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 20 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 21 -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Embedded-mode-ignite-on-spark-tp6942p7122.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
