incubator-s4-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matthieu Morel <mmo...@apache.org>
Subject Re: S4R URL
Date Tue, 09 Oct 2012 08:57:58 GMT
Hi, see my answers inline.

On 10/9/12 4:57 AM, Frank Zheng wrote:
> Hi,
>
> I find that there are a lot of progress by typing "jps".
> Even I Ctrl+C S4 nodes or ZooKeeper servers, the progresses are still
> running.
> When I restart another S4 node, there will be one more progress and will
> not stop untill I type "kill -9 PID".

Thanks for reporting that, we certainly need to properly handle the 
normal shutdown.

> After I kill all previously running progresses, at port 12000, 12001 and
> 13000, I restart all three nodes, and two of them working well.
> One cluster1 PE node does not work properly. The error messages are as
> follows.

If cluster1 is the node that is supposed to process the RawStatus 
stream, it would be that the twitter-counter application hasn't been 
deployed yet. Have you checked with "s4 status"? Can you see the 
expected deployment configuration? Do the logs show that the application 
was correctly deployed?

Hope this helps,

Matthieu


>
> 18:50:35.153 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.153 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.154 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.158 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.158 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.160 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.161 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.163 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.168 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.170 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.171 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.176 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.180 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.182 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.184 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.187 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.189 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.208 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.314 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:35.397 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:36.060 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
> 18:50:36.063 [Receiver] ERROR org.apache.s4.core.Receiver - Could not
> find target stream for event with appId=-1 and streamId=RawStatus
>
>
>
> On Mon, Oct 8, 2012 at 5:30 PM, Matthieu Morel <mmorel@apache.org
> <mailto:mmorel@apache.org>> wrote:
>
>     Hi,
>
>     the log message that says it is fetching the app from a local temp
>     directory is correct.
>     What each node does for loading S4 archives is a bit similar to what
>     hadoop does when you deploy a new job. First, the node downloads the
>     S4R from the remote URI. Then this is extracted to a local temporary
>     directory. Then we define a new classloader that reads files from
>     this temporary directory, so that S4R classes and dependencies can
>     be dynamically loaded.
>     The log message is about the local temporary directory.
>
>     Regarding the logged error, this looks like a port conflict, most
>     probably you have something else running on port 12000.
>
>     Hope this helps,
>
>     Matthieu
>
>
>
>
>
>
>     On 10/8/12 10:45 AM, Frank Zheng wrote:
>
>         Hi All,
>
>         I tried to run the Twitter Trending Example in a multi-server
>         cluster on
>         two machines.
>         I followed the steps on the website except I create and deploy
>         in two
>         steps, instead of one, like this.
>
>         ./s4 s4r
>         -b=/usr/apache-s4-0.5.0-__incubating-src/test-apps/__twitter-counter/build.gradle
>         twitter-counter
>
>         ./s4 deploy
>         -s4r=/usr/apache-s4-0.5.0-__incubating-src/test-apps/__twitter-counter/build/libs/__twitter-counter.s4r
>         -c=cluster1 -appName=twitter-counter -zk=testing.machine1:2181
>
>
>         These two steps succeeded. And the status like this.
>
>         App Status
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>                   Name
>         Cluster                                                  URI
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>             twitter-adapter         cluster2
>         file:/usr/apache-s4-0.5.0-__incubating-src/test-apps/__twitter-adapter/build/libs/__twitter-adapter.s4r
>             twitter-counter         cluster1
>         file:/usr/apache-s4-0.5.0-__incubating-src/test-apps/__twitter-counter/build/libs/__twitter-counter.s4r
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>
>
>
>         Cluster Status
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>
>                               Active nodes
>                   Name                App           Tasks
>         ------------------------------__------------------------------__--------------------
>                                                              Number    Task
>         id                         Host                         Port
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>                 cluster2        twitter-adapter      1         0
>                 cluster1        twitter-counter      2         0
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>
>
>
>         Stream Status
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>                   Name
>         Producers                                              Consumers
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>                RawStatus
>         --                                                     --
>         ------------------------------__------------------------------__------------------------------__------------------------------__----------
>
>
>         Then i set up three nodes, two for cluster1 and one cluster2.
>         But they all loaded s4r file from "/tmp/XXXX", not the file
>         directory I
>         specified.
>         The error messages are as follows.
>
>         [root@testing apache-s4-0.5.0-incubating-__src]# ./s4 node
>         -c=cluster1
>         -zk=testing.machine1:2181
>         16:36:26.655 [main] INFO  org.apache.s4.core.Main - Initializing
>         S4 node
>         with :
>         - comm module class [org.apache.s4.comm.__DefaultCommModule]
>         - comm configuration file [default.s4.comm.properties from
>         classpath]
>         - core module class [org.apache.s4.core.__DefaultCoreModule]
>         - core configuration file[default.s4.core.__properties from
>         classpath]
>         - extra modules: []
>         - inline parameters: []
>         16:36:26.665 [main] DEBUG org.apache.s4.core.Main - Adding named
>         parameters for injection :
>         [s4.cluster.zk_address=__testing.machine1:2181]
>         16:36:26.991 [main] INFO  org.apache.s4.core.Main - Starting S4
>         node.
>         This node will automatically download applications published for the
>         cluster it belongs to
>         16:36:32.087 [main] INFO  o.a.s.comm.topology.__AssignmentFromZK
>         - New
>         session:88452960352141328; state is : SyncConnected
>         16:36:32.172 [main] INFO  o.a.s.comm.topology.__AssignmentFromZK -
>         Successfully acquired task:Task-0 by testing.machine1
>         *16:36:32.200 [main] INFO  org.apache.s4.core.Server - Loading
>
>         application [twitter-counter] from file
>         [/tmp/__tmp3230139471078202749s4r]
>         16:36:32.201 [main] WARN  o.a.s4.base.util.__S4RLoaderFactory -
>         s4.tmp.dir
>         not specified, using temporary directory [/tmp/1349685392201-0] for
>         unpacking S4R. You may want to specify a parent non-temporary
>         directory.*
>
>
>         16:36:32.201 [main] INFO  o.a.s4.base.util.__S4RLoaderFactory -
>         Unzipping
>         S4R archive in [/tmp/1349685392201-0]
>         16:36:32.295 [main] INFO  org.apache.s4.core.Server - App class
>         name is:
>         org.apache.s4.example.twitter.__TwitterCounterApp
>         16:36:32.355 [main] INFO  o.a.s4.comm.topology.__ClusterFromZK -
>         Changing
>         cluster topology to {
>         nbNodes=1,name=cluster1,mode=__unicast,type=,nodes=[{__partition=0,port=12000,__machineName=testing.machine1,__taskId=Task-0}]}
>         from null
>         16:36:32.387 [main] INFO  o.a.s4.comm.topology.__ClusterFromZK -
>         Adding
>         topology change
>         listener:org.apache.s4.comm.__tcp.TCPEmitter@2e879860
>         16:36:32.433 [main] INFO  o.a.s4.comm.topology.__ClustersFromZK
>         - New
>         session:88452960352141330
>         16:36:32.435 [main] INFO  o.a.s4.comm.topology.__ClustersFromZK
>         - Detected
>         new stream [RawStatus]
>         16:36:32.468 [main] INFO  o.a.s4.comm.topology.__ClustersFromZK
>         - New
>         session:88452960352141331
>         16:36:32.481 [main] INFO  o.a.s4.comm.topology.__ClusterFromZK -
>         Changing
>         cluster topology to {
>         nbNodes=1,name=cluster1,mode=__unicast,type=,nodes=[{__partition=0,port=12000,__machineName=testing.machine1,__taskId=Task-0}]}
>         from null
>         16:36:32.489 [main] INFO  o.a.s4.comm.topology.__ClusterFromZK -
>         Changing
>         cluster topology to {
>         nbNodes=1,name=cluster2,mode=__unicast,type=,nodes=[{__partition=0,port=13000,__machineName=testing.machine1,__taskId=Task-0}]}
>         from null
>         16:36:32.508 [main] ERROR org.apache.s4.core.Server - Could not
>         load s4
>         application form s4r file [{/tmp/__tmp3230139471078202749s4r}]
>         com.google.inject.__ProvisionException: Guice provision errors:
>
>         1) Error injecting constructor,
>         org.jboss.netty.channel.__ChannelException: Failed to bind to:
>         0.0.0.0/0.0.0.0:12000 <http://0.0.0.0/0.0.0.0:12000>
>         <http://0.0.0.0/0.0.0.0:12000>
>
>             at
>         org.apache.s4.comm.tcp.__TCPListener.<init>(__TCPListener.java:66)
>             while locating org.apache.s4.comm.tcp.__TCPListener
>             while locating org.apache.s4.base.Listener
>               for parameter 0 at
>         org.apache.s4.core.Receiver.<__init>(Receiver.java:59)
>             at org.apache.s4.core.Receiver.__class(Receiver.java:51)
>             while locating org.apache.s4.core.Receiver
>               for field at org.apache.s4.core.App.__receiver(App.java:47)
>             while locating org.apache.s4.example.twitter.__TwitterCounterApp
>
>         1 error
>               at
>         com.google.inject.internal.__Errors.__throwProvisionExceptionIfError__sExist(Errors.java:451)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__MembersInjectorImpl.__injectMembers(__MembersInjectorImpl.java:65)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__InjectorImpl.injectMembers(__InjectorImpl.java:944)
>         ~[guice-3.0.jar:na]
>               at org.apache.s4.core.Server.__loadApp(Server.java:120)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at
>         org.apache.s4.deploy.__DistributedDeploymentManager.__deployApplication(__DistributedDeploymentManager.__java:128)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at
>         org.apache.s4.deploy.__DistributedDeploymentManager.__start(__DistributedDeploymentManager.__java:181)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at org.apache.s4.core.Server.__start(Server.java:87)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at org.apache.s4.core.Main.__startNode(Main.java:150)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at org.apache.s4.core.Main.main(__Main.java:75)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at sun.reflect.__NativeMethodAccessorImpl.__invoke0(Native
>         Method)
>         ~[na:1.6.0_22]
>               at
>         sun.reflect.__NativeMethodAccessorImpl.__invoke(__NativeMethodAccessorImpl.java:__57)
>         ~[na:1.6.0_22]
>               at
>         sun.reflect.__DelegatingMethodAccessorImpl.__invoke(__DelegatingMethodAccessorImpl.__java:43)
>         ~[na:1.6.0_22]
>               at java.lang.reflect.Method.__invoke(Method.java:616)
>         ~[na:1.6.0_22]
>               at org.apache.s4.tools.Tools$__Task.dispatch(Tools.java:54)
>         [s4-tools-0.5.0-incubating.__jar:0.5.0-incubating]
>               at org.apache.s4.tools.Tools.__main(Tools.java:94)
>         [s4-tools-0.5.0-incubating.__jar:0.5.0-incubating]
>         Caused by: org.jboss.netty.channel.__ChannelException: Failed to
>         bind to:
>         0.0.0.0/0.0.0.0:12000 <http://0.0.0.0/0.0.0.0:12000>
>         <http://0.0.0.0/0.0.0.0:12000>
>
>               at
>         org.jboss.netty.bootstrap.__ServerBootstrap.bind(__ServerBootstrap.java:303)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.apache.s4.comm.tcp.__TCPListener.<init>(__TCPListener.java:92)
>         ~[s4-comm-0.5.0-incubating.__jar:0.5.0-incubating]
>               at
>         org.apache.s4.comm.tcp.__TCPListener$$FastClassByGuice$__$82db237d.newInstance(<__generated>)
>         ~[guice-3.0.jar:0.5.0-__incubating]
>               at
>         com.google.inject.internal.__cglib.reflect.$__FastConstructor.newInstance(__FastConstructor.java:40)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__DefaultConstructionProxyFactor__y$1.newInstance(__DefaultConstructionProxyFactor__y.java:60)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__ConstructorInjector.construct(__ConstructorInjector.java:85)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__ConstructorBindingImpl$__Factory.get(__ConstructorBindingImpl.java:__254)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__FactoryProxy.get(FactoryProxy.__java:54)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__SingleParameterInjector.__inject(__SingleParameterInjector.java:__38)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__SingleParameterInjector.__getAll(__SingleParameterInjector.java:__62)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__ConstructorInjector.construct(__ConstructorInjector.java:84)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__ConstructorBindingImpl$__Factory.get(__ConstructorBindingImpl.java:__254)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__ProviderToInternalFactoryAdapt__er$1.call(__ProviderToInternalFactoryAdapt__er.java:46)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__InjectorImpl.callInContext(__InjectorImpl.java:1031)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__ProviderToInternalFactoryAdapt__er.get(__ProviderToInternalFactoryAdapt__er.java:40)
>         ~[guice-3.0.jar:na]
>               at com.google.inject.Scopes$1$1.__get(Scopes.java:65)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__InternalFactoryToProviderAdapt__er.get(__InternalFactoryToProviderAdapt__er.java:40)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__SingleFieldInjector.inject(__SingleFieldInjector.java:53)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__MembersInjectorImpl.__injectMembers(__MembersInjectorImpl.java:110)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__MembersInjectorImpl$1.call(__MembersInjectorImpl.java:75)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__MembersInjectorImpl$1.call(__MembersInjectorImpl.java:73)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__InjectorImpl.callInContext(__InjectorImpl.java:1024)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__MembersInjectorImpl.__injectAndNotify(__MembersInjectorImpl.java:73)
>         ~[guice-3.0.jar:na]
>               at
>         com.google.inject.internal.__MembersInjectorImpl.__injectMembers(__MembersInjectorImpl.java:60)
>         ~[guice-3.0.jar:na]
>               ... 13 common frames omitted
>         Caused by: java.net.BindException: Address already in use
>               at sun.nio.ch.Net.bind(Native Method) ~[na:1.6.0_22]
>               at
>         sun.nio.ch
>         <http://sun.nio.ch>.__ServerSocketChannelImpl.bind(__ServerSocketChannelImpl.java:__137)
>         ~[na:1.6.0_22]
>               at sun.nio.ch
>         <http://sun.nio.ch>.__ServerSocketAdaptor.bind(__ServerSocketAdaptor.java:77)
>         ~[na:1.6.0_22]
>               at
>         org.jboss.netty.channel.__socket.nio.__NioServerSocketPipelineSink.__bind(__NioServerSocketPipelineSink.__java:148)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__socket.nio.__NioServerSocketPipelineSink.__handleServerSocket(__NioServerSocketPipelineSink.__java:100)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__socket.nio.__NioServerSocketPipelineSink.__eventSunk(__NioServerSocketPipelineSink.__java:74)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__Channels.bind(Channels.java:__468)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__AbstractChannel.bind(__AbstractChannel.java:192)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.bootstrap.__ServerBootstrap$Binder.__channelOpen(ServerBootstrap.__java:348)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__Channels.fireChannelOpen(__Channels.java:176)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__socket.nio.__NioServerSocketChannel.<init>(__NioServerSocketChannel.java:__85)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__socket.nio.__NioServerSocketChannelFactory.__newChannel(__NioServerSocketChannelFactory.__java:142)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.channel.__socket.nio.__NioServerSocketChannelFactory.__newChannel(__NioServerSocketChannelFactory.__java:90)
>         ~[netty-3.2.5.Final.jar:na]
>               at
>         org.jboss.netty.bootstrap.__ServerBootstrap.bind(__ServerBootstrap.java:282)
>         ~[netty-3.2.5.Final.jar:na]
>               ... 36 common frames omitted
>         16:36:32.510 [main] ERROR o.a.s.d.__DistributedDeploymentManager
>         - Cannot
>         deploy application
>         org.apache.s4.deploy.__DeploymentFailedException: Cannot deploy
>         application [twitter-counter] from URI
>         [file:/usr/apache-s4-0.5.0-__incubating-src/test-apps/__twitter-counter/build/libs/__twitter-counter.s4r]
>         : cannot start application
>               at
>         org.apache.s4.deploy.__DistributedDeploymentManager.__deployApplication(__DistributedDeploymentManager.__java:134)
>         ~[s4-core-0.5.0-incubating.__jar:0.5.0-incubating]
>               at
>         org.apache.s4.deploy.__DistributedDeploymentManager.__start(__DistributedDeploymentManager.__java:181)
>         ~[s4-core-0.5.0-incubating.__jar:0.5.0-incubating]
>               at org.apache.s4.core.Server.__start(Server.java:87)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at org.apache.s4.core.Main.__startNode(Main.java:150)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at org.apache.s4.core.Main.main(__Main.java:75)
>         [s4-core-0.5.0-incubating.jar:__0.5.0-incubating]
>               at sun.reflect.__NativeMethodAccessorImpl.__invoke0(Native
>         Method)
>         ~[na:1.6.0_22]
>               at
>         sun.reflect.__NativeMethodAccessorImpl.__invoke(__NativeMethodAccessorImpl.java:__57)
>         ~[na:1.6.0_22]
>               at
>         sun.reflect.__DelegatingMethodAccessorImpl.__invoke(__DelegatingMethodAccessorImpl.__java:43)
>         ~[na:1.6.0_22]
>               at java.lang.reflect.Method.__invoke(Method.java:616)
>         ~[na:1.6.0_22]
>               at org.apache.s4.tools.Tools$__Task.dispatch(Tools.java:54)
>         [s4-tools-0.5.0-incubating.__jar:0.5.0-incubating]
>               at org.apache.s4.tools.Tools.__main(Tools.java:94)
>         [s4-tools-0.5.0-incubating.__jar:0.5.0-incubating]
>         16:36:51.598 [ZkClient-EventThread-25-__testing.machine1:2181] INFO
>         o.a.s4.comm.topology.__ClusterFromZK - Changing cluster topology
>         to {
>         nbNodes=2,name=cluster1,mode=__unicast,type=,nodes=[{__partition=0,port=12000,__machineName=testing.machine1,__taskId=Task-0},
>         {partition=1,port=12001,__machineName=testing.machine1,__taskId=Task-1}]}
>         from {
>         nbNodes=1,name=cluster1,mode=__unicast,type=,nodes=[{__partition=0,port=12000,__machineName=testing.machine1,__taskId=Task-0}]}
>         16:36:51.601 [ZkClient-EventThread-19-__testing.machine1:2181] INFO
>         o.a.s4.comm.topology.__ClusterFromZK - Changing cluster topology
>         to {
>         nbNodes=2,name=cluster1,mode=__unicast,type=,nodes=[{__partition=0,port=12000,__machineName=testing.machine1,__taskId=Task-0},
>         {partition=1,port=12001,__machineName=testing.machine1,__taskId=Task-1}]}
>         from {
>         nbNodes=1,name=cluster1,mode=__unicast,type=,nodes=[{__partition=0,port=12000,__machineName=testing.machine1,__taskId=Task-0}]}
>
>
>
>
>
>
>
> --
> Sincerely,
> Zheng Yu
> Mobile:  (852) 60670059
> Email: bearzheng2011@gmail.com <mailto:bearzheng2011@gmail.com>
>
>
>


Mime
View raw message