I tried getting this in logs..
2018-03-15 20:59:38,154 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask
- No state backend has been configured, using default state
backend (Memory / JobManager)
2018-03-15 20:59:38,296 INFO
org.apache.flink.streaming.api.functions.source.Message
I tried in cluster as well .
On Wed, Mar 14, 2018 at 10:01 PM, Timo Walther wrote:
> Hi Puneet,
>
> are you running this job on the cluster or locally in your IDE?
>
> Regards,
> Timo
>
>
> Am 14.03.18 um 13:49 schrieb Puneet Kinra:
>
> Hi
>
> I used apache bahir connector below is the code.the
Hi Puneet,
are you running this job on the cluster or locally in your IDE?
Regards,
Timo
Am 14.03.18 um 13:49 schrieb Puneet Kinra:
Hi
I used apache bahir connector below is the code.the job is getting
finished
and not generated the output as well ,ideal it should keep on running
below th
Hi
I used apache bahir connector below is the code.the job is getting finished
and not generated the output as well ,ideal it should keep on running below
the code.
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.flink.streaming.api.datastream.DataStream;
import
org.apac
