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 <kkhambadk...@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 > >
