We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 40a15c9 commit 2741ecfCopy full SHA for 2741ecf
1 file changed
flink/core/src/test/java/cz/o2/proxima/flink/core/CommitLogSourceFunctionTest.java
@@ -45,6 +45,7 @@
45
import org.apache.flink.streaming.api.operators.StreamSource;
46
import org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness;
47
import org.junit.jupiter.api.Assertions;
48
+import org.junit.jupiter.api.Disabled;
49
import org.junit.jupiter.api.Test;
50
import org.junit.jupiter.api.Timeout;
51
@@ -95,6 +96,7 @@ private static StreamElement newData(
95
96
97
@Test
98
@Timeout(60)
99
+ @Disabled("https://github.com/O2-Czech-Republic/proxima-platform/issues/355")
100
void testRunAndClose() throws Exception {
101
final Repository repository = Repository.ofTest(ConfigFactory.parseString(MODEL));
102
final AttributeDescriptor<?> attribute = repository.getEntity("test").getAttribute("data");
0 commit comments