NPE when using spring bean in custom input format

[madan]

Hi,

Need help in the below scenario,

I have CustomInputFormat which loads the records using a bean,

public class CustomInputFormat extends GenericInputFormat {

      private Iterator<Map<String, Object>> recordsIterator;

      @Override

        public void open(GenericInputSplit split) throws IOException {

               ServiceX serviceX = SpringBeanFinder.getBean(ServiceX.class);

                recordsIterator = serviceX.getRecords(..);

         }

}

The above input format works fine when using Flink LocalEnvironment in
spring application. Problem is when running flink in a cluster mode and
trying to connect to it using RemoveEnvironment. Since Spring applicaiton
context will not be initialized, NPE is thrown. Please suggest what could
be the solution in this scenario.



-- 
Thank you,
Madan.