[flink] Use versioned action jars

Author: platinumhamburg

fluss-flink/fluss-flink-1.18/pom.xml

@@ -219,11 +219,19 @@
                                     <include>org.apache.fluss:fluss-client</include>
                                 </includes>
                             </artifactSet>
+                            <filters combine.children="append">
+                                <filter>
+                                    <artifact>org.apache.fluss:fluss-flink-common</artifact>
+                                    <excludes>
+                                        <exclude>org/apache/fluss/flink/action/**</exclude>
+                                    </excludes>
+                                </filter>
+                            </filters>
                         </configuration>
                     </execution>
                 </executions>
             </plugin>
         </plugins>
     </build>
 
-</project>
+</project>

fluss-flink/fluss-flink-1.18/src/main/resources/META-INF/services/org.apache.fluss.flink.action.ActionFactory

@@ -213,11 +213,16 @@
                                     <include>org.apache.fluss:fluss-client</include>
                                 </includes>
                             </artifactSet>
+                            <transformers combine.children="append">
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>org.apache.fluss.flink.action.FlussActionEntrypoint</mainClass>
+                                </transformer>
+                            </transformers>
                         </configuration>
                     </execution>
                 </executions>
             </plugin>
         </plugins>
     </build>
 
-</project>
+</project>

fluss-flink/fluss-flink-1.19/pom.xml

@@ -234,11 +234,16 @@
                                     <include>org.apache.fluss:fluss-client</include>
                                 </includes>
                             </artifactSet>
+                            <transformers combine.children="append">
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>org.apache.fluss.flink.action.FlussActionEntrypoint</mainClass>
+                                </transformer>
+                            </transformers>
                         </configuration>
                     </execution>
                 </executions>
             </plugin>
         </plugins>
     </build>
 
-</project>
+</project>

fluss-flink/fluss-flink-1.20/pom.xml

@@ -258,6 +258,11 @@
                                     <include>org.apache.fluss:fluss-client</include>
                                 </includes>
                             </artifactSet>
+                            <transformers combine.children="append">
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>org.apache.fluss.flink.action.FlussActionEntrypoint</mainClass>
+                                </transformer>
+                            </transformers>
                         </configuration>
                     </execution>
                 </executions>

fluss-flink/fluss-flink-2.2/pom.xml

@@ -45,6 +45,10 @@ public static Optional<Action> createAction(String[] args) {
             printDefaultHelp();
             return Optional.empty();
         }
+        if (isHelp(args[0])) {
+            printDefaultHelp();
+            return Optional.empty();
+        }
         String name = args[0].toLowerCase().replace('-', '_');
         ActionFactory factory =
                 findFactory(name)
@@ -55,14 +59,27 @@ public static Optional<Action> createAction(String[] args) {
                                                         + args[0]
                                                         + ". Run with --help for available actions."));
         String[] remaining = Arrays.copyOfRange(args, 1, args.length);
-        MultipleParameterToolAdapter params = MultipleParameterToolAdapter.fromArgs(remaining);
-        if (params.has("help")) {
+        if (hasHelp(remaining)) {
             System.out.println(factory.help());
             return Optional.empty();
         }
+        MultipleParameterToolAdapter params = MultipleParameterToolAdapter.fromArgs(remaining);
         return factory.create(params);
     }
 
+    private static boolean isHelp(String arg) {
+        return "--help".equals(arg) || "-h".equals(arg);
+    }
+
+    private static boolean hasHelp(String[] args) {
+        for (String arg : args) {
+            if (isHelp(arg)) {
+                return true;
+            }
+        }
+        return false;
+    }
+
     private static Optional<ActionFactory> findFactory(String identifier) {
         for (ActionFactory f : ServiceLoader.load(ActionFactory.class)) {
             if (f.identifier().equals(identifier)) {

fluss-flink/fluss-flink-action/pom.xml

@@ -19,7 +19,7 @@
 
 import java.util.Optional;
 
-/** Main entrypoint for the Fluss Flink action jar. Delegates to {@link ActionLoader}. */
+/** Main entrypoint for Fluss Flink action jars. Delegates to {@link ActionLoader}. */
 public class FlussActionEntrypoint {
 
     public static void main(String[] args) throws Exception {

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/action/ActionLoader.java

@@ -38,7 +38,6 @@
         <module>fluss-flink-1.18</module>
         <module>fluss-flink-2.2</module>
         <module>fluss-flink-tiering</module>
-        <module>fluss-flink-action</module>
     </modules>
 
     <!-- override these root dependencies as 'provided', so they don't end up
@@ -77,4 +76,4 @@
         </plugins>
     </build>
 
-</project>
+</project>