This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 65ec2a20701e950709053f5b8b218465cec0f1d6 Author: sjwiesman <sjwies...@gmail.com> AuthorDate: Mon Aug 16 10:44:08 2021 -0500 [hotfix][state-processor-api] test state reader with modern state backend stack --- ...dRocksDBStateBackendReaderKeyedStateITCase.java | 31 ++++++++++++++++++++++ .../EmbeddedRocksDBStateBackendWindowITCase.java | 31 ++++++++++++++++++++++ .../HashMapStateBackendReaderKeyedStateITCase.java | 31 ++++++++++++++++++++++ .../state/api/HashMapStateBackendWindowITCase.java | 31 ++++++++++++++++++++++ 4 files changed, 124 insertions(+) diff --git a/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/EmbeddedRocksDBStateBackendReaderKeyedStateITCase.java b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/EmbeddedRocksDBStateBackendReaderKeyedStateITCase.java new file mode 100644 index 0000000..47857fd --- /dev/null +++ b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/EmbeddedRocksDBStateBackendReaderKeyedStateITCase.java @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.state.api; + +import org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend; + +/** IT Case for reading state from a RocksDB keyed state backend. */ +public class EmbeddedRocksDBStateBackendReaderKeyedStateITCase + extends SavepointReaderKeyedStateITCase<EmbeddedRocksDBStateBackend> { + + @Override + protected EmbeddedRocksDBStateBackend getStateBackend() { + return new EmbeddedRocksDBStateBackend(); + } +} diff --git a/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/EmbeddedRocksDBStateBackendWindowITCase.java b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/EmbeddedRocksDBStateBackendWindowITCase.java new file mode 100644 index 0000000..b615e2f --- /dev/null +++ b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/EmbeddedRocksDBStateBackendWindowITCase.java @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.state.api; + +import org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend; + +/** IT Case for reading window state with the memory state backend. */ +public class EmbeddedRocksDBStateBackendWindowITCase + extends SavepointWindowReaderITCase<EmbeddedRocksDBStateBackend> { + + @Override + protected EmbeddedRocksDBStateBackend getStateBackend() { + return new EmbeddedRocksDBStateBackend(); + } +} diff --git a/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/HashMapStateBackendReaderKeyedStateITCase.java b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/HashMapStateBackendReaderKeyedStateITCase.java new file mode 100644 index 0000000..cac7825 --- /dev/null +++ b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/HashMapStateBackendReaderKeyedStateITCase.java @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.state.api; + +import org.apache.flink.runtime.state.hashmap.HashMapStateBackend; + +/** IT Case for reading keyed state from a memory state backend. */ +public class HashMapStateBackendReaderKeyedStateITCase + extends SavepointReaderKeyedStateITCase<HashMapStateBackend> { + + @Override + protected HashMapStateBackend getStateBackend() { + return new HashMapStateBackend(); + } +} diff --git a/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/HashMapStateBackendWindowITCase.java b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/HashMapStateBackendWindowITCase.java new file mode 100644 index 0000000..ef4699a --- /dev/null +++ b/flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/HashMapStateBackendWindowITCase.java @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.state.api; + +import org.apache.flink.runtime.state.hashmap.HashMapStateBackend; + +/** IT Case for reading window state with the memory state backend. */ +public class HashMapStateBackendWindowITCase + extends SavepointWindowReaderITCase<HashMapStateBackend> { + + @Override + protected HashMapStateBackend getStateBackend() { + return new HashMapStateBackend(); + } +}