You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/01/08 06:58:00 UTC
[jira] [Commented] (FLINK-11281) Two test in
StateBackendMigrationTestBase failes
[ https://issues.apache.org/jira/browse/FLINK-11281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736809#comment-16736809 ]
Tzu-Li (Gordon) Tai commented on FLINK-11281:
---------------------------------------------
Hi, this would be a duplicate of FLINK-11280, which I'm currently trying to fix.
> Two test in StateBackendMigrationTestBase failes
> ------------------------------------------------
>
> Key: FLINK-11281
> URL: https://issues.apache.org/jira/browse/FLINK-11281
> Project: Flink
> Issue Type: Bug
> Reporter: BoWang
> Priority: Blocker
> Attachments: fail.png
>
>
> Hi, all.
> I found Flink builds got two stable failures in StateBackendMigrationTestBase of recent PRs, which also occurs in my development environment. The detailed errors are as follows.
> This currently doesn't pass because the ListSerializer doesn't respect the reconfigured case, yet.
> java.lang.UnsupportedOperationException: The serializer should have been reconfigured as a new instance; shouldn't be used.
> at org.apache.flink.runtime.testutils.statemigration.TestType$ReconfigurationRequiringTestTypeSerializer.serialize(TestType.java:160)
> at org.apache.flink.runtime.testutils.statemigration.TestType$ReconfigurationRequiringTestTypeSerializer.serialize(TestType.java:154)
> at org.apache.flink.contrib.streaming.state.RocksDBSerializedCompositeKeyBuilder.serializeKeyGroupAndKey(RocksDBSerializedCompositeKeyBuilder.java:159)
> at org.apache.flink.contrib.streaming.state.RocksDBSerializedCompositeKeyBuilder.setKeyAndKeyGroup(RocksDBSerializedCompositeKeyBuilder.java:96)
> at org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.setCurrentKey(RocksDBKeyedStateBackend.java:383)
> at org.apache.flink.runtime.state.StateBackendMigrationTestBase.testKeySerializerUpgrade(StateBackendMigrationTestBase.java:401)
> at org.apache.flink.runtime.state.StateBackendMigrationTestBase.testStateBackendRestoreSucceedsIfNewKeySerializerRequiresReconfiguration
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)