Hi Ravi, I'm moving this thread to the user@flink mailing list, which is designed for these type of questions.
For your issue, I don't think it's related to the elasticsearch integration. It seems like there is something wrong with your log4j setup. Either you have a conflicting log4j jars on the classpath (for Flink 1.13.x, make sure you're using 2.12.1 version [1]) or there is something wrong with the log4j configuration. There are already some stack-overflow threads, describing similar issues [2] (from other projects). [1] https://github.com/apache/flink/blob/release-1.13.3/pom.xml#L110 [2] https://stackoverflow.com/questions/50970960/facing-issue-with-log4j2-java-lang-exceptionininitializererror On Mon, Nov 8, 2021 at 12:26 PM Ravi Sankar Reddy Sangana <ra...@radware.com> wrote: > 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.<init>(MutableLogEvent.java:62) > at > org.apache.logging.log4j.core.impl.MutableLogEvent.<init>(MutableLogEvent.java:70) > at > org.apache.logging.log4j.core.impl.ReusableLogEventFactory.createEvent(ReusableLogEventFactory.java:83) > at > org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:408) > at > org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:63) > at org.apache.logging.log4j.core.Logger.logMessage(Logger.java:154) > at > org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2116) > at > org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2100) > at > org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:1999) > at > org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1858) > at org.apache.logging.slf4j.Log4jLogger.info(Log4jLogger.java:179) > at > org.apache.flink.runtime.util.EnvironmentInformation.logEnvironmentInfo(EnvironmentInformation.java:409) > at > org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.main(StandaloneApplicationClusterEntryPoint.java:55) > Caused by: java.lang.IllegalArgumentException: Initial capacity must be at > least one but was 0 > at > org.apache.logging.log4j.util.SortedArrayStringMap.<init>(SortedArrayStringMap.java:102) > at > org.apache.logging.log4j.core.impl.ContextDataFactory.createContextData(ContextDataFactory.java:109) > at > org.apache.logging.log4j.core.impl.ContextDataFactory.<clinit>(ContextDataFactory.java:57) > ... 13 more > > Build log: > [INFO] Including org.elasticsearch:elasticsearch-cli:jar:6.3.1 in the > shaded jar. > [INFO] Including net.sf.jopt-simple:jopt-simple:jar:5.0.2 in the shaded > jar. > [INFO] Including com.carrotsearch:hppc:jar:0.7.1 in the shaded jar. > [INFO] Including joda-time:joda-time:jar:2.9.9 in the shaded jar. > [INFO] Including com.tdunning:t-digest:jar:3.2 in the shaded jar. > [INFO] Including org.hdrhistogram:HdrHistogram:jar:2.1.9 in the shaded jar. > [INFO] Including org.apache.logging.log4j:log4j-api:jar:2.9.1 in the > shaded jar. > [INFO] Including org.elasticsearch:jna:jar:4.5.1 in the shaded jar. > [INFO] Including > org.elasticsearch.client:elasticsearch-rest-client:jar:6.3.1 in the shaded > jar. > [INFO] Including org.apache.httpcomponents:httpclient:jar:4.5.2 in the > shaded jar. > [INFO] Including org.apache.httpcomponents:httpcore:jar:4.4.5 in the > shaded jar. > [INFO] Including org.apache.httpcomponents:httpasyncclient:jar:4.1.2 in > the shaded jar. > [INFO] Including org.apache.httpcomponents:httpcore-nio:jar:4.4.5 in the > shaded jar. > [INFO] Including commons-codec:commons-codec:jar:1.10 in the shaded jar. > [INFO] Including commons-logging:commons-logging:jar:1.1.3 in the shaded > jar. > [INFO] Including org.elasticsearch.plugin:parent-join-client:jar:6.3.1 in > the shaded jar. > [INFO] Including > org.elasticsearch.plugin:aggs-matrix-stats-client:jar:6.3.1 in the shaded > jar. > [INFO] Including org.elasticsearch.plugin:rank-eval-client:jar:6.3.1 in > the shaded jar. > > > Can you please help in resolving this ?? > > > Regards, > Ravi Sankar Reddy. >
