flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Krishnanand Khambadkone <kkhambadk...@yahoo.com>
Subject Re: Twitter example
Date Wed, 30 Aug 2017 15:20:07 GMT
I am running this standalone, not under yarn,  on a single instance setup.  I believe you are
referring to the flink log files

Sent from my iPhone

> On Aug 30, 2017, at 12:56 AM, Fabian Hueske <fhueske@gmail.com> wrote:
> 
>    Fabian Hueske (fhueske@gmail.com) is not on your Guest List | Approve sender | Approve
domain 
> Hi,
> 
> print() writes the data to the out files of the TaskManagers. So you need to go to the
machine that runs the TM and check its out file which is located in the log folder.
> 
> Best, Fabian
> 
> 2017-08-29 23:53 GMT+02:00 Krishnanand Khambadkone <kkhambadkone@yahoo.com>:
>> I am trying to run the basic twitter example,  it does deploy correctly and show
as RUNNING both in the command line and in the UI.  However I see no output.  I am able to
verify that my credentials are correct with another small client I have built that does connect
to twitter and prints out tweets.
>> 
>> 
>>                 streamSource = env.addSource(new TwitterSource(props));
>>                 streamSource.print();
>> 
>> 
>> 
>> 
>> *************** TWITTER INPUTS *************
>> qzenHPFVPNb7GaEypSvp3yV3s : XQuQHpOklVnUHEUTmtEbePU7O80Vaj5mwWnvNMrGyBiSsML9dA :
78358289-rjJ44rtlFr5BlTMyNPzDjQq6daOMT7PnQVvkGgwgO : IAr1eoCbBuJRkaERcKFxv5mFAOu6KPr7Q2EmAZYRXmedl
>> ********************* FOUND PROPERTIES *****************
>> Submitting job with JobID: de6024b484fc1d163b4190011595e4f0. Waiting for job completion.
>> Connected to JobManager at Actor[akka.tcp://flink@localhost:6123/user/jobmanager#1901137740]
with leader session id 00000000-0000-0000-0000-000000000000.
>> 08/29/2017 14:25:32	Job execution switched to status RUNNING.
>> 08/29/2017 14:25:32	Source: Custom Source -> Sink: Unnamed(1/1) switched to SCHEDULED

>> 08/29/2017 14:25:32	Source: Custom Source -> Sink: Unnamed(1/1) switched to DEPLOYING

>> 08/29/2017 14:25:32	Source: Custom Source -> Sink: Unnamed(1/1) switched to RUNNING
>> 
> 

Mime
View raw message