Skip to content

Commit 3fafe30

Browse files
committed
ordering params
1 parent 367ac1b commit 3fafe30

File tree

1 file changed

+1
-1
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event

1 file changed

+1
-1
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,14 +36,14 @@ class EventProcessor<R extends HasMetadata> implements EventHandler, LifecycleAw
3636
private static final Logger log = LoggerFactory.getLogger(EventProcessor.class);
3737
private static final long MINIMAL_RATE_LIMIT_RESCHEDULE_DURATION = 50;
3838

39+
private volatile boolean running;
3940
private final Set<ResourceID> underProcessing = new HashSet<>();
4041
private final ReconciliationDispatcher<R> reconciliationDispatcher;
4142
private final Retry retry;
4243
private final Map<ResourceID, RetryExecution> retryState = new HashMap<>();
4344
private final ExecutorService executor;
4445
private final String controllerName;
4546
private final Metrics metrics;
46-
private volatile boolean running;
4747
private final Cache<R> cache;
4848
private final EventSourceManager<R> eventSourceManager;
4949
private final EventMarker eventMarker = new EventMarker();

0 commit comments

Comments
 (0)