Skip to content

Commit

Permalink
#7947 - IWorkerHook: remove erroneous recursive call
Browse files Browse the repository at this point in the history
* Porting changes from STORM-3693

* Refactoring changes proposed on STORM-3693 and adding an unit test

* Update Executor.java

* Update SpoutExecutor.java

* Update SpoutExecutor.java

* Update SpoutExecutor.java

* Adding missing license

* Adding missing license

* Update IWorkerHook.java
  • Loading branch information
reiabreu authored Feb 17, 2025
1 parent 7eece73 commit 48de748
Showing 1 changed file with 2 additions and 13 deletions.
15 changes: 2 additions & 13 deletions storm-client/src/jvm/org/apache/storm/hooks/IWorkerHook.java
Original file line number Diff line number Diff line change
Expand Up @@ -22,18 +22,7 @@
* when you want to execute operations before topology processing starts, or cleanup operations before your workers shut down.
*/
public interface IWorkerHook extends Serializable {
/**
* This method is called when a worker is started.
*
* @param topoConf The Storm configuration for this worker
* @param context This object can be used to get information about this worker's place within the topology
*
* @deprecated see {@link IWorkerHook#start(Map, WorkerUserContext)}
*/
default void start(Map<String, Object> topoConf, WorkerTopologyContext context) {
// NOOP
}


/**
* This method is called when a worker is started and can be used to do necessary prep-processing and allow initialization of shared
* application state.
Expand All @@ -43,7 +32,7 @@ default void start(Map<String, Object> topoConf, WorkerTopologyContext context)
* {@link WorkerUserContext#setResource(String, Object)} to set the shared application state.
*/
default void start(Map<String, Object> topoConf, WorkerUserContext context) {
start(topoConf, context);
// NOOP
}

/**
Expand Down

0 comments on commit 48de748

Please sign in to comment.