You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/24 08:33:00 UTC
[jira] [Comment Edited] (FLINK-26836) Add sanity check for state.savepoints.dir when using savepoint upgrade mode
[ https://issues.apache.org/jira/browse/FLINK-26836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511689#comment-17511689 ]
Yang Wang edited comment on FLINK-26836 at 3/24/22, 8:32 AM:
-------------------------------------------------------------
{{SavepointTriggerNonce}} should also check the "state.savepoints.dir".
[~nicholasjiang] Yes, the sanity check needs to be added in {{{}DefaultDeploymentValidator{}}}.
was (Author: fly_in_gis):
{{SavepointTriggerNonce}} should also check the "state.savepoints.dir".
> Add sanity check for state.savepoints.dir when using savepoint upgrade mode
> ---------------------------------------------------------------------------
>
> Key: FLINK-26836
> URL: https://issues.apache.org/jira/browse/FLINK-26836
> Project: Flink
> Issue Type: Sub-task
> Components: Kubernetes Operator
> Reporter: Yang Wang
> Assignee: Nicholas Jiang
> Priority: Major
>
> Change upgrade mode from stateless to savepoint with {{examples/basic.yaml}} will have following errors.
> {code:java}
> // code placeholder
> ESC[mESC[33m2022-03-24 02:49:18,484ESC[m ESC[36mi.j.o.p.e.ReconciliationDispatcherESC[m ESC[1;31m[ERROR][default/basic-example] Error during event processing ExecutionScope{ resource id: CustomResou
> rceID{name='basic-example', namespace='default'}, version: 3807979} failed.
> org.apache.flink.kubernetes.operator.exception.ReconciliationException: java.util.concurrent.ExecutionException: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.res
> t.handler.RestHandlerException: Config key [state.savepoints.dir] is not set. Property [targetDirectory] must be provided.
> at org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler.triggerOperation(SavepointHandlers.java:163)
> at org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers$TriggerHandler.handleRequest(AbstractAsynchronousOperationHandlers.java:118)
> at org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler.handleRequest(SavepointHandlers.java:136)
> at org.apache.flink.runtime.rest.handler.AbstractRestHandler.respondToRequest(AbstractRestHandler.java:83)
> at org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:195)
> at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:83)
> at java.util.Optional.ifPresent(Optional.java:159)
> at org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)
> at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:80)
> at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49)
> at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
> at org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
> at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)
> at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)
> at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
> at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
> : {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)