============4) SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/u01/hbase/tmp/nm-local-dir/usercache/hbase/filecache/785/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:13 INFO executor.CoarseGrainedExecutorBackend: Registered signal handlers for [TERM, HUP, INT] 16/08/17 09:28:14 INFO spark.SecurityManager: Changing view acls to: hbase 16/08/17 09:28:14 INFO spark.SecurityManager: Changing modify acls to: hbase 16/08/17 09:28:14 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:15 INFO spark.SecurityManager: Changing view acls to: hbase 16/08/17 09:28:15 INFO spark.SecurityManager: Changing modify acls to: hbase 16/08/17 09:28:15 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:15 INFO slf4j.Slf4jLogger: Slf4jLogger started 16/08/17 09:28:15 INFO Remoting: Starting remoting 16/08/17 09:28:15 INFO Remoting: Remoting started; listening on addresses :[akka.tcp://sparkExecutorActorSystem@vxxxx:62569] 16/08/17 09:28:15 INFO util.Utils: Successfully started service 'sparkExecutorActorSystem' on port 62569. 16/08/17 09:28:15 INFO storage.DiskBlockManager: Created local directory at /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/blockmgr-eeadd1d1-8dd8-48ef-84da-f3ed72048c80 16/08/17 09:28:15 INFO storage.MemoryStore: MemoryStore started with capacity 10.3 GB 16/08/17 09:28:16 INFO executor.CoarseGrainedExecutorBackend: Connecting to driver: spark://[email protected]:64381 16/08/17 09:28:16 INFO executor.CoarseGrainedExecutorBackend: Successfully registered with driver 16/08/17 09:28:16 INFO executor.Executor: Starting executor ID 4 on host xxxx 16/08/17 09:28:16 INFO util.Utils: Successfully started service 'org.apache.spark.network.netty.NettyBlockTransferService' on port 15883. 16/08/17 09:28:16 INFO netty.NettyBlockTransferService: Server created on 15883 16/08/17 09:28:16 INFO storage.BlockManagerMaster: Trying to register BlockManager 16/08/17 09:28:16 INFO storage.BlockManagerMaster: Registered BlockManager 16/08/17 09:28:17 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 4 16/08/17 09:28:17 INFO executor.Executor: Running task 4.0 in stage 0.0 (TID 4) 16/08/17 09:28:17 INFO executor.Executor: Fetching http://10.194.70.26:64443/jars/spark_zmqpull_engine841.jar with timestamp 1471397276248 16/08/17 09:28:17 INFO util.Utils: Fetching http://10.194.70.26:64443/jars/spark_zmqpull_engine841.jar to /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/spark-e30ebe68-c99e-443d-87c2-9f9372e9759d/fetchFileTemp4290126145592989981.tmp 16/08/17 09:28:23 INFO util.Utils: Copying /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/spark-e30ebe68-c99e-443d-87c2-9f9372e9759d/15389795251471397276248_cache to /u01/hbase/tmp/nm-local-dir/usercache/hbase/appcache/application_1455892346017_5248/container_1455892346017_5248_01_000005/./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_000005/./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 143 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:25 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:25 INFO internal.IgniteKernal: Config URL: n/a 16/08/17 09:28:25 INFO internal.IgniteKernal: Daemon mode: off 16/08/17 09:28:25 INFO internal.IgniteKernal: OS: Linux 2.6.32-220.23.2.ali878.el6.x86_64 amd64 16/08/17 09:28:25 INFO internal.IgniteKernal: OS user: hbase 16/08/17 09:28:25 INFO internal.IgniteKernal: Language runtime: Java Platform API Specification ver. 1.7 16/08/17 09:28:25 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:25 INFO internal.IgniteKernal: VM total memory: 14.0GB 16/08/17 09:28:25 INFO internal.IgniteKernal: Remote Management [restart: off, REST: on, JMX (remote: off)] 16/08/17 09:28:25 INFO internal.IgniteKernal: IGNITE_HOME=null 16/08/17 09:28:25 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_000005/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_000005, -XX:MaxPermSize=256m] 16/08/17 09:28:25 INFO internal.IgniteKernal: Configured caches ['ignite-marshaller-sys-cache', 'ignite-sys-cache', 'ignite-atomics-sys-cache'] 16/08/17 09:28:25 INFO internal.IgniteKernal: Non-loopback local IPs: xxx 16/08/17 09:28:25 INFO internal.IgniteKernal: Enabled local MACs: 283152A80FEB 16/08/17 09:28:25 INFO plugin.IgnitePluginProcessor: Configured plugins: 16/08/17 09:28:25 INFO plugin.IgnitePluginProcessor: ^-- None 16/08/17 09:28:25 INFO plugin.IgnitePluginProcessor: 16/08/17 09:28:25 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_000005/tmp/ignite/work/ipc/shmem/c2671205-0499-428b-b2a3-c180a70a6c03-88279] 16/08/17 09:28:25 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:25 INFO tcp.TcpCommunicationSpi: Successfully bound to TCP port [port=47100, locHost=0.0.0.0/0.0.0.0] 16/08/17 09:28:25 WARN noop.NoopCheckpointSpi: Checkpoints are disabled (to enable configure any GridCheckpointSpi implementation) 16/08/17 09:28:25 WARN collision.GridCollisionManager: Collision resolution is disabled (all jobs will be activated upon arrival). 16/08/17 09:28:25 WARN noop.NoopSwapSpaceSpi: Swap space is disabled. To enable use FileSwapSpaceSpi. 16/08/17 09:28:25 INFO internal.IgniteKernal: Security status [authentication=off, tls/ssl=off] 16/08/17 09:28:26 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:26 INFO tcp.TcpDiscoverySpi: Successfully bound to TCP port [port=47500, localHost=0.0.0.0/0.0.0.0] 16/08/17 09:28:26 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:27 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:28 INFO cache.GridCachePartitionExchangeManager: Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion [topVer=1, minorTopVer=0], evt=NODE_JOINED, node=c2671205-0499-428b-b2a3-c180a70a6c03] 16/08/17 09:28:28 INFO internal.IgniteKernal: To start Console Management & Monitoring run ignitevisorcmd.{sh|bat} 16/08/17 09:28:28 INFO internal.IgniteKernal: 16/08/17 09:28:28 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: 88279@xxx >>> Local node [ID=C2671205-0499-428B-B2A3-C180A70A6C03, order=1, >>> clientMode=false] >>> Local node addresses: [xxx, /127.0.0.1] >>> Local ports: TCP:11211 TCP:47100 UDP:47400 TCP:47500 TCP:48100 16/08/17 09:28:28 INFO discovery.GridDiscoveryManager: Topology snapshot [ver=1, servers=1, clients=0, CPUs=24, heap=15.0GB] 16/08/17 09:28:28 INFO executor.Executor: Finished task 4.0 in stage 0.0 (TID 4). 903 bytes result sent to driver 16/08/17 09:28:29 INFO discovery.GridDiscoveryManager: Added new node to topology: TcpDiscoveryNode [id=6fc9a7ab-ebfc-4d84-8a66-8aa83f4ef9ec, addrs=[xxx, 127.0.0.1], sockAddrs=[xxx:47500, /10.194.54.60:47500, /127.0.0.1:47500], discPort=47500, order=2, intOrder=2, lastExchangeTime=1471397309234, loc=false, ver=1.6.0#20160518-sha1:0b22c45b, isClient=false] 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:30 INFO cache.GridCachePartitionExchangeManager: Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion [topVer=2, minorTopVer=0], evt=NODE_JOINED, node=6fc9a7ab-ebfc-4d84-8a66-8aa83f4ef9ec] 16/08/17 09:28:31 INFO cache.GridCachePartitionExchangeManager: Skipping rebalancing (nothing scheduled) [top=AffinityTopologyVersion [topVer=2, minorTopVer=1], evt=DISCOVERY_CUSTOM_EVT, node=c2671205-0499-428b-b2a3-c180a70a6c03] 16/08/17 09:28:33 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 7 16/08/17 09:28:33 INFO executor.Executor: Running task 2.0 in stage 1.0 (TID 7) 16/08/17 09:28:33 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 12 16/08/17 09:28:33 INFO executor.Executor: Running task 7.0 in stage 1.0 (TID 12) 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 50 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 7.0 in stage 1.0 (TID 12). 905 bytes result sent to driver 16/08/17 09:28:33 INFO executor.Executor: Finished task 2.0 in stage 1.0 (TID 7). 905 bytes result sent to driver 16/08/17 09:28:34 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 19 16/08/17 09:28:34 INFO executor.Executor: Running task 4.0 in stage 2.0 (TID 19) 16/08/17 09:28:34 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 24 16/08/17 09:28:34 INFO executor.Executor: Running task 9.0 in stage 2.0 (TID 24) 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 12 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=c2671205-0499-428b-b2a3-c180a70a6c03] 16/08/17 09:28:35 INFO executor.Executor: Finished task 4.0 in stage 2.0 (TID 19). 903 bytes result sent to driver 16/08/17 09:28:35 INFO executor.Executor: Finished task 9.0 in stage 2.0 (TID 24). 903 bytes result sent to driver 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2076 16/08/17 09:28:40 INFO executor.Executor: Running task 3.0 in stage 5.0 (TID 2076) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2081 16/08/17 09:28:40 INFO executor.Executor: Running task 8.0 in stage 5.0 (TID 2081) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2086 16/08/17 09:28:40 INFO executor.Executor: Running task 13.0 in stage 5.0 (TID 2086) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2091 16/08/17 09:28:40 INFO executor.Executor: Running task 18.0 in stage 5.0 (TID 2091) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2096 16/08/17 09:28:40 INFO executor.Executor: Running task 23.0 in stage 5.0 (TID 2096) 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 10 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 23.0 in stage 5.0 (TID 2096). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 13.0 in stage 5.0 (TID 2086). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 3.0 in stage 5.0 (TID 2076). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 18.0 in stage 5.0 (TID 2091). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 8.0 in stage 5.0 (TID 2081). 1162 bytes result sent to driver 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2127 16/08/17 09:28:40 INFO executor.Executor: Running task 4.0 in stage 6.0 (TID 2127) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2132 16/08/17 09:28:40 INFO executor.Executor: Running task 9.0 in stage 6.0 (TID 2132) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2137 16/08/17 09:28:40 INFO executor.Executor: Running task 14.0 in stage 6.0 (TID 2137) 16/08/17 09:28:40 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2141 16/08/17 09:28:40 INFO executor.Executor: Running task 19.0 in stage 6.0 (TID 2141) 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: 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@xxx: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 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 10 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 7 ms 16/08/17 09:28:40 INFO storage.ShuffleBlockFetcherIterator: Started 1 remote fetches in 12 ms 16/08/17 09:28:40 INFO executor.Executor: Finished task 19.0 in stage 6.0 (TID 2141). 1166 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 9.0 in stage 6.0 (TID 2132). 1172 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 14.0 in stage 6.0 (TID 2137). 1166 bytes result sent to driver 16/08/17 09:28:40 INFO executor.Executor: Finished task 4.0 in stage 6.0 (TID 2127). 1172 bytes result sent to driver 16/08/17 09:28:42 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2146 16/08/17 09:28:42 INFO executor.Executor: Running task 0.0 in stage 10.0 (TID 2146) 16/08/17 09:28:42 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 10 16/08/17 09:28:42 INFO storage.MemoryStore: Block broadcast_10_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 10 took 11 ms 16/08/17 09:28:42 INFO storage.MemoryStore: Block broadcast_10 stored as values in memory (estimated size 62.4 KB, free 144.8 KB) 16/08/17 09:28:42 INFO executor.CoarseGrainedExecutorBackend: Got assigned task 2149 16/08/17 09:28:42 INFO executor.Executor: Running task 0.0 in stage 13.0 (TID 2149) 16/08/17 09:28:42 INFO broadcast.TorrentBroadcast: Started reading broadcast variable 13 16/08/17 09:28:42 INFO storage.MemoryStore: Block broadcast_13_piece0 stored as bytes in memory (estimated size 62.4 KB, free 207.2 KB) 16/08/17 09:28:42 INFO broadcast.TorrentBroadcast: Reading broadcast variable 13 took 11 ms 16/08/17 09:28:42 INFO storage.MemoryStore: Block broadcast_13 stored as values in memory (estimated size 62.4 KB, free 269.6 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 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: Starting receiver 16/08/17 09:28:42 INFO receiver.ReceiverSupervisorImpl: Called receiver onStart 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:42 INFO receiver.ReceiverSupervisorImpl: Waiting for receiver to be stopped 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 29 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 30 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 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 22 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 23 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 24 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 25 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 26 16/08/17 09:29:20 INFO storage.BlockManager: Removing RDD 27 16/08/17 09:29:28 INFO internal.IgniteKernal: Metrics for local node (to disable set 'metricsLogFrequency' to 0) -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Embedded-mode-ignite-on-spark-tp6942p7121.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
