Hi, Sandeep. Thank you for reply. No, I only got
2016-05-31 20:34:00,628 INFO com.datatorrent.bufferserver.server.Server: Server started listening at /0:0:0:0:0:0:0:0:45546 2016-05-31 20:34:01,668 INFO com.datatorrent.stram.engine.StreamingContainer: Waiting for pending request. 2016-05-31 20:34:02,172 INFO com.datatorrent.stram.engine.StreamingContainer: Waiting for pending request. 2016-05-31 20:34:02,676 INFO com.datatorrent.stram.engine.StreamingContainer: Waiting for pending request. 2016-05-31 20:34:03,179 INFO com.datatorrent.stram.engine.StreamingContainer: Waiting for pending request. I can continuously see only this message. Do you have any guest why it did not show "Deploy request"? When I ran wordcount example, I can see "Deploy request". I attached screenshot of web UI. Thanks, Junguk 2016-06-01 1:10 GMT-06:00 Sandeep Deshmukh <[email protected]>: > Thanks for details. > > Typically the "Waiting for pending status" is followed by "Deploy request" > as highlighted below. Are you getting the highlighted line in your log? If > not, the operators is not getting deployed correctly. Please let us know. > > > 2016-05-23 14:46:51,649 DEBUG > com.datatorrent.stram.engine.StreamingContainer: buffer server memory 512 > 2016-05-23 14:46:51,655 INFO > com.datatorrent.bufferserver.storage.DiskStorage: using > /data/hadoop-2.7.2/tmp/nm-local-dir/usercache/sandeep/appcache/application_1463980780220_0003/container_1463980780220_0003_01_000002/tmp > as the basepath for spooling. > 2016-05-23 14:46:51,663 INFO com.datatorrent.bufferserver.server.Server: > Server started listening at /0:0:0:0:0:0:0:0:42358 > 2016-05-23 14:46:51,665 DEBUG > com.datatorrent.stram.engine.StreamingContainer: Buffer server started: > /0:0:0:0:0:0:0:0:42358 > 2016-05-23 14:46:51,700 DEBUG > com.datatorrent.stram.engine.StreamingContainer: Entering heartbeat loop > (interval is 1000 ms) > 2016-05-23 14:46:52,750 INFO > com.datatorrent.stram.engine.StreamingContainer: Waiting for pending > request. > 2016-05-23 14:46:53,255 INFO > com.datatorrent.stram.engine.StreamingContainer: Waiting for pending > request. > 2016-05-23 14:46:56,287 INFO > com.datatorrent.stram.engine.StreamingContainer: Waiting for pending > request. > 2016-05-23 14:46:56,791 INFO > com.datatorrent.stram.engine.StreamingContainer: Waiting for pending > request. > 2016-05-23 14:46:57,295 INFO > com.datatorrent.stram.engine.StreamingContainer: Waiting for pending > request. > 2016-05-23 14:46:57,809 INFO > com.datatorrent.stram.engine.StreamingContainer: Deploy request: > [OperatorDeployInfo[id=1,name=Input,type=INPUT,checkpoint={ffffffffffffffff, > 0, > 0},inputs=[],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=output,streamId=enrich,bufferServer=goofy]]]] > 2016-05-23 14:46:57,811 DEBUG > com.datatorrent.stram.engine.StreamingContainer: Restoring operator 1 to > checkpoint ffffffffffffffff stateless=false. > 2016-05-23 14:46:57,876 DEBUG com.datatorrent.stram.engine.Node: type=INPUT, > operator class=class com.datatorrent.InputFileReader > 2016-05-23 14:46:57,889 DEBUG > com.datatorrent.stram.engine.StreamingContainer: Marking operator 1 as > deployed. > > > Regards, > Sandeep > > Regards, > Sandeep > > On Wed, Jun 1, 2016 at 12:29 PM, Junguk Cho <[email protected]> wrote: >> >> Hi, >> >> 1. I used only one machine and use docker image to run it. >> When I access to ip:8088, it shows I use 8 GB memory. >> (Is there a configuration file I can check?) >> >> 2. Hadoop version : 2.7.1 >> I tested both Apex 3.2.2 and Apex 3.3. >> >> Thanks, >> Junguk >> >> >> 2016-05-31 22:09 GMT-06:00 Sandeep Deshmukh <[email protected]>: >> > Hi Junguk, >> > >> > Could you please give us some details: >> > >> > Hadoop cluster configuration: no of machines and their configuration >> > (memory >> > in particular) >> > Version of Hadoop and Apex >> > >> > Regards, >> > Sandeep >> > >> > On Wed, Jun 1, 2016 at 5:04 AM, Junguk Cho <[email protected]> wrote: >> >> >> >> Hi, >> >> >> >> I am new to apex. >> >> I tried to run demo examples in incubator-apex-malhar. >> >> >> >> When I ran yahoofinance example, I think it was stuck. >> >> Log file said >> >> 2016-05-31 20:34:00,628 INFO >> >> com.datatorrent.bufferserver.server.Server: Server started listening >> >> at /0:0:0:0:0:0:0:0:45546 >> >> 2016-05-31 20:34:01,668 INFO >> >> com.datatorrent.stram.engine.StreamingContainer: Waiting for pending >> >> request. >> >> >> >> I think binding IP address has a problem. >> >> >> >> Does anyone help me? >> >> >> >> >> >> Thanks, >> >> Junguk >> > >> > > >
