majialong
Results
1
comments of
majialong
I added logging to verify the race condition. In `MonitorableSinkTask.put()`: ``` @Override public void put(Collection records) { super.put(records); count += records.size(); // add log System.out.println("MonitorableSinkTask: count updated to: " +...