小编Ank*_*kit的帖子

我有一个Flink作业，我在其中从文件夹读取文件并将其转储到数据库中。每天都有新文件进入该文件夹。

我已启用检查点，以便如果由于某种原因Flink作业停止并且需要再次启动它，则Flink作业不应读取已读取的文件。

我在代码中添加了以下几行，但是当我重新启动作业时，Flink作业再次读取所有文件。

env.setStateBackend（new FsStateBackend（“ file：/// C：// Users // folder”））; env.enableCheckpointing（10L）;

尝试使用加密的数据库密码使用 spring 自动配置连接到数据库

我正在使用 Spring 自动配置连接到数据库。为此，我在属性文件中添加了以下属性：

spring.datasource.url=jdbc:oracle:thin:@ABCDE2D.com:1888:ABCDE2D1
spring.datasource.username=user
spring.datasource.password=password
spring.datasource.driver-class-oracle.jdbc.driver.OracleDriver

在我的 dao 类中，我有 @Autowired NamedParameterJdbcTemplate 并直接使用它从数据库中获取数据。

直到这里它工作正常。

现在我需要加密属性文件中的密码。为此，我做了以下工作：

1. 在 pom 中添加了 jasypt-spring-boot-starter
2. 在属性文件中添加 spring.datasource.password=ENC(NoIv2c+WQYF3LenN0tDYPA==)
3. 在属性文件中添加了 jasypt.encryptor.password=key

现在我收到以下错误：

Failed to bind properties under 'spring.datasource.password' to  
java.lang.String:
Reason: Failed to bind properties under 'spring.datasource.password' to   
java.lang.String