Flink是将Timers和状态ttl存储在哪里？

Flink 的 Timers 和状态 ttl 都是存储在状态后端（State Backends）中的。Flink 支持多种状态后端，包括 Memory State Backend、RocksDB State Backend、File System State Backend 和任意对外暴露了状态访问 API 的第三方状态后端。

下面是一个使用 RocksDB State Backend 的示例代码：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

// 使用 RocksDB State Backend
env.setStateBackend(new RocksDBStateBackend("hdfs:///flink/checkpoints"));

// 其他配置 ...

DataStream<String> stream = env.addSource(new MySource());

stream.keyBy(...).process(new MyFunction());

在上面的代码中，我们使用了 RocksDB State Backend 并指定了一个 HDFS 路径作为 state checkpoint 存储位置。其他状态后端同理，只需要使用相应的类即可。

注意，如果不进行指定状态后端的操作，Flink 默认会使用 Memory State Backend，这种方式适用于调试和简单的例子，但对于生产环境的应用不建议使用。