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
}
/**