[
https://issues.apache.org/jira/browse/FLINK-23515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388400#comment-17388400
]
李伟高 commented on FLINK-23515:
-----------------------------
[~yunta] Thank you for your reply.
First, repeat the shutdown. Two submissions of issues were caused by my
network. I closed one of them myself.
Second, I have a question, that is, the source code annotation is that I can
modify it, and its priority is higher than my flink-conf.yml.Source code in
rg.apache.flink.runtime.state.CheckpointStorageLoader.class:
{code:java}
if (defaultSavepointDirectory != null) {
// If a savepoint directory was manually specified in code
// we override any value set in the flink-conf. This allows
// us to pass this value to the CheckpointStorage instance
// where it is needed at runtime while keeping its API logically
// separated for users.
config.set(
CheckpointingOptions.SAVEPOINT_DIRECTORY,
defaultSavepointDirectory.toString());
}
{code}
> I try to specify savepoint dir in my app. However, the startup task reports
> an error, java.lang.unsupported operationexception: the configuration is
> unmodifiable; its contents cannot be changed.
> --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-23515
> URL: https://issues.apache.org/jira/browse/FLINK-23515
> Project: Flink
> Issue Type: Bug
> Components: API / State Processor
> Affects Versions: 1.13.1
> Environment: Flink Version :1.13.1
> Standalone Cluster
> Reporter: 李伟高
> Priority: Major
>
> The directory where savepoint is configured in my application
> {code:java}
> String savepointDir;
> if (Strings.isNotBlank(savepointDir =
> parameterTool.get("system.savepoint.dir"))) {
> env.setDefaultSavepointDirectory(savepointDir);
> }
> {code}
> Where `system.savepoint.dir` is not empty.
>
> When I submit an application to my standalone cluster, an error is prompted:
> {code:java}
> 2021-07-27 16:26:34.029 [travel_spilt -> (Sink: sink_es_insert, Sink:
> sink_es_update) (1/1)#31] WARN org.apache.flink.runtime.taskmanager.Task -
> travel_spilt -> (Sink: sink_es_insert, Sink: sink_es_update) (1/1)#31
> (1f33925046e04307ba6beb3959d2cad5) switched from DEPLOYING to FAILED with
> failure cause: java.lang.UnsupportedOperationException: The configuration is
> unmodifiable; its contents cannot be changed.2021-07-27 16:26:34.029
> [travel_spilt -> (Sink: sink_es_insert, Sink: sink_es_update) (1/1)#31] WARN
> org.apache.flink.runtime.taskmanager.Task - travel_spilt -> (Sink:
> sink_es_insert, Sink: sink_es_update) (1/1)#31
> (1f33925046e04307ba6beb3959d2cad5) switched from DEPLOYING to FAILED with
> failure cause: java.lang.UnsupportedOperationException: The configuration is
> unmodifiable; its contents cannot be changed. at
> org.apache.flink.configuration.UnmodifiableConfiguration.error(UnmodifiableConfiguration.java:73)
> at
> org.apache.flink.configuration.UnmodifiableConfiguration.setValueInternal(UnmodifiableConfiguration.java:63)
> at org.apache.flink.configuration.Configuration.set(Configuration.java:709)
> at
> org.apache.flink.runtime.state.CheckpointStorageLoader.load(CheckpointStorageLoader.java:174)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.createCheckpointStorage(StreamTask.java:1231)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:337)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:308)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:281)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:273)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:263)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.<init>(OneInputStreamTask.java:65)
> at sun.reflect.GeneratedConstructorAccessor339.newInstance(Unknown Source)
> at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at
> org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:1524)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:730) at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) at
> java.lang.Thread.run(Thread.java:748)
> {code}
> Every stateful operator has this error.What do I need to do? I looked at
> other versions and didn't find the method Unmodifiable
> configuration#setvalueinternal (string key, t value).
> Looking forward to your reply, thank you.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
