[jira] [Created] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[Shang Yuanchun (Jira)]

Aljoscha Krettek created FLINK-5372:
---------------------------------------

             Summary: Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
                 Key: FLINK-5372
                 URL: https://issues.apache.org/jira/browse/FLINK-5372
             Project: Flink
          Issue Type: Bug
          Components: Streaming
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek


The test is currently {{@Ignored}}. We have to change {{AsyncCheckpointOperator}} to make sure that we can run fully asynchronously. Then, the test will still fail because the canceling behaviour was changed in the meantime.

{code}
public static class AsyncCheckpointOperator
    extends AbstractStreamOperator<String>
    implements OneInputStreamOperator<String, String> {

    @Override
    public void open() throws Exception {
        super.open();

        // also get the state in open, this way we are sure that it was created before
        // we trigger the test checkpoint
        ValueState<String> state = getPartitionedState(
                VoidNamespace.INSTANCE,
                VoidNamespaceSerializer.INSTANCE,
                new ValueStateDescriptor<>("count",
                        StringSerializer.INSTANCE, "hello"));

    }

    @Override
    public void processElement(StreamRecord<String> element) throws Exception {
        // we also don't care

        ValueState<String> state = getPartitionedState(
                VoidNamespace.INSTANCE,
                VoidNamespaceSerializer.INSTANCE,
                new ValueStateDescriptor<>("count",
                        StringSerializer.INSTANCE, "hello"));

        state.update(element.getValue());
    }

    @Override
    public void snapshotState(StateSnapshotContext context) throws Exception {
        // do nothing so that we don't block
    }
}
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)