Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Flink Server side JM TM启动 classloader 初始化并发异常 #169

Closed
baisui1981 opened this issue Nov 28, 2022 · 1 comment
Closed

Flink Server side JM TM启动 classloader 初始化并发异常 #169

baisui1981 opened this issue Nov 28, 2022 · 1 comment
Labels
3.7.1 bug Something isn't working
Milestone

Comments

@baisui1981
Copy link
Member

baisui1981 commented Nov 28, 2022

Flink 远端 会启多个VM,一个JM,多个TM,问题是多个VM在运行时 本地插件/配置的目录对应的是一个,为了避免其中一个VM更新之后,其他VM就中的pluginManager->UberClassLoader就 不更新了,

所以本地需要有两个配置快照的副本,一个是localSnaphsot(每次从本地文件系统中去load),另外一个 cacheSnaphsot(缓存在VM内存中的,用来和最新的远端快照做对比)

@baisui1981
Copy link
Member Author

修复了

@baisui1981 baisui1981 added this to the v3.7.1 milestone Apr 13, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
3.7.1 bug Something isn't working
Projects
None yet
Development

No branches or pull requests

1 participant