I have run cascading job(local) in which i am checking whether flow is local or not using stepsAreLocal().
I want to add listener on flowStepStats to get stats if flow is local.
But in cascading-flink, stepsAreLocal() of FlinkFlow class is always returning false, even when job runs in local.
Hence i am unable to add listener to get stats.
I have tested above scenario using Hadoop2MR1FlowConnector and Hadoop2TezFlowConnector, stepsAreLocal() returns true for cascading job(local).
I am using below version of jar :
cascading : 3.1.0
cascading-flink : 0.3.0
hadoop : 2.6.0
Can someone please help why stepsAreLocal() method in FlinkFlow class is returning false while running jobs in local?
Thanks
Santlal Gupta