Skip to content

Commit

Permalink
[hotfix] Disable KryoSerializerConcurrencyCheckInactiveITCase if logg…
Browse files Browse the repository at this point in the history
…ing level is DEBUG
  • Loading branch information
rmetzger committed Oct 15, 2020
1 parent 9ae7d81 commit c6bf700
Showing 1 changed file with 7 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,12 @@

package org.apache.flink.api.java.typeutils.runtime.kryo;

import org.apache.flink.util.TestLogger;

import org.junit.Test;

import static org.junit.Assert.assertTrue;
import static org.junit.Assume.assumeFalse;

/**
* A test that validates that the concurrency checks in the Kryo Serializer
Expand All @@ -33,7 +36,7 @@
* <p><b>Important:</b> If you see this test fail and the initial settings are still
* correct, check the assumptions above (on fresh JVM fork).
*/
public class KryoSerializerConcurrencyCheckInactiveITCase {
public class KryoSerializerConcurrencyCheckInactiveITCase extends TestLogger {

// this sets the debug initialization back to its default, even if
// by default tests modify it (implicitly via assertion loading)
Expand All @@ -47,6 +50,9 @@ public class KryoSerializerConcurrencyCheckInactiveITCase {
*/
@Test
public void testWithNoConcurrencyCheck() throws Exception {
// this test will fail on DEBUG log level: If we run the test with DEBUG log level
// the KryoSerializer.CONCURRENT_ACCESS_CHECK will be enabled, causing a failure here.
assumeFalse(log.isDebugEnabled());
boolean assertionError;
try {
new KryoSerializerConcurrencyTest().testConcurrentUseOfSerializer();
Expand Down

0 comments on commit c6bf700

Please sign in to comment.