Re: Query on RestartPipelinedRegionFailoverStrategy

Hi Prabhu, If the edge between a -> b -> c -> d -> e all are point-wise, In theory, it should form two regions. Best regards, Weijie Prabhu Joseph 于2023年5月15日周一 09:58写道： > Hi, I am testing the Flink Fine-Grained Recovery >

Re: StreamTable Environment initialized failed -- "Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath"

Hi  Sharil, I've tried your suggestion, but unfortunately it does not work, same exception. Any other ideas ? Thanks, Leo 在 2023/5/15 20:15, Sharil Shafie 写道: Hi, May be you could try table planner loader instead. org.apache.flink flink-table-planner-loader     1.16.0     provided

Re: StreamTable Environment initialized failed -- "Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath"

Hi krislee, I think you can try to add the path of jars in FLINK_HOME to the classpath of your command, such as 1. mvn exec:java -Dexec.mainClass="xxx" -Dexec.classpathScope="your classpath" 2. java -jar target/xxx.jar -cp {your classpath} Or you can run your application in IDE directly after th

Re: StreamTable Environment initialized failed -- "Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath"

hi: I think there may be the following reasons： 1、the scope of dependency is 'provided' in your "pom.xml" 。When you package, this dependency will not be included in the jar. and you xxx.jar execution enviroment lack this dependency 2、i can not see the "pom.xml" completely,can you add the dependen

Re: StreamTable Environment initialized failed -- "Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath"

Hi, May be you could try table planner loader instead. org.apache.flink flink-table-planner-loader 1.16.0 provided Regards. On Mon, 15 May 2023, 18:54 krislee, wrote: > Hi ALL, > > OS: CentOS 7.9 > > Flink version: 1.16.0 > > > It looks like I'm hitting a notorious ex

Re: JVM Metaspace for Task Mangers and Job Managers are not getting released.

Thanks for the information. On Mon, May 15, 2023 at 1:46 AM Shammon FY wrote: > Hi Ajinkya, > > The command 'jcmd GC.run' can be used to trigger fullgc for JVM > process. However, it should be noted that this may have a performance > impact on the ongoing computation. > > Best, > Shammon FY > >

StreamTable Environment initialized failed -- "Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath"

Hi  ALL, OS:   CentOS 7.9 Flink version:  1.16.0 It looks like  I'm hitting a  notorious exception which had been discoverd since earlier fink version.  The issue was triggered when below java code executed:    StreamTableEnvironment tEnv = StreamTableEnvironment.create(env); More detaile

Re: How to know when a pipeline ends

Hi Luke, Did you try to use *env.registerJobListener()* to be notified on job execution? https://coderstea.in/post/big-data/flink-job-listener-run-a-task-after-flink-job-is-completed/ Best regards, Alex On Fri, May 12, 2023 at 8:01 PM Luke Xiong wrote: > Hi Weihua and Shammon, > > Thanks for