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 = getSizeInternal(
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 = materializedAt.getSize(getPipe