This is with Flink 1.3.2. I’ll paste the full contents of the flink lib dir
below, as well as the maven shade config for our job jar.
lib/
-rw-r--r-- 1 root root 62983 Oct 18 18:24 activation-1.1.jar
-rw-r--r-- 1 root root 44925 Oct 18 18:24 apacheds-i18n-2.0.0-M15.jar
-rw-r--r-- 1 root root 691479 Oct 18 18:24
apacheds-kerberos-codec-2.0.0-M15.jar
-rw-r--r-- 1 root root 16560 Oct 18 18:24 api-asn1-api-1.0.0-M20.jar
-rw-r--r-- 1 root root 79912 Oct 18 18:24 api-util-1.0.0-M20.jar
-rw-r--r-- 1 root root 303139 Oct 18 18:24 avro-1.7.4.jar
-rw-r--r-- 1 root root 11948376 Oct 18 18:24 aws-java-sdk-1.7.4.jar
-rw-r--r-- 1 root root 188671 Oct 18 18:24 commons-beanutils-1.7.0.jar
-rw-r--r-- 1 root root 206035 Oct 18 18:24 commons-beanutils-core-1.8.0.jar
-rw-r--r-- 1 root root 52988 Oct 18 18:24 commons-cli-1.3.1.jar
-rw-r--r-- 1 root root 46725 Oct 18 18:24 commons-codec-1.3.jar
-rw-r--r-- 1 root root 588337 Oct 18 18:24 commons-collections-3.2.2.jar
-rw-r--r-- 1 root root 241367 Oct 18 18:24 commons-compress-1.4.1.jar
-rw-r--r-- 1 root root 298829 Oct 18 18:24 commons-configuration-1.6.jar
-rw-r--r-- 1 root root 143602 Oct 18 18:24 commons-digester-1.8.jar
-rw-r--r-- 1 root root 305001 Oct 18 18:24 commons-httpclient-3.1.jar
-rw-r--r-- 1 root root 185140 Oct 18 18:24 commons-io-2.4.jar
-rw-r--r-- 1 root root 284220 Oct 18 18:24 commons-lang-2.6.jar
-rw-r--r-- 1 root root 1599627 Oct 18 18:24 commons-math3-3.1.1.jar
-rw-r--r-- 1 root root 273370 Oct 18 18:24 commons-net-3.1.jar
-rw-r--r-- 1 root root 2657422 Oct 18 18:24 curator-client-4.0.0.jar
-rw-r--r-- 1 root root 307244 Oct 18 18:24 curator-framework-4.0.0.jar
-rw-r--r-- 1 root root 294100 Oct 18 18:24 curator-recipes-4.0.0.jar
-rw-r--r-- 1 root root 2740 Oct 18 18:26 flink-appmaster-1.0-SNAPSHOT.jar
-rw-r--r-- 1 root root 20099 Oct 18 18:24
flink-connector-kafka-0.10_2.11-1.3.2.jar
-rw-r--r-- 1 root root 29961 Oct 18 18:24
flink-connector-kafka-0.9_2.11-1.3.2.jar
-rw-r--r-- 1 root root 78938 Oct 18 18:24
flink-connector-kafka-base_2.11-1.3.2.jar
-rw-r--r-- 1 root root 73351238 Aug 3 12:10 flink-dist_2.11-1.3.2.jar
-rw-rw-r-- 1 root root 100653 Aug 3 12:07 flink-python_2.11-1.3.2.jar
-rw-r--r-- 1 root root 36638085 Aug 3 11:58
flink-shaded-hadoop2-uber-1.3.2.jar
-rw-r--r-- 1 root root 7286 Oct 18 18:24 force-shading-1.3.2.jar
-rw-r--r-- 1 root root 190432 Oct 18 18:24 gson-2.2.4.jar
-rw-r--r-- 1 root root 2442625 Oct 18 18:24 guava-20.0.jar
-rw-r--r-- 1 root root 17385 Oct 18 18:24 hadoop-annotations-2.7.2.jar
-rw-r--r-- 1 root root 70685 Oct 18 18:24 hadoop-auth-2.7.2.jar
-rw-r--r-- 1 root root 103119 Oct 18 18:24 hadoop-aws-2.7.2.jar
-rw-r--r-- 1 root root 3443040 Oct 18 18:24 hadoop-common-2.7.2.jar
-rw-r--r-- 1 root root 1475955 Oct 18 18:24 htrace-core-3.1.0-incubating.jar
-rw-r--r-- 1 root root 424648 Oct 18 18:24 httpclient-4.2.jar
-rw-r--r-- 1 root root 223282 Oct 18 18:24 httpcore-4.2.jar
-rw-r--r-- 1 root root 55786 Oct 18 18:24 jackson-annotations-2.8.10.jar
-rw-r--r-- 1 root root 282634 Oct 18 18:24 jackson-core-2.8.10.jar
-rw-r--r-- 1 root root 232248 Oct 18 18:24 jackson-core-asl-1.9.13.jar
-rw-r--r-- 1 root root 1242948 Oct 18 18:24 jackson-databind-2.8.10.jar
-rw-r--r-- 1 root root 17883 Oct 18 18:24 jackson-jaxrs-1.8.3.jar
-rw-r--r-- 1 root root 780664 Oct 18 18:24 jackson-mapper-asl-1.9.13.jar
-rw-r--r-- 1 root root 32319 Oct 18 18:24 jackson-xc-1.8.3.jar
-rw-r--r-- 1 root root 18490 Oct 18 18:24 java-xmlbuilder-0.4.jar
-rw-r--r-- 1 root root 105134 Oct 18 18:24 jaxb-api-2.2.2.jar
-rw-r--r-- 1 root root 890168 Oct 18 18:24 jaxb-impl-2.2.3-1.jar
-rw-r--r-- 1 root root 16515 Oct 18 18:24 jcl-over-slf4j-1.7.25.jar
-rw-r--r-- 1 root root 458739 Oct 18 18:24 jersey-core-1.9.jar
-rw-r--r-- 1 root root 147952 Oct 18 18:24 jersey-json-1.9.jar
-rw-r--r-- 1 root root 713089 Oct 18 18:24 jersey-server-1.9.jar
-rw-r--r-- 1 root root 539735 Oct 18 18:24 jets3t-0.9.0.jar
-rw-r--r-- 1 root root 67758 Oct 18 18:24 jettison-1.1.jar
-rw-r--r-- 1 root root 539912 Oct 18 18:24 jetty-6.1.26.jar
-rw-r--r-- 1 root root 177131 Oct 18 18:24 jetty-util-6.1.26.jar
-rw-r--r-- 1 root root 625986 Oct 18 18:24 joda-time-2.9.1.jar
-rw-r--r-- 1 root root 78175 Oct 18 18:24 jopt-simple-5.0.3.jar
-rw-r--r-- 1 root root 185746 Oct 18 18:24 jsch-0.1.42.jar
-rw-r--r-- 1 root root 100636 Oct 18 18:24 jsp-api-2.1.jar
-rw-r--r-- 1 root root 33031 Oct 18 18:24 jsr305-3.0.0.jar
-rw-r--r-- 1 root root 4596 Oct 18 18:24 jul-to-slf4j-1.7.25.jar
-rw-r--r-- 1 root root 5642726 Oct 18 18:24 kafka_2.11-0.10.2.1.jar
-rw-r--r-- 1 root root 951041 Oct 18 18:24 kafka-clients-0.10.2.1.jar
-rw-r--r-- 1 root root 23645 Oct 18 18:24 log4j-over-slf4j-1.7.25.jar
-rw-r--r-- 1 root root 309130 Oct 18 18:24 logback-classic-1.1.11.jar
-rw-r--r-- 1 root root 475477 Oct 18 18:24 logback-core-1.1.11.jar
-rw-r--r-- 1 root root 236880 Oct 18 18:24 lz4-1.3.0.jar
-rw-r--r-- 1 root root 82123 Oct 18 18:24 metrics-core-2.2.0.jar
-rw-r--r-- 1 root root 1540617 Oct 18 18:24 mongo-java-driver-3.3.0.jar
-rw-r--r-- 1 root root 1330394 Oct 18 18:26 netty-3.10.5.Final.jar
-rw-r--r-- 1 root root 29555 Oct 18 18:24 paranamer-2.3.jar
-rw-r--r-- 1 root root 533455 Oct 18 18:24 protobuf-java-2.5.0.jar
-rw-r--r-- 1 root root 5744974 Oct 18 18:24 scala-library-2.11.8.jar
-rw-r--r-- 1 root root 423753 Oct 18 18:24
scala-parser-combinators_2.11-1.0.4.jar
-rw-r--r-- 1 root root 150385 Oct 18 18:24 sentry-1.5.3.jar
-rw-r--r-- 1 root root 9210 Oct 18 18:24 sentry-logback-1.5.3.jar
-rw-r--r-- 1 root root 105112 Oct 18 18:24 servlet-api-2.5.jar
-rw-r--r-- 1 root root 41203 Oct 18 18:24 slf4j-api-1.7.25.jar
-rw-r--r-- 1 root root 995968 Oct 18 18:24 snappy-java-1.0.4.1.jar
-rw-r--r-- 1 root root 23346 Oct 18 18:24 stax-api-1.0-2.jar
-rw-r--r-- 1 root root 15010 Oct 18 18:24 xmlenc-0.52.jar
-rw-r--r-- 1 root root 94672 Oct 18 18:24 xz-1.0.jar
-rw-r--r-- 1 root root 74798 Oct 18 18:24 zkclient-0.10.jar
-rw-r--r-- 1 root root 871369 Oct 18 18:24 zookeeper-3.4.10.jar
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>1.2.7.RELEASE</version>
</dependency>
</dependencies>
<executions>
<!-- Run shade goal on package phase -->
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<artifactSet>
<excludes>
<!-- This list contains all dependencies of flink-dist
Everything else will be packaged into the fat-jar -->
<exclude>org.apache.flink:flink-annotations</exclude>
<exclude>org.apache.flink:flink-shaded-hadoop1</exclude>
<exclude>org.apache.flink:flink-shaded-hadoop2</exclude>
<exclude>org.apache.flink:flink-shaded-curator-recipes</exclude>
<exclude>org.apache.flink:flink-core</exclude>
<exclude>org.apache.flink:flink-java</exclude>
<exclude>org.apache.flink:flink-metrics-core</exclude>
<exclude>org.apache.flink:flink-scala_2.11</exclude>
<exclude>org.apache.flink:flink-runtime_2.11</exclude>
<exclude>org.apache.flink:flink-optimizer_2.11</exclude>
<exclude>org.apache.flink:flink-clients_2.11</exclude>
<exclude>org.apache.flink:flink-avro_2.11</exclude>
<exclude>org.apache.flink:flink-examples-batch_2.11</exclude>
<exclude>org.apache.flink:flink-examples-streaming_2.11</exclude>
<exclude>org.apache.flink:flink-streaming-java_2.11</exclude>
<exclude>org.apache.flink:flink-statebackend-rocksdb_2.11</exclude>
<!-- Also exclude very big transitive dependencies of Flink
WARNING: You have to remove these excludes if your code
relies on other versions
of these dependencies. -->
<exclude>org.scala-lang:scala-library</exclude>
<exclude>org.scala-lang:scala-compiler</exclude>
<exclude>org.scala-lang:scala-reflect</exclude>
<exclude>ch.qos.logback:*</exclude>
<exclude>com.esotericsoftware.kryo:kryo</exclude>
<exclude>com.esotericsoftware.minlog:minlog</exclude>
<exclude>com.fasterxml.jackson.core:jackson-core</exclude>
<exclude>com.fasterxml.jackson.core:jackson-databind</exclude>
<exclude>com.fasterxml.jackson.core:jackson-annotations</exclude>
<exclude>com.github.scopt:scopt_*</exclude>
<exclude>com.google.inject:guice</exclude>
<exclude>com.google.protobuf:protobuf-java</exclude>
<exclude>com.sun.jersey:jersey-core</exclude>
<exclude>com.thoughtworks.paranamer:paranamer</exclude>
<exclude>com.twitter:chill_*</exclude>
<exclude>com.twitter:chill-java</exclude>
<exclude>com.twitter:chill-avro_*</exclude>
<exclude>com.twitter:chill-bijection_*</exclude>
<exclude>com.twitter:bijection-core_*</exclude>
<exclude>com.twitter:bijection-avro_*</exclude>
<exclude>com.typesafe:config</exclude>
<exclude>com.typesafe.akka:akka-actor_*</exclude>
<exclude>com.typesafe.akka:akka-remote_*</exclude>
<exclude>com.typesafe.akka:akka-slf4j_*</exclude>
<exclude>commons-beanutils:commons-beanutils</exclude>
<exclude>commons-collections:commons-collections</exclude>
<exclude>commons-cli:commons-cli</exclude>
<exclude>commons-daemon:commons-daemon</exclude>
<exclude>commons-digester:commons-digester</exclude>
<exclude>commons-fileupload:commons-fileupload</exclude>
<exclude>commons-io:commons-io</exclude>
<exclude>commons-lang:commons-lang</exclude>
<exclude>commons-logging:commons-logging</exclude>
<exclude>commons-net:commons-net</exclude>
<exclude>de.javakaffee:kryo-serializers</exclude>
<exclude>io.netty:netty</exclude>
<exclude>org.apache.avro:avro</exclude>
<exclude>org.apache.commons:commons-compress</exclude>
<exclude>org.apache.commons:commons-lang3</exclude>
<exclude>org.apache.commons:commons-math</exclude>
<exclude>org.apache.commons:commons-math3</exclude>
<exclude>org.apache.sling:org.apache.sling.commons.json</exclude>
<exclude>org.codehaus.jackson:jackson-core-asl</exclude>
<exclude>org.codehaus.jackson:jackson-mapper-asl</exclude>
<exclude>org.javassist:javassist</exclude>
<exclude>org.mongodb:mongo-java-driver</exclude>
<exclude>org.tukaani:xz</exclude>
<exclude>org.uncommons.maths:uncommons-maths</exclude>
<exclude>org.xerial.snappy:snappy-java</exclude>
<exclude>org.objenesis:objenesis</exclude>
<exclude>org.slf4j:slf4j-api</exclude>
<exclude>org.slf4j:log4j-over-slf4j</exclude>
<exclude>org.slf4j:slf4j-log4j12</exclude>
<exclude>junit:junit</exclude>
<exclude>log4j:log4j</exclude>
<exclude>stax:stax-api</exclude>
<!-- Exclude - brought in by intellify-api - this shades
Flink 1.3's ASM 5.1 with ASM 5.0.3 -->
<exclude>com.jayway.jsonpath:json-path</exclude>
<exclude>net.minidev:json-smart</exclude>
<exclude>net.minidev:accessors-smart</exclude>
<exclude>org.ow2.asm:*</exclude>
<exclude>*:asm</exclude>
<!-- end ASM exclude -->
</excludes>
</artifactSet>
<filters>
<filter>
<artifact>org.apache.flink:*</artifact>
<excludes>
<!-- exclude shaded google but include shaded curator -->
<exclude>org/apache/flink/shaded/com/**</exclude>
<exclude>web-docs/**</exclude>
</excludes>
</filter>
<!-- exclude asm from various sources -->
<filter>
<artifact>asm:*</artifact>
<excludes>
<exclude>org/objectweb/asm/**</exclude>
</excludes>
</filter>
<filter>
<artifact>org.glassfish.jersey.core:*</artifact>
<excludes>
<exclude>jersey/repackaged/org/objectweb/**</exclude>
</excludes>
</filter>
<!-- end exclude asm from various sources -->
<filter>
<!-- Do not copy the signatures in the META-INF folder.
Otherwise, this might cause SecurityExceptions when using
the JAR. -->
<artifact>*:*</artifact>
<excludes>
<exclude>META-INF/*.SF</exclude>
<exclude>META-INF/*.DSA</exclude>
<exclude>META-INF/*.RSA</exclude>
</excludes>
</filter>
</filters>
<relocations>
<relocation>
<pattern>org.apache.commons.codec</pattern>
<shadedPattern>com.intellify.flink.shaded.org.apache.commons.codec</shadedPattern>
</relocation>
<relocation>
<pattern>org.apache.http</pattern>
<shadedPattern>com.intellify.flink.shaded.org.apache.http</shadedPattern>
</relocation>
<relocation>
<pattern>com.amazonaws</pattern>
<shadedPattern>com.intellify.flink.shaded.com.amazonaws</shadedPattern>
</relocation>
</relocations>
<transformers combine.children="append">
<transformer
implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
<resource>META-INF/spring.handlers</resource>
</transformer>
<transformer
implementation="org.springframework.boot.maven.PropertiesMergingResourceTransformer">
<resource>META-INF/spring.factories</resource>
</transformer>
<transformer
implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
<resource>META-INF/spring.schemas</resource>
</transformer>
<transformer
implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
<resource>META-INF/spring.tooling</resource>
</transformer>
</transformers>
<createDependencyReducedPom>false</createDependencyReducedPom>
<shadedArtifactAttached>true</shadedArtifactAttached>
</configuration>
</execution>
</executions>
</plugin>
--
Jared Stehler
Chief Architect - Intellify Learning
o: 617.701.6330 x703
> On Oct 19, 2017, at 5:12 AM, Piotr Nowojski <pi...@data-artisans.com> wrote:
>
> Hi,
>
> What versions of Flink/logback are you using?
>
> Have you read this:
> https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/best_practices.html#use-logback-when-running-flink-out-of-the-ide--from-a-java-application
>
> <https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/best_practices.html#use-logback-when-running-flink-out-of-the-ide--from-a-java-application>
> ?
> Maybe this is an issue of having multiple logging tools and their
> configurations on the class path?
>
> Piotrek
>
>> On 18 Oct 2017, at 20:32, Jared Stehler <jared.steh...@intellifylearning.com
>> <mailto:jared.steh...@intellifylearning.com>> wrote:
>>
>> I’m having an issue where I’ve got logging setup and functioning for my
>> flink-mesos deployment, and works fine up to a point (the same point every
>> time) where it seems to fall back to “defaults” and loses all of my
>> configured filtering.
>>
>> 2017-10-11 21:37:17.454 [flink-akka.actor.default-dispatcher-17] INFO
>> o.a.f.m.runtime.clusterframework.MesosFlinkResourceManager - TaskManager
>> taskmanager-00008 has started.
>> 2017-10-11 21:37:17.454 [flink-akka.actor.default-dispatcher-16] INFO
>> org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager
>> at ip-10-80-54-201
>> (akka.tcp://fl...@ip-10-80-54-201.us-west-2.compute.internal:31014/user/taskmanager
>>
>> <akka.tcp://fl...@ip-10-80-54-201.us-west-2.compute.internal:31014/user/taskmanager>)
>> as 697add78bd00fe7dc6a7aa60bc8d75fb. Current number of registered hosts is
>> 39. Current number of alive task slots is 39.
>> 2017-10-11 21:37:18.820 [flink-akka.actor.default-dispatcher-17] INFO
>> org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager
>> at ip-10-80-54-201
>> (akka.tcp://fl...@ip-10-80-54-201.us-west-2.compute.internal:31018/user/taskmanager
>>
>> <akka.tcp://fl...@ip-10-80-54-201.us-west-2.compute.internal:31018/user/taskmanager>)
>> as a6cff0f18d71aabfb3b112f5e2c36c2b. Current number of registered hosts is
>> 40. Current number of alive task slots is 40.
>> 2017-10-11 21:37:18.821 [flink-akka.actor.default-dispatcher-17] INFO
>> o.a.f.m.runtime.clusterframework.MesosFlinkResourceManager - TaskManager
>> taskmanager-00010 has started.
>> 2017-10-11
>> 21:39:04,371:6171(0x7f67fe9cd700):ZOO_WARN@zookeeper_interest@1570: Exceeded
>> deadline by 13ms
>>
>> — here is where it turns over into default pattern layout ---
>> 21:39:05.616 [nioEventLoopGroup-5-6] INFO o.a.flink.runtime.blob.BlobClient
>> - Blob client connecting to akka://flink/user/jobmanager
>> <akka://flink/user/jobmanager>
>>
>> 21:39:09.322 [nioEventLoopGroup-5-6] INFO
>> o.a.flink.runtime.client.JobClient - Checking and uploading JAR files
>> 21:39:09.322 [nioEventLoopGroup-5-6] INFO o.a.flink.runtime.blob.BlobClient
>> - Blob client connecting to akka://flink/user/jobmanager
>> <akka://flink/user/jobmanager>
>> 21:39:09.788 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.m.r.c.MesosJobManager - Submitting job
>> 005b570ff2866023aa905f2bc850f7a3 (Sa-As-2b-Submission-Join-V3 :=
>> demos-demo500--data-canvas-2-sa-qs-as-v3).
>> 21:39:09.789 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.m.r.c.MesosJobManager - Using restart strategy
>> FailureRateRestartStrategy(failuresInterval=120000 msdelayInterval=1000
>> msmaxFailuresPerInterval=3) for 005b570ff2866023aa905f2bc850f7a3.
>> 21:39:09.789 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.r.e.ExecutionGraph - Job recovers via failover strategy: full graph
>> restart
>> 21:39:09.790 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.m.r.c.MesosJobManager - Running initialization on master for job
>> Sa-As-2b-Submission-Join-V3 := demos-demo500--data-canvas-2-sa-qs-as-v3
>> (005b570ff2866023aa905f2bc850f7a3).
>> 21:39:09.790 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.m.r.c.MesosJobManager - Successfully ran initialization on master in 0
>> ms.
>> 21:39:09.791 [flink-akka.actor.default-dispatcher-4] WARN
>> o.a.f.configuration.Configuration - Config uses deprecated configuration key
>> 'high-availability.zookeeper.storageDir' instead of proper key
>> 'high-availability.storageDir'
>> 21:39:09.791 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.c.GlobalConfiguration - Loading configuration property:
>> mesos.failover-timeout, 60
>> 21:39:09.791 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.c.GlobalConfiguration - Loading configuration property:
>> mesos.initial-tasks, 1
>> 21:39:09.791 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.c.GlobalConfiguration - Loading configuration property:
>> mesos.maximum-failed-tasks, -1
>> 21:39:09.791 [flink-akka.actor.default-dispatcher-4] INFO
>> o.a.f.c.GlobalConfiguration - Loading configuration property:
>> mesos.resourcemanager.framework.role, '*'
>>
>> The reason this is a vexing issue is that the app master then proceeds to
>> dump megabytes of " o.a.f.c.GlobalConfiguration - Loading configuration
>> property:” messages into the log, and I’m unable to filter them out.
>>
>> My logback config is:
>>
>> <?xml version="1.0" encoding="UTF-8"?>
>> <configuration debug="true">
>> <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
>> <encoder>
>> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level
>> %logger{60} %X{sourceThread} - %msg%n</pattern>
>> </encoder>
>> </appender>
>>
>> <appender name="SENTRY" class="io.sentry.logback.SentryAppender">
>> <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
>> <level>ERROR</level>
>> </filter>
>> </appender>
>>
>> <logger name="org.apache.flink.runtime.metrics.MetricRegistry"
>> level="OFF" />
>> <logger name="org.apache.kafka.clients.ClientUtils" level="OFF" />
>> <logger
>> name="org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler"
>> level="OFF" />
>> <logger
>> name="org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase"
>> level="OFF" />
>>
>> <logger name="org.apache.flink.configuration.GlobalConfiguration"
>> level="WARN" />
>> <logger name="org.apache.flink.runtime.checkpoint.CheckpointCoordinator"
>> level="WARN" />
>>
>> <logger name="org.elasticsearch.client.transport" level="DEBUG" />
>>
>> <root level="INFO">
>> <appender-ref ref="CONSOLE" />
>> <appender-ref ref="SENTRY" />
>> </root>
>> </configuration>
>>
>>
>>
>> --
>> Jared Stehler
>> Chief Architect - Intellify Learning
>> o: 617.701.6330 x703
>>
>>
>>
>
