Elasticsearch6 connector in flink stand alone

Hi Team, I am migrating from flink 1.13 session cluster to stand alone. While converting whenever I added elasticsearch6 connector I am getting a error. Error: Exception in thread "main" java.lang.ExceptionInInitializerError at org.apache.logging.log4j.core.impl.MutableLogEvent.(Mutabl

Reactive mode in 1.13

Hi team, We are planning to move to reactive mode with standalone job for scaling options. While submitting the jobs getting errors saying the kafka conusmers and client related jars are missing even they packed in the fat jar and the same jar is running with normal session cluster. Can any

FW: Time windowing

Hi Team, I am trying to upgrade from 1.7 to 1.13 Code in 1.7 Schema schema = new Schema(); schema.rowtime(new Rowtime() .timestampsFromField("eventTime") .watermarksPeriodicBounded(3000) ); Code in 1.13 tableEnv.executeSql("CREATE TABLE ORDERS ( " + "`sid` BIGINT, " +

Flink table error in 1.11 "Could not find a suitable table factory "

Hi Team, I am trying Flink 1.11 by using the official doc and examples. Here is my code. While executing I am getting this error. Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFacto

Need help in setting up flink 1.10

Hi Team, We are using flink 1.7 currently in prod. We want to move to latest release and trying 1.10. We are using google storage for our checkpoints. In these release we need Hadoop to the integrated from our side. So following this link