You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/07/03 15:12:18 UTC
[flink] branch release-1.11 updated: [FLINK-18470] Ensure rocksdb
is loaded in RocksKeyGroupsRocksSingleStateIteratorTest
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 5d07c04 [FLINK-18470] Ensure rocksdb is loaded in RocksKeyGroupsRocksSingleStateIteratorTest
5d07c04 is described below
commit 5d07c046a45bd273b1d0cb3dd7cd0cb2b942bc00
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Fri Jul 3 09:09:48 2020 +0200
[FLINK-18470] Ensure rocksdb is loaded in RocksKeyGroupsRocksSingleStateIteratorTest
---
.../state/RocksKeyGroupsRocksSingleStateIteratorTest.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksKeyGroupsRocksSingleStateIteratorTest.java b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksKeyGroupsRocksSingleStateIteratorTest.java
index 2c73fc7..c84e398 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksKeyGroupsRocksSingleStateIteratorTest.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksKeyGroupsRocksSingleStateIteratorTest.java
@@ -25,11 +25,13 @@ import org.apache.flink.core.memory.ByteArrayOutputStreamWithPos;
import org.apache.flink.util.IOUtils;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.TemporaryFolder;
import org.rocksdb.ColumnFamilyDescriptor;
import org.rocksdb.ColumnFamilyHandle;
+import org.rocksdb.NativeLibraryLoader;
import org.rocksdb.ReadOptions;
import org.rocksdb.RocksDB;
@@ -51,6 +53,11 @@ public class RocksKeyGroupsRocksSingleStateIteratorTest {
@Rule
public TemporaryFolder tempFolder = new TemporaryFolder();
+ @Before
+ public void before() throws Exception {
+ NativeLibraryLoader.getInstance().loadLibrary(tempFolder.newFolder().getAbsolutePath());
+ }
+
@Test
public void testEmptyMergeIterator() throws Exception {
RocksStatesPerKeyGroupMergeIterator emptyIterator =