Hey all Quick status update. I have started working on a new project for developers that intersects

Hey all Quick note that Cascading 4.5 has been released. This adds support for Hadoop 3.x. This

Hey all Quick note that Cascading 4.1 has been released. This will be the last Hadoop 2.x minor

There are a lot of 'depends' here to work through.. First, I'd see what the gap is to

Hey all Thanks to the team at Foursquare Labs, we have a new WIP with support for Hadoop 3. Special

Can you share what version of Hadoop you are running in the cluster? Also, is this test run on the

Hey all Just a quick note to announce that Cascading 4.0.0 has been released to Maven Central. https:

I made the switch.. For complicated reasons I had to redirect the name servers to reference a new

I'm unsure what outcome you expect? You can always test the sources for size before you plan the

If you stick log4j log declarations into your JobConf, that is then passed to the planner, they will

Sounds like you have a record the regex used by TextDelimited can't parse. If you enable traps

Hi My plan is to release Cascading 4.0 for Hadoop 2 only. When C4 will be released, I'm unsure.

Threading is not happening within the task. We use multithreading to create and run many MR jobs in

Yeah that does help. I figure I could reach into the JSON myself if I use the whole originalRecord

If Hadoop supports gs:// then Cascading supports it. Just know the support may not ship native in

Hi Cascading Buddies, I just pushed a new version of cascading.utils to Conjars. Minor changes

I vaguely recall (could very well be wrong, long time ago) that you have to set this on the

I tried joinWithSmaller, it's also not terminated. So, I was thinking to try something more

Hi, It seems that the version of your hive metastore service is older than that of your hive

Hey, this looks great! Thanks for sharing this with everyone! chris On Jun 28, 2019, at 8:57 AM, Ben

I was able to do this by modifying the HFileoutFormat2 to work with the hadoop.mapred library. I then

Why are you comparing Avro records? Are you using the record as part of a grouping key? Asking

Hi all, I've never really had a good opportunity to deeply understand LARGE (inner) joins in

1. For complex ETL pipelines where we had to apply multiple business rules on incoming data, we found

Hello, I am facing an issue while reading decimal and timestamp type values from a parquet file. I am

Basically we have some join operations that have a small set of keys (100's) and we want want one

Hi Shivank, As Bill Atkinson told me when I first started working at Apple, "Measure, then

I'm using the following code to convert a pipe into a map and use it in a subsequent step: val

Title: Jr. ScrumMaster Location: Denver (DTC) - CO Duration: 6 month contract Experience : 4-5 yrs

see FlowStepJob#blockOnJob() that should get you going in the right direction. but keep in mind this