Chris K Wensel
Chris K Wensel
Local mode should set this property so that operations have access to the current file being processed.
Step/SliceCounters sums durations in wall clock milliseconds, but some read or write operations may be very short. The fear is we are introducing a lot of error by summing ms...
For some reason, Cascading integration was removed from Parquet, https://github.com/apache/parquet-mr/commit/907314ce317e59e25bbf572e891f7ce2a7c70a54. There was much room for improvement, so we can add it back here.
By default, we don't leverage threading server/processing side since it's a highly constrained resource. But in local mode, and when partitioning sink data into multiple files, parallelizing the close operation...
This type should support String representations via Base64.
Even if the name is declared, `$n` should still resolve appropriately.
Currently the empty string in hashed, optionally this should be null.
Seeing this exception sometimes talking to S3. Could be a race condition on directory (key) creates on S3, but there should be no task cleaup when using S3. ```cascading.tap.TapException: exception...
I am attempting to reindex an index into an already created/initialized index with new mapping configurations for given fields (but no existing data). The tool does report success (though it...
### Task List - [x] Steps to reproduce provided - [x] Stacktrace (if present) provided - [x] Example that reproduces the problem (link to git repository is ideal) - [x]...