Re: temporary table size is 0, which makes reducer number too small

i may found the root cause in my case： public void materializeAt(SourceTarget sourceTarget) { this.materializedAt = sourceTarget; this.size = materializedAt.getSize(getPipeline().getConfiguration()); } @Override public long getSize() { if (size < 0) { this.size =

Re: temporary table size is 0, which makes reducer number too small

Yep, that's right-- can you file a JIRA, and I'll post the patch? On Mon, Oct 17, 2016 at 10:52 PM, 陈竞 wrote: > i may found the root cause in my case： > > public void materializeAt(SourceTarget sourceTarget) { > this.materializedAt = sourceTarget; > this.size =