PailTap in its sourceConfInit method, when creating its Pail instance, ignores Hadoop configuration provided to it. This present a problem for us. We are using MapR instance of Hadoop and thus the default configuration is obtained from MapR client config directories. Well, we often override those setting with custom ones (in code). For example, instead of using the default MapR filesystem we often use LocalFileSystem (during testing), and thus the tests fail since PailTap resolves to default configuration, which MapR.
It is interesting that in other places in this class PailTap actually uses the provided configuration (when sinking), but it seems to ignore it when sourcing.
PailTap in its sourceConfInit method, when creating its Pail instance, ignores Hadoop configuration provided to it. This present a problem for us. We are using MapR instance of Hadoop and thus the default configuration is obtained from MapR client config directories. Well, we often override those setting with custom ones (in code). For example, instead of using the default MapR filesystem we often use LocalFileSystem (during testing), and thus the tests fail since PailTap resolves to default configuration, which MapR.
It is interesting that in other places in this class PailTap actually uses the provided configuration (when sinking), but it seems to ignore it when sourcing.
The pull request is coming.