尝试使用S3启用Flink熵，但不生成熵键

Question

我正在尝试启用Flink提供的熵特性，但最终_entropy_没有被解析(我的意思是没有生成“键”)

我有以下配置：

s3.access-key   my-key
s3.secret-key   ******

s3.entropy.key  _entropy_
s3.entropy.length   8

state.backend   filesystem
state.backend.incremental   true
state.backend.local-recovery    true

state.checkpoints.dir   s3p://<my-bucket>/_entropy_/flink/checkpoints/stage
state.checkpoints.num-retained  2
state.savepoints.dir    s3p://<my-bucket>/flink/savepoints/stage

打开桶时，我看到的是文件夹_entropy_，而不是随机的8个字符文件夹。

对于代码中的声明：

env.enableCheckpointing(10000L, CheckpointingMode.EXACTLY_ONCE)
   .getCheckpointConfig()     
   .enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.DELETE_ON_CANCELLATION);
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(3000L);

PS:我用的是Flink 1.11.2

Answer 1

Flink 1.11.2中有一个回归，打破了这一特性；这在1.11.4中得到了修正。详情请参见FLINK-22081。