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
