@@ -160,7 +160,7 @@ private void submitReconciliationExecution(ResourceState state) {
160
160
state .unMarkEventReceived ();
161
161
metrics .reconcileCustomResource (state .getId (), state .getRetry (), metricsMetadata );
162
162
log .debug ("Executing events for custom resource. Scope: {}" , executionScope );
163
- executor .execute (new ControllerExecution (executionScope ));
163
+ executor .execute (new ReconcilerExecutor (executionScope ));
164
164
} else {
165
165
log .debug (
166
166
"Skipping executing controller for resource id: {}. Controller in execution: {}. Latest Resource present: {}" ,
@@ -376,10 +376,10 @@ private void handleAlreadyMarkedEvents() {
376
376
}
377
377
}
378
378
379
- private class ControllerExecution implements Runnable {
379
+ private class ReconcilerExecutor implements Runnable {
380
380
private final ExecutionScope <R > executionScope ;
381
381
382
- private ControllerExecution (ExecutionScope <R > executionScope ) {
382
+ private ReconcilerExecutor (ExecutionScope <R > executionScope ) {
383
383
this .executionScope = executionScope ;
384
384
}
385
385
@@ -390,7 +390,7 @@ public void run() {
390
390
final var name = thread .getName ();
391
391
try {
392
392
MDCUtils .addResourceInfo (executionScope .getResource ());
393
- thread .setName ("EventHandler -" + controllerName );
393
+ thread .setName ("ReconcilerExecutor -" + controllerName + "-" + thread . getId () );
394
394
PostExecutionControl <R > postExecutionControl =
395
395
reconciliationDispatcher .handleExecution (executionScope );
396
396
eventProcessingFinished (executionScope , postExecutionControl );
0 commit comments