z1wu

Results 6 comments of z1wu

I have the same problem, even when I run the demo.py provided by author. It looks like when "area == easy | area == hard " the result will be...

Maybe we don't need to generate random number, I currently use a task Id get from `SinkWriter.Context` as a work-around. ``` java this.taskIndex = context.getIndexOfSubtask(); ```

I also agree that these metrics would be very useful for troubleshooting. I have noticed that in current implementation, metrics of `ExecuteStatement exec_time` is got within `org.apache.kyuubi.operation.ExecuteStatement`. I wonder if...

In which scenarios will the Batch corresponding to the PushDataRequest with HARD_SPLIT response be appended to the PartitionLocation datafile? @RexXiong

> However, when a partition encounters a HardSplit, the affected batches need to be resubmitted, but these resubmitted batches would definitively not write to their previous partition locations. Therefore, Celeborn...