You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I had searched in the issues and found no similar issues.
Java Version
Java 8
Scala Version
2.12.x
StreamPark Version
dev
Flink Version
flink all version
deploy mode
kubernetes-session
What happened
The class loads InternalConfigHolder as a cache class, and an object is regenerated when used (it should be the same one, otherwise the cache will become invalid, and everything will become the default value)
As follows:
Springboot startup
Springboot startup is completed, and the yaml configuration is refreshed into InternalConfigHolder through EnvInitializer
After springboot is started, click to start k8s sesssion deploy
It can be seen that after passing this classloader, InternalConfigHolder regenerates an object
I tried to add an output to InternalConfigHolder, printed it once after the initial service, and then submitted it to the flink environment. Will print again
Search before asking
Java Version
Java 8
Scala Version
2.12.x
StreamPark Version
dev
Flink Version
flink all version
deploy mode
kubernetes-session
What happened
The class loads InternalConfigHolder as a cache class, and an object is regenerated when used (it should be the same one, otherwise the cache will become invalid, and everything will become the default value)
As follows:
Springboot startup
Springboot startup is completed, and the yaml configuration is refreshed into InternalConfigHolder through EnvInitializer
After springboot is started, click to start k8s sesssion deploy
It can be seen that after passing this classloader, InternalConfigHolder regenerates an object
Error Exception
No response
Screenshots
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: