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