apache · sercuzz8 · Aug 5, 2026 · Aug 28, 2026 · Aug 29, 2026
diff --git a/.mvn/.gitkeep b/.mvn/.gitkeep
diff --git a/examples/storm-hdfs-examples/pom.xml b/examples/storm-hdfs-examples/pom.xml
@@ -93,6 +93,11 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.gmavenplus</groupId>
+                <artifactId>gmavenplus-plugin</artifactId>
+                <!--Note - the version/config would be inherited-->
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java b/examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java
@@ -180,7 +180,7 @@ public void execute(Tuple tuple) {
 
         @Override
         public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            // this bolt does not emit anything
+        // this bolt does not emit anything
         }
 
         @Override

diff --git a/...es/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileTopology.java b/...es/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileTopology.java
@@ -25,8 +25,8 @@
 import org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat;
 import org.apache.storm.hdfs.bolt.format.FileNameFormat;
 import org.apache.storm.hdfs.bolt.rotation.FileRotationPolicy;
-import org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy;
 import org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy.Units;
+import org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy;
 import org.apache.storm.hdfs.bolt.sync.CountSyncPolicy;
 import org.apache.storm.hdfs.bolt.sync.SyncPolicy;
 import org.apache.storm.hdfs.common.rotation.MoveFileAction;
@@ -189,7 +189,7 @@ public void execute(Tuple tuple) {
 
         @Override
         public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            // this bolt does not emit anything
+        // this bolt does not emit anything
         }
 
         @Override

diff --git a/examples/storm-jdbc-examples/pom.xml b/examples/storm-jdbc-examples/pom.xml
@@ -85,6 +85,11 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.gmavenplus</groupId>
+                <artifactId>gmavenplus-plugin</artifactId>
+                <!--Note - the version/config would be inherited-->
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java b/examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java
@@ -19,11 +19,9 @@
 package org.apache.storm.jdbc.spout;
 
 import com.google.common.collect.Lists;
-
 import java.util.List;
 import java.util.Map;
 import java.util.Random;
-
 import org.apache.storm.spout.SpoutOutputCollector;
 import org.apache.storm.task.TopologyContext;
 import org.apache.storm.topology.IRichSpout;

diff --git a/...torm-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java b/...torm-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java
@@ -20,11 +20,9 @@
 
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
-
 import java.sql.Types;
 import java.util.List;
 import java.util.Map;
-
 import org.apache.storm.Config;
 import org.apache.storm.StormSubmitter;
 import org.apache.storm.generated.StormTopology;

diff --git a/...m-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/UserPersistenceTopology.java b/...m-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/UserPersistenceTopology.java
@@ -19,10 +19,8 @@
 package org.apache.storm.jdbc.topology;
 
 import com.google.common.collect.Lists;
-
 import java.sql.Types;
 import java.util.List;
-
 import org.apache.storm.generated.StormTopology;
 import org.apache.storm.jdbc.bolt.JdbcInsertBolt;
 import org.apache.storm.jdbc.bolt.JdbcLookupBolt;

diff --git a/...examples/src/main/java/org/apache/storm/jdbc/topology/UserPersistenceTridentTopology.java b/...examples/src/main/java/org/apache/storm/jdbc/topology/UserPersistenceTridentTopology.java
@@ -19,9 +19,7 @@
 package org.apache.storm.jdbc.topology;
 
 import com.google.common.collect.Lists;
-
 import java.sql.Types;
-
 import org.apache.storm.generated.StormTopology;
 import org.apache.storm.jdbc.common.Column;
 import org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper;

diff --git a/examples/storm-jms-examples/pom.xml b/examples/storm-jms-examples/pom.xml
@@ -105,6 +105,11 @@
                 </executions>
 
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.gmavenplus</groupId>
+                <artifactId>gmavenplus-plugin</artifactId>
+                <!--Note - the version/config would be inherited-->
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/examples/storm-kafka-client-examples/pom.xml b/examples/storm-kafka-client-examples/pom.xml
@@ -103,6 +103,11 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.gmavenplus</groupId>
+                <artifactId>gmavenplus-plugin</artifactId>
+                <!--Note - the version/config would be inherited-->
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/examples/storm-loadgen/pom.xml b/examples/storm-loadgen/pom.xml
@@ -122,6 +122,11 @@
           </execution>
         </executions>
       </plugin>
+      <plugin>
+          <groupId>org.codehaus.gmavenplus</groupId>
+          <artifactId>gmavenplus-plugin</artifactId>
+          <!--Note - the version/config would be inherited-->
+      </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/...les/storm-loadgen/src/main/java/org/apache/storm/loadgen/ExecAndProcessLatencyEngine.java b/...les/storm-loadgen/src/main/java/org/apache/storm/loadgen/ExecAndProcessLatencyEngine.java
@@ -67,7 +67,7 @@ public void sleepNano(long start, long sleepAmount) {
         long diff = newEnd - start;
         //There are some different levels of accuracy here, and we want to deal with all of them
         if (diff <= 1_000) {
-            //We are done, nothing that short is going to work here
+        //We are done, nothing that short is going to work here
         } else if (diff < NANO_IN_MS) {
             //Busy wait...
             long sum = 0;

diff --git a/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java b/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java
@@ -184,7 +184,7 @@ public Builder withGroupingType(Grouping grouping) {
                     } catch (Exception e) {
                         //ignored
                     }
-                    //Fall through if not supported
+                //Fall through if not supported
                 default:
                     LOG.warn("{} is not supported for replay of a topology.  Using SHUFFLE", thriftType);
                     break;

diff --git a/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java b/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java
@@ -319,7 +319,7 @@ private static class NoCloseOutputStream extends FilterOutputStream {
 
         @Override
         public void close() {
-            //NOOP on purpose
+        //NOOP on purpose
         }
     }
 
@@ -363,7 +363,7 @@ abstract static class FileReporter implements MetricResultsReporter {
 
         @Override
         public void start() {
-            //NOOP
+        //NOOP
         }
 
         @Override

diff --git a/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/LoadCompConfTest.java b/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/LoadCompConfTest.java
@@ -18,10 +18,10 @@
 
 package org.apache.storm.loadgen;
 
-import org.junit.jupiter.api.Test;
-
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
+import org.junit.jupiter.api.Test;
+
 public class LoadCompConfTest {
     @Test
     public void scaleParallel() {
@@ -54,4 +54,4 @@ public void scaleThroughput() {
         //But throughput is the same
         assertEquals(1000.0, scaled.getAllEmittedAggregate(), 0.001);
     }
-}
+}
diff --git a/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/LoadMetricsServerTest.java b/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/LoadMetricsServerTest.java
@@ -18,12 +18,12 @@
 
 package org.apache.storm.loadgen;
 
+import static org.apache.storm.loadgen.LoadMetricsServer.convert;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
 import java.util.concurrent.TimeUnit;
 import org.junit.jupiter.api.Test;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.apache.storm.loadgen.LoadMetricsServer.convert;
-
 public class LoadMetricsServerTest {
     @Test
     public void convertTest() {
@@ -34,4 +34,4 @@ public void convertTest() {
             }
         }
     }
-}
+}
diff --git a/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/NormalDistStatsTest.java b/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/NormalDistStatsTest.java
@@ -18,10 +18,10 @@
 
 package org.apache.storm.loadgen;
 
-import org.junit.jupiter.api.Test;
-
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
+import org.junit.jupiter.api.Test;
+
 public class NormalDistStatsTest {
     public static void assertNDSEquals(NormalDistStats a, NormalDistStats b) {
         assertEquals(a.mean, b.mean, 0.0001, "mean");
@@ -40,4 +40,4 @@ public void scaleBy() {
         assertNDSEquals(expectedHalf, orig.scaleBy(0.5));
     }
 
-}
+}
diff --git a/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/OutputStreamTest.java b/examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/OutputStreamTest.java
@@ -18,10 +18,10 @@
 
 package org.apache.storm.loadgen;
 
-import org.junit.jupiter.api.Test;
-
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
+import org.junit.jupiter.api.Test;
+
 public class OutputStreamTest {
     @Test
     public void scaleThroughput() {
@@ -34,4 +34,4 @@ public void scaleThroughput() {
         assertEquals(scaled.rate.min, 199.0, 0.0001);
         assertEquals(scaled.rate.max, 201.0, 0.0001);
     }
-}
+}
diff --git a/examples/storm-perf/pom.xml b/examples/storm-perf/pom.xml
@@ -86,6 +86,11 @@
                     <mainClass>${storm.topology}</mainClass>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.gmavenplus</groupId>
+                <artifactId>gmavenplus-plugin</artifactId>
+                <!--Note - the version/config would be inherited-->
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/examples/storm-perf/src/main/java/org/apache/storm/perf/JitterAwareGroupingTopology.java b/examples/storm-perf/src/main/java/org/apache/storm/perf/JitterAwareGroupingTopology.java
@@ -343,7 +343,7 @@ public void execute(Tuple tuple) {
 
         @Override
         public void declareOutputFields(OutputFieldsDeclarer declarer) {
-            // terminal — no output
+        // terminal — no output
         }
     }
 }
diff --git a/examples/storm-perf/src/main/java/org/apache/storm/perf/KafkaClientSpoutNullBoltTopo.java b/examples/storm-perf/src/main/java/org/apache/storm/perf/KafkaClientSpoutNullBoltTopo.java
@@ -22,8 +22,8 @@
 import org.apache.storm.generated.StormTopology;
 import org.apache.storm.kafka.spout.FirstPollOffsetStrategy;
 import org.apache.storm.kafka.spout.KafkaSpout;
-import org.apache.storm.kafka.spout.KafkaSpoutConfig;
 import org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee;
+import org.apache.storm.kafka.spout.KafkaSpoutConfig;
 import org.apache.storm.perf.bolt.DevNullBolt;
 import org.apache.storm.perf.utils.Helper;
 import org.apache.storm.topology.TopologyBuilder;

diff --git a/examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/AckingProducer.java b/examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/AckingProducer.java
@@ -51,12 +51,12 @@ public void run() {
     private class Handler implements JCQueue.Consumer {
         @Override
         public void accept(Object event) {
-            // no-op
+        // no-op
         }
 
         @Override
         public void flush() {
-            // no-op
+        // no-op
         }
     }
 }
diff --git a/examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Consumer.java b/examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Consumer.java
@@ -57,7 +57,7 @@ public void accept(Object event) {
 
         @Override
         public void flush() {
-            // no-op
+        // no-op
         }
     }
 }
diff --git a/examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Forwarder.java b/examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Forwarder.java
@@ -64,7 +64,7 @@ public void accept(Object event) {
 
         @Override
         public void flush() {
-            // no-op
+        // no-op
         }
     }
 }
diff --git a/examples/storm-redis-examples/pom.xml b/examples/storm-redis-examples/pom.xml
@@ -89,6 +89,11 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.codehaus.gmavenplus</groupId>
+                <artifactId>gmavenplus-plugin</artifactId>
+                <!--Note - the version/config would be inherited-->
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-checkstyle-plugin</artifactId>

diff --git a/...examples/src/main/java/org/apache/storm/redis/tools/Base64ToBinaryStateMigrationUtil.java b/...examples/src/main/java/org/apache/storm/redis/tools/Base64ToBinaryStateMigrationUtil.java
@@ -21,7 +21,6 @@
 import java.io.IOException;
 import java.util.HashMap;
 import java.util.Map;
-
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.DefaultParser;

diff --git a/...s/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/LookupWordCount.java b/...s/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/LookupWordCount.java
@@ -19,11 +19,9 @@
 package org.apache.storm.redis.topology;
 
 import com.google.common.collect.Lists;
-
 import java.util.List;
 import java.util.Map;
 import java.util.Random;
-
 import org.apache.storm.Config;
 import org.apache.storm.StormSubmitter;
 import org.apache.storm.redis.bolt.RedisLookupBolt;
@@ -39,7 +37,6 @@
 import org.apache.storm.tuple.ITuple;
 import org.apache.storm.tuple.Tuple;
 import org.apache.storm.tuple.Values;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/...torm-redis-examples/src/main/java/org/apache/storm/redis/topology/WhitelistWordCount.java b/...torm-redis-examples/src/main/java/org/apache/storm/redis/topology/WhitelistWordCount.java
@@ -20,7 +20,6 @@
 
 import java.util.Map;
 import java.util.Random;
-
 import org.apache.storm.Config;
 import org.apache.storm.StormSubmitter;
 import org.apache.storm.redis.bolt.RedisFilterBolt;

diff --git a/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java b/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java
@@ -19,9 +19,7 @@
 package org.apache.storm.redis.topology;
 
 import com.google.common.collect.Maps;
-
 import java.util.Map;
-
 import org.apache.storm.task.TopologyContext;
 import org.apache.storm.topology.BasicOutputCollector;
 import org.apache.storm.topology.IBasicBolt;

diff --git a/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java b/examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java
@@ -21,7 +21,6 @@
 import java.util.Map;
 import java.util.Random;
 import java.util.UUID;
-
 import org.apache.storm.spout.SpoutOutputCollector;
 import org.apache.storm.task.TopologyContext;
 import org.apache.storm.topology.IRichSpout;

diff --git a/...ples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/PrintFunction.java b/...ples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/PrintFunction.java
@@ -19,11 +19,9 @@
 package org.apache.storm.redis.trident;
 
 import java.util.Random;
-
 import org.apache.storm.trident.operation.BaseFunction;
 import org.apache.storm.trident.operation.TridentCollector;
 import org.apache.storm.trident.tuple.TridentTuple;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;