ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From percent620 <percent...@163.com>
Subject Re: Embedded mode ignite on spark
Date Wed, 17 Aug 2016 02:34:28 GMT
======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.

Mime
View raw message