File tree Expand file tree Collapse file tree
beam/tools/src/test/java/cz/o2/proxima/beam/tools/groovy
flink/core/src/test/java/cz/o2/proxima/flink/core Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -659,7 +659,7 @@ public void testImpulse() {
659659 }
660660 }
661661
662- @ Test (timeout = 20000 )
662+ @ Test (timeout = 60000 )
663663 public void testPeriodicImpulse () throws InterruptedException {
664664 SerializableScopedValue <Integer , AtomicBoolean > finished =
665665 new SerializableScopedValue <>(AtomicBoolean ::new );
Original file line number Diff line number Diff line change @@ -104,6 +104,10 @@ subprojects {
104104 }
105105 }
106106 }
107+
108+ test {
109+ forkEvery 1
110+ }
107111}
108112
109113sonar {
Original file line number Diff line number Diff line change @@ -33,8 +33,4 @@ updateModulePath(project)
3333
3434registerTestsJar(project)
3535
36- test {
37- forkEvery 1
38- }
39-
4036publishArtifacts(project, " default" )
Original file line number Diff line number Diff line change @@ -44,8 +44,4 @@ registerTestsJar(project) {
4444 mergeServiceFiles()
4545}
4646
47- test {
48- forkEvery 1
49- }
50-
5147publishArtifacts(project, " default" )
Original file line number Diff line number Diff line change @@ -47,8 +47,4 @@ protobuf {
4747 protoc { artifact = libraries. protoc }
4848}
4949
50- test {
51- forkEvery 1
52- }
53-
5450publishArtifacts(project, " default" )
Original file line number Diff line number Diff line change 4242 filter {
4343 excludeTestsMatching " *IT_Large*"
4444 }
45- forkEvery 1
4645}
4746
4847publishArtifacts(project, " default" )
Original file line number Diff line number Diff line change 4545import org .apache .flink .streaming .api .operators .StreamSource ;
4646import org .apache .flink .streaming .util .AbstractStreamOperatorTestHarness ;
4747import org .junit .jupiter .api .Assertions ;
48+ import org .junit .jupiter .api .Disabled ;
4849import org .junit .jupiter .api .Test ;
4950import org .junit .jupiter .api .Timeout ;
5051
@@ -95,6 +96,7 @@ private static StreamElement newData(
9596
9697 @ Test
9798 @ Timeout (60 )
99+ @ Disabled ("https://github.com/O2-Czech-Republic/proxima-platform/issues/355" )
98100 void testRunAndClose () throws Exception {
99101 final Repository repository = Repository .ofTest (ConfigFactory .parseString (MODEL ));
100102 final AttributeDescriptor <?> attribute = repository .getEntity ("test" ).getAttribute ("data" );
You can’t perform that action at this time.
0 commit comments