flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Twitter example
Date Wed, 30 Aug 2017 07:56:00 GMT
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