我在spring batch的JobExecution上下文中添加了一个对象,它包含一个Instant
字段。
它的序列化如下:
{
"startFrom": {
"nano": 0,
"epochSecond": 1541116800
}
}
然而,Spring Batch似乎无法实现它。
Caused by: java.lang.IllegalArgumentException: Unable to deserialize the execution context
at org.springframework.batch.core.repository.dao.JdbcExecutionContextDao$ExecutionContextRowMapper.mapRow(JdbcExecutionContextDao.java:325)
at org.springframework.batch.core.repository.dao.JdbcExecutionContextDao$ExecutionContextRowMapper.mapRow(JdbcExecutionContextDao.java:309)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:93)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:60)
at org.springframework.jdbc.core.JdbcTemplate$1.doInPreparedStatement(JdbcTemplate.java:667)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:605)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:657)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:688)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:700)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:756)
at org.springframework.batch.core.repository.dao.JdbcExecutionContextDao.getExecutionContext(JdbcExecutionContextDao.java:112)
at org.springframework.batch.core.explore.support.SimpleJobExplorer.getJobExecutionDependencies(SimpleJobExplorer.java:202)
at org.springframework.batch.core.explore.support.SimpleJobExplorer.getJobExecutions(SimpleJobExplorer.java:83)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:564)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:343)
at org.springframework.aop.framework.ReflectiveMethod
在做一些研究时,我看到Jackson有一个JavaTimeModule
来序列化/重新序列化Instant
和其他日期类。但是,在Jackson2ExecutionContextStringSerializer
类中,它创建了ObjectMapper
,如下所示,没有注册正确的模块:
public Jackson2ExecutionContextStringSerializer() {
this.objectMapper = new ObjectMapper();
this.objectMapper.configure(MapperFeature.DEFAULT_VIEW_INCLUSION, false);
this.objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, true);
this.objectMapper.enableDefaultTyping();
this.objectMapper.registerModule(new JobParametersModule());
}
Spring Batch不使用自动连接的ObjectMapper有什么原因吗?或者是他们不注册JavaTimeModule
的原因?是否有解决此问题的方法?
谢谢你,谢谢
编辑:
我发现了如何覆盖这个对象Map器:
@Bean
public JobRepository createJobRepository() throws Exception {
ObjectMapper objectMapper = new ObjectMapper().registerModule(new JavaTimeModule()).findAndRegisterModules();
Jackson2ExecutionContextStringSerializer defaultSerializer = new Jackson2ExecutionContextStringSerializer();
defaultSerializer.setObjectMapper(objectMapper);
JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
factory.setDataSource(dataSource);
factory.setTransactionManager(transactionManager);
factory.setSerializer(defaultSerializer);
factory.afterPropertiesSet();
return factory.getObject();
}
然而,即使这样,问题仍然存在。
4条答案
按热度按时间gcxthw6b1#
以下为我工作。我在扩展马哈茂德·本·哈辛的回答,上面的回答对尼古拉斯·维达特不起作用。(我没有足够的声誉来评论)。
(我在另一个
@Configuration
类中定义了一个ObjectMapper
bean。)这里重要的是覆盖createJobExplorer()
方法并在那里设置正确的ExecutionContextSerializer
,因为这个方法将在JobExplorerFactoryBean
上调用getTarget()
,如果没有设置,它将设置一个vanillaExecutionContextSerializer
,这将导致您所描述的错误。8tntrjer2#
您显示的代码是序列化程序的默认初始化。您可以通过提供一个自定义的对象Map器来覆盖它,该Map器是用所需的模块预先配置的。下面是一个示例:
希望这对你有帮助。
w8rqjzmb3#
更新
Spring batch现在有一个修复程序,允许您自定义您的
ObjectMapper
,同时还可以获得Jackson2ExecutionContextStringSerialier
在解决此问题后在内部执行的所有默认设置:https://jira.spring.io/browse/BATCH-2828。修复在
4.2.0
中,在撰写本文时,它目前位于RC1
。原始答案
我注意到类似的问题。我需要自定义
ObjectMapper
以添加KotlinModule
来处理Kotlin数据类。不幸的是,目前编写Jackson2ExecutionContextStringSerializer
的方式扩展性不强。正如您从创建的默认ObjectMapper
中看到的那样,添加了一些默认值,包括对作业参数的重复问题的修复:https://jira.spring.io/browse/BATCH-2680。他们设置的
JobParametersModule
是一个private
类,因此我们不能设置ObjectMapper
具有相同的功能并添加到它。我在Jira提出了一个问题:https://jira.spring.io/browse/BATCH-2828
在此问题得到解决之前,最简单的解决方法是复制并粘贴
JobParmetersModule
的源代码,以便您可以在覆盖中注册相同的代码。mpgws1up4#
通过使用上述所有答案,
对我来说,为了使用Jackson示例,
jackson-datatype-jsr310 : support for Java 8 Date & Time API type
如下所示
请注意,我还必须覆盖getTransactionManager(),并且由于我使用的是JPA,我还必须将创建的隔离级别设置为
ISOLATION_DEFAULT
: