Not able to start Rule Engine

Products

• CA Automic Workload Automation - Automation Engine

Issue/Introduction

Simple rule event can not start in Analytics:

Below error is visible:

Caused by: org.apache.flink.util.FlinkException: Could not run the jar.
        ... 9 more
Caused by: org.apache.flink.client.program.ProgramInvocationException: The program caused an error:
        at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:93)
        at org.apache.flink.client.program.ClusterClient.getOptimizedPlan(ClusterClient.java:334)
        at org.apache.flink.runtime.webmonitor.handlers.JarActionHandler.getJobGraphAndClassLoader(JarActionHandler.java:87)
        at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleJsonRequest$0(JarRunHandler.java:69)
        ... 8 more
Caused by: java.lang.NoClassDefFoundError: Lorg/apache/flink/api/common/io/ratelimiting/FlinkConnectorRateLimiter;
        at java.lang.Class.getDeclaredFields0(Native Method)
        at java.lang.Class.privateGetDeclaredFields(Class.java:2583)
        at java.lang.Class.getDeclaredField(Class.java:2068)
        at java.io.ObjectStreamClass.getDeclaredSUID(ObjectStreamClass.java:1872)
        at java.io.ObjectStreamClass.access$700(ObjectStreamClass.java:79)
        at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:506)
        at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:494)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:494)
        at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391)
        at java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:490)
        at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391)
        at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1134)
        at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
        at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:447)
        at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:81)
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:1550)
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1462)
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1406)
        at com.automic.analytics.rule.engine.RuleEngine.run(RuleEngine.java:77)
        at com.automic.analytics.rule.simple.SimpleRuleExecution.main(SimpleRuleExecution.java:48)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:525)
        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:417)
        at org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83)
        ... 11 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.io.ratelimiting.FlinkConnectorRateLimiter
        at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
        ... 39 more

        at com.automic.analytics.backend.rule.FlinkMonitoringService.parseResponse(FlinkMonitoringService.java:307)
        at com.automic.analytics.backend.rule.FlinkMonitoringService.runJar(FlinkMonitoringService.java:206)
                                                                                                                     

Environment

Release : 12.3

Component : Automic Workload Automation

Sub-Component: Analytics

Cause

Wrong Package.Rule.Simple 1.4.0 attached to the AWA 12.3 release

Resolution

Use the attached Package.Rule.Simple 1.3.0 for AWA 12.3 release

Additional Information

Package.Rule.Simple 1.1 >>> compatible with AWI 12.1 - 12.2
Package.Rule.Simple 1.3 >>> compatible with AWI 12.3 
Package.Rule.Simple 1.4 >>> compatible with AE 21.0