Add dynamic partition support for AbstractFSDirectoryInputOperator
operator.
Fix AbstractFSDirectoryInputOperatorTest
Merge branch 'tushargosavi-MLHR-1203'
test setting kafka producer properties
Add support for retrying processing of files on which read failed in middle.
added @ShipContatingJars and benchmark application

Conflicts:
	contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraTransactionableOutputOperatorPS.java
Add test case for handling failed files.
Merge branch 'SPOI-2620' of https://github.com/tushargosavi/Malhar into tushargosavi-SPOI-2620
Merge branch 'tushargosavi-SPOI-2620'