[kafka] branch trunk updated: HOTFIX: ignoring tests using old versions of Streams until KIP-268 is merged (#4766)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 29838c1  HOTFIX: ignoring tests using old versions of Streams until KIP-268 is merged (#4766)
29838c1 is described below

commit 29838c104249572cebac69c7d156dff4e1cc41f1
Author: Bill Bejeck <bb...@gmail.com>
AuthorDate: Wed Mar 28 20:41:08 2018 -0400

    HOTFIX: ignoring tests using old versions of Streams until KIP-268 is merged (#4766)
    
    Reviewers: Guozhang Wang <wa...@gmail.com>
---
 .../tests/streams/streams_multiple_rolling_upgrade_test.py     |  3 ++-
 tests/kafkatest/tests/streams/streams_upgrade_test.py          | 10 ++++++----
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/tests/kafkatest/tests/streams/streams_multiple_rolling_upgrade_test.py b/tests/kafkatest/tests/streams/streams_multiple_rolling_upgrade_test.py
index 3fbf67d..58385a8 100644
--- a/tests/kafkatest/tests/streams/streams_multiple_rolling_upgrade_test.py
+++ b/tests/kafkatest/tests/streams/streams_multiple_rolling_upgrade_test.py
@@ -13,7 +13,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-
+from ducktape.mark import ignore
 from ducktape.mark import matrix
 from ducktape.mark.resource import cluster
 from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService
@@ -100,6 +100,7 @@ class StreamsMultipleRollingUpgradeTest(BaseStreamsTest):
         self.wait_for_verification(self.driver, "ALL-RECORDS-DELIVERED", self.driver.STDOUT_FILE)
         self.driver.stop()
 
+    @ignore
     @cluster(num_nodes=9)
     @matrix(broker_version=streams_upgrade_versions)
     def test_rolling_upgrade_downgrade_multiple_apps(self, broker_version):
diff --git a/tests/kafkatest/tests/streams/streams_upgrade_test.py b/tests/kafkatest/tests/streams/streams_upgrade_test.py
index 6ac5939..3b38ff6 100644
--- a/tests/kafkatest/tests/streams/streams_upgrade_test.py
+++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py
@@ -13,14 +13,15 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import time
+from ducktape.mark import ignore
+from ducktape.mark import matrix
 from ducktape.mark.resource import cluster
 from ducktape.tests.test import Test
-from ducktape.mark import matrix
 from kafkatest.services.kafka import KafkaService
-from kafkatest.services.zookeeper import ZookeeperService
 from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService
+from kafkatest.services.zookeeper import ZookeeperService
 from kafkatest.version import LATEST_0_10_2, LATEST_0_11, LATEST_1_0, DEV_BRANCH, KafkaVersion
-import time
 
 upgrade_versions = [str(LATEST_0_10_2), str(LATEST_0_11), str(LATEST_1_0), str(DEV_BRANCH)]
 
@@ -77,6 +78,7 @@ class StreamsUpgradeTest(Test):
             node.version = KafkaVersion(to_version)
             self.kafka.start_node(node)
 
+    @ignore
     @cluster(num_nodes=6)
     @matrix(from_version=upgrade_versions, to_version=upgrade_versions)
     def test_upgrade_downgrade_streams(self, from_version, to_version):
@@ -124,7 +126,7 @@ class StreamsUpgradeTest(Test):
             self.processor1.node.account.ssh_capture("grep SMOKE-TEST-CLIENT-CLOSED %s" % self.processor1.STDOUT_FILE, allow_fail=False)
 
 
-
+    @ignore
     @cluster(num_nodes=6)
     @matrix(from_version=upgrade_versions, to_version=upgrade_versions)
     def test_upgrade_brokers(self, from_version, to_version):

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.