Exception in thread “Thread-3” java.lang.IllegalStateException: Trying to access closed classloader. Please check if you store classloaders directly or indirectly in static fields. If the stacktrace suggests that the leak occurs in a third party library and cannot be fixed immediately, you can disable this check with the configuration ‘classloader.check-leaked-classloader’.
at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders
S
a
f
e
t
y
N
e
t
W
r
a
p
p
e
r
C
l
a
s
s
L
o
a
d
e
r
.
e
n
s
u
r
e
I
n
n
e
r
(
F
l
i
n
k
U
s
e
r
C
o
d
e
C
l
a
s
s
L
o
a
d
e
r
s
.
j
a
v
a
:
164
)
a
t
o
r
g
.
a
p
a
c
h
e
.
f
l
i
n
k
.
r
u
n
t
i
m
e
.
e
x
e
c
u
t
i
o
n
.
l
i
b
r
a
r
y
c
a
c
h
e
.
F
l
i
n
k
U
s
e
r
C
o
d
e
C
l
a
s
s
L
o
a
d
e
r
s
SafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:164) at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders
S
a
f
e
t
y
N
e
t
W
r
a
p
p
e
r
C
l
a
s
s
L
o
a
d
e
r
.
e
n
s
u
r
e
I
n
n
e
r
(
F
l
i
n
k
U
s
e
r
C
o
d
e
C
l
a
s
s
L
o
a
d
e
r
s
.
j
a
v
a
:
1
6
4
)
a
t
o
r
g
.
a
p
a
c
h
e
.
f
l
i
n
k
.
r
u
n
t
i
m
e
.
e
x
e
c
u
t
i
o
n
.
l
i
b
r
a
r
y
c
a
c
h
e
.
F
l
i
n
k
U
s
e
r
C
o
d
e
C
l
a
s
s
L
o
a
d
e
r
s
SafetyNetWrapperClassLoader.getResource(FlinkUserCodeClassLoaders.java:183)
解决办法： 在 flink 配置文件里 flink-conf.yaml设置
classloader.check-leaked-classloader: false