|
@@ -407,9 +407,9 @@ public class AppConfiguration {
|
|
|
Runnable job = () -> {
|
|
Runnable job = () -> {
|
|
|
long startNs = System.nanoTime();
|
|
long startNs = System.nanoTime();
|
|
|
try {
|
|
try {
|
|
|
- taskLog.info("[ConversionBackfill] executing for offsets=1..7");
|
|
|
|
|
|
|
+ taskLog.info("[ConversionBackfill] executing for offsets=1..5");
|
|
|
ConversionSyncService.SyncResult r = conversionSyncRunner.runBackfillForOffsetsParallel(
|
|
ConversionSyncService.SyncResult r = conversionSyncRunner.runBackfillForOffsetsParallel(
|
|
|
- List.of(-1, -2, -3, -4, -5, -6, -7), 3);
|
|
|
|
|
|
|
+ List.of(-1, -2, -3, -4, -5), 3);
|
|
|
long costMs = java.util.concurrent.TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs);
|
|
long costMs = java.util.concurrent.TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs);
|
|
|
taskLog.info("[ConversionBackfill] done: fetched={} matched={} sent={} failed={} skipped={} alreadySent={}",
|
|
taskLog.info("[ConversionBackfill] done: fetched={} matched={} sent={} failed={} skipped={} alreadySent={}",
|
|
|
r.fetched.get(), r.matched.get(), r.sent.get(), r.failed.get(),
|
|
r.fetched.get(), r.matched.get(), r.sent.get(), r.failed.get(),
|