Resolve a failing CascadingLocalTest. The testReadFromES() fails because the testWriteToES() never writes to ES. Solution: set the ES_BATCH_SIZE_ENTRIES to 1 in ESLocalScheme.initTargetUrl to make it flush the buffer
The HadoopFlowStep.initFromSink() creates tempSink and resets the ESOutputFormat to to null output format if no output path (mapred.output.dir) is found! That means the output is never send to ES. Solution: Inside ESHadoopScheme.sinkConfInit() set a dummy output path to configuration configuration.
filter-out the null-fields input entries to  resolve the (org.codehaus.jackson.map.JsonMappingException: No serializer found for class org.apache.hadoop.io.NullWritable) exception thrown BufferedRestClient.addToIndex()