This is an automated email from the ASF dual-hosted git repository.

rzo1 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/master by this push:
     new 48de7483c #7947 - IWorkerHook: remove erroneous recursive call
48de7483c is described below

commit 48de7483cfa9dd79bebdb51d1f678a09a0edaa4d
Author: reiabreu <[email protected]>
AuthorDate: Mon Feb 17 19:19:51 2025 +0000

    #7947 - IWorkerHook: remove erroneous recursive call
    
    * 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
---
 .../src/jvm/org/apache/storm/hooks/IWorkerHook.java       | 15 ++-------------
 1 file changed, 2 insertions(+), 13 deletions(-)

diff --git a/storm-client/src/jvm/org/apache/storm/hooks/IWorkerHook.java 
b/storm-client/src/jvm/org/apache/storm/hooks/IWorkerHook.java
index 7533e1ccd..fa60975f2 100644
--- a/storm-client/src/jvm/org/apache/storm/hooks/IWorkerHook.java
+++ b/storm-client/src/jvm/org/apache/storm/hooks/IWorkerHook.java
@@ -22,18 +22,7 @@ import org.apache.storm.task.WorkerUserContext;
  * 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.
@@ -43,7 +32,7 @@ public interface IWorkerHook extends Serializable {
      * {@link WorkerUserContext#setResource(String, Object)} to set the shared 
application state.
      */
     default void start(Map<String, Object> topoConf, WorkerUserContext 
context) {
-        start(topoConf, context);
+         // NOOP
     }
 
     /**

Reply via email to