当然不会。
杨浩 于2021年11月25日周四 下午6:09写道:
> keyed state重新指定并行度后,比如2->4或者4->2,请问下是不是会丢失部分老的状态?
keyed state重新指定并行度后,比如2->4或者4->2,请问下是不是会丢失部分老的状态?
你好
现在 KeyedState 是不能跨算子使用的,也就是不同的算子使用的是不同的 state。
Best,
Congxian
Z-Z 于2020年6月11日周四 上午10:11写道:
> 请问,假设两个算子以相同的字段keyby,它们可以使用相同的StateDescriptor从而使用相同的的keyed state吗
??keybyStateDescriptorkeyed
state??
tate.NoOpTaskLocalStateStoreImpl@3fd9cf09.
2020-04-14 11:42:46,070 DEBUG
org.apache.flink.streaming.api.operators.BackendRestorerProcedure - Creating
keyed state backend for
KeyedProcessOperator_20ba6b65f97481d5570070de90e4e791_(1/1) and restoring with
gt; >/data/flink1_10/tmp/flink-io-01229972-48d4-4229-ac8c-33f0edfe5b7c/job_5ec178dc885a8f1a64c1925e182562e3_op_KeyedProcessOperator_da2b90ef97e5c844980791c8fe08b926__1_2__uuid_772b4663-f633-4ed5-a67a-d1904760a160/db/001888.sst
> >这个文件是不是存在 double check 下,如果是下载失败,你需要确认下下载失败的原因
> >
> >Best,
> >Congxian
> >
> >
> >chenxyz 于2020年4月1日周三 下午3:02写道:
> >
>
.sst
>这个文件是不是存在 double check 下,如果是下载失败,你需要确认下下载失败的原因
>
>Best,
>Congxian
>
>
>chenxyz 于2020年4月1日周三 下午3:02写道:
>
>> 任务启用rocksdb作为状态后端,任务出现异常重启时经常失败Could not restore keyed state backend for
>> KeyedProcessOperator。这个问题怎么解决呢?
>>
>> 版本:1.10 standalone
>
check 下,如果是下载失败,你需要确认下下载失败的原因
Best,
Congxian
chenxyz 于2020年4月1日周三 下午3:02写道:
> 任务启用rocksdb作为状态后端,任务出现异常重启时经常失败Could not restore keyed state backend for
> KeyedProcessOperator。这个问题怎么解决呢?
>
> 版本:1.10 standalone
>
> 配置信息:
>
> state.backend: rocksdb
>
> state.checkp
任务启用rocksdb作为状态后端,任务出现异常重启时经常失败Could not restore keyed state backend for
KeyedProcessOperator。这个问题怎么解决呢?
版本:1.10 standalone
配置信息:
state.backend: rocksdb
state.checkpoints.dir: hdfs://nameservice1/data/flink1_10/checkpoint
state.backend.incremental: true
jobmanager.execution.failover