You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2018/06/29 07:44:44 UTC
flink git commit: [FLINK-9217][kafka-tests] Ignore testTimestamps for
Kafka 0.10
Repository: flink
Updated Branches:
refs/heads/kafka [created] 92a6a223a
[FLINK-9217][kafka-tests] Ignore testTimestamps for Kafka 0.10
This test was deadlocking someimtes and for some reasons it appears not failing in Kafka 0.11.
Disabling it for now, since this probably indicates there was a bug in Kafka 0.10
that was fixed later in Kafka 0.11.
This closes #6215
This closes #6149
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/92a6a223
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/92a6a223
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/92a6a223
Branch: refs/heads/kafka
Commit: 92a6a223aaf085887a08ed314c6dea38674c0158
Parents: 9b36604
Author: Piotr Nowojski <pi...@gmail.com>
Authored: Wed Jun 27 11:39:20 2018 +0200
Committer: Piotr Nowojski <pi...@gmail.com>
Committed: Fri Jun 29 09:43:37 2018 +0200
----------------------------------------------------------------------
.../apache/flink/streaming/connectors/kafka/Kafka010ITCase.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/92a6a223/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java b/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
index 0855e92..45ab958 100644
--- a/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
+++ b/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
@@ -39,6 +39,7 @@ import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema;
import org.apache.flink.streaming.util.serialization.KeyedSerializationSchemaWrapper;
+import org.junit.Ignore;
import org.junit.Test;
import javax.annotation.Nullable;
@@ -169,6 +170,7 @@ public class Kafka010ITCase extends KafkaConsumerTestBase {
/**
* Kafka 0.10 specific test, ensuring Timestamps are properly written to and read from Kafka.
*/
+ @Ignore("This test is disabled because of: https://issues.apache.org/jira/browse/FLINK-9217")
@Test(timeout = 60000)
public void testTimestamps() throws Exception {