At the moment I use a standalone cluster, isn't using env.java.opts the right way to do it?
Il gio 19 nov 2020, 20:11 Arvid Heise <ar...@ververica.com> ha scritto: > Hi Flavio, > > -D afaik passes only the system property to the entry point (client or > jobmanager depending on setup), while you probably want to have it on the > task managers. > > The specific options to pass it to the task managers depend on the way you > deploy. -yD for yarn for example. For docker or k8s, you would use env. > > On Wed, Nov 18, 2020 at 10:20 PM Flavio Pompermaier <pomperma...@okkam.it> > wrote: > >> Hi to all, >> while trying to solve a leak with dynamic class loading I found out >> that mysql connector creates an AbandonedConnectionCleanupThread that >> is retained in the ChildFirstClassLoader..from version 8.0.22 there's >> the possibility to inhibit this thread passing the system property >> com.mysql.disableAbandonedConnectionCleanup=true [1] (I put the mysql >> jar in the lib folder). >> >> I tried to set in the flink-conf.yml >> env.java.opts: "-Dcom.mysql.disableAbandonedConnectionCleanup=true" >> >> but the property does not produce the desired effect in the static >> section of such a thread [2] (I verified that attaching the remote >> debugger to the task manager). >> >> How can I fix this problem? >> >> [1] >> https://dev.mysql.com/doc/relnotes/connector-j/8.0/en/news-8-0-22.html >> [2] >> public class AbandonedConnectionCleanupThread implements Runnable { >> private static boolean abandonedConnectionCleanupDisabled = >> >> Boolean.getBoolean(PropertyDefinitions.SYSP_disableAbandonedConnectionCleanup); >> >> static { >> if (abandonedConnectionCleanupDisabled) { >> cleanupThreadExecutorService = null; >> } else { >> cleanupThreadExecutorService = >> Executors.newSingleThreadExecutor(r -> {....} >> } >> } >> > > > -- > > Arvid Heise | Senior Java Developer > > <https://www.ververica.com/> > > Follow us @VervericaData > > -- > > Join Flink Forward <https://flink-forward.org/> - The Apache Flink > Conference > > Stream Processing | Event Driven | Real Time > > -- > > Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany > > -- > Ververica GmbH > Registered at Amtsgericht Charlottenburg: HRB 158244 B > Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji > (Toni) Cheng >
