flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Krishnanand Khambadkone <kkhambadk...@yahoo.com>
Subject Twitter example
Date Tue, 29 Aug 2017 21:53:12 GMT
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