panshi106

感觉是StarRocksOutputFormat类中writeMultipleRecordsInternal方法中if (rows.size() != batchSize) { streamLoadManager.flush(null, false); } 这个if判断感觉有问题，会让数据积压到最后一次才全部flush，所以会导致oom，去掉if判断就好了