Mute current failures

tests/integration/helpers/cluster.py

@@ -1836,6 +1836,10 @@ class ClickHouseInstance:
         build_opts = self.query("SELECT value FROM system.build_options WHERE name = 'CXX_FLAGS'")
         return "-fsanitize={}".format(sanitizer_name) in build_opts
 
+    def is_debug_build(self):
+        build_opts = self.query("SELECT value FROM system.build_options WHERE name = 'CXX_FLAGS'")
+        return 'NDEBUG' not in build_opts
+
     def is_built_with_thread_sanitizer(self):
         return self.is_built_with_sanitizer('thread')
 

tests/integration/test_distributed_respect_user_timeouts/test.py

@@ -3,6 +3,7 @@ import os.path
 import timeit
 
 import pytest
+import logging
 from helpers.cluster import ClickHouseCluster
 from helpers.network import PartitionManager
 from helpers.test_tools import TSV
@@ -11,6 +12,8 @@ cluster = ClickHouseCluster(__file__)
 
 NODES = {'node' + str(i): None for i in (1, 2)}
 
+IS_DEBUG = False
+
 CREATE_TABLES_SQL = '''
 CREATE DATABASE test;
 
@@ -104,6 +107,11 @@ def started_cluster(request):
     try:
         cluster.start()
 
+        if cluster.instances["node1"].is_debug_build():
+            global IS_DEBUG
+            IS_DEBUG = True
+            logging.warning("Debug build is too slow to show difference in timings. We disable checks.")
+
         for node_id, node in list(NODES.items()):
             node.query(CREATE_TABLES_SQL)
             node.query(INSERT_SQL_TEMPLATE.format(node_id=node_id))
@@ -133,8 +141,9 @@ def _check_timeout_and_exception(node, user, query_base, query):
     # And it should timeout no faster than:
     measured_timeout = timeit.default_timer() - start
 
-    assert expected_timeout - measured_timeout <= TIMEOUT_MEASUREMENT_EPS
+    if not IS_DEBUG:
-    assert measured_timeout - expected_timeout <= TIMEOUT_DIFF_UPPER_BOUND[user][query_base]
+        assert expected_timeout - measured_timeout <= TIMEOUT_MEASUREMENT_EPS
+        assert measured_timeout - expected_timeout <= TIMEOUT_DIFF_UPPER_BOUND[user][query_base]
 
     # And exception should reflect connection attempts:
     _check_exception(exception, repeats)

tests/integration/test_replicated_merge_tree_hdfs_zero_copy/test.py

@@ -37,6 +37,9 @@ def cluster():
                              with_hdfs=True)
         logging.info("Starting cluster...")
         cluster.start()
+        if cluster.instances["node1"].is_debug_build():
+            # https://github.com/ClickHouse/ClickHouse/issues/27814
+            pytest.skip("libhdfs3 calls rand function which does not pass harmful check in debug build")
         logging.info("Cluster started")
 
         fs = HdfsClient(hosts=cluster.hdfs_ip)

tests/integration/test_storage_kafka/test.py

@@ -180,28 +180,6 @@ def avro_confluent_message(schema_registry_client, value):
     })
     return serializer.encode_record_with_schema('test_subject', schema, value)
 
-# Fixtures
-
-@pytest.fixture(scope="module")
-def kafka_cluster():
-    try:
-        global kafka_id
-        cluster.start()
-        kafka_id = instance.cluster.kafka_docker_id
-        print(("kafka_id is {}".format(kafka_id)))
-        yield cluster
-
-    finally:
-        cluster.shutdown()
-
-@pytest.fixture(autouse=True)
-def kafka_setup_teardown():
-    instance.query('DROP DATABASE IF EXISTS test; CREATE DATABASE test;')
-    wait_kafka_is_available() # ensure kafka is alive
-    kafka_producer_send_heartbeat_msg() # ensure python kafka client is ok
-    # print("kafka is available - running test")
-    yield  # run test
-
 # Tests
 
 def test_kafka_settings_old_syntax(kafka_cluster):
@@ -694,6 +672,11 @@ def describe_consumer_group(kafka_cluster, name):
 def kafka_cluster():
     try:
         cluster.start()
+        if instance.is_debug_build():
+            # https://github.com/ClickHouse/ClickHouse/issues/26547
+            pytest.skip("~WriteBufferToKafkaProducer(): Assertion `rows == 0 && chunks.empty()' failed.")
+        kafka_id = instance.cluster.kafka_docker_id
+        print(("kafka_id is {}".format(kafka_id)))
         yield cluster
     finally:
         cluster.shutdown()
@@ -1124,6 +1107,7 @@ def test_kafka_protobuf_no_delimiter(kafka_cluster):
 
 
 def test_kafka_materialized_view(kafka_cluster):
+
     instance.query('''
         DROP TABLE IF EXISTS test.view;
         DROP TABLE IF EXISTS test.consumer;

tests/integration/test_storage_kerberized_kafka/test.py

@@ -55,6 +55,9 @@ def kafka_produce(kafka_cluster, topic, messages, timestamp=None):
 def kafka_cluster():
     try:
         cluster.start()
+        if instance.is_debug_build():
+            # https://github.com/ClickHouse/ClickHouse/issues/27651
+            pytest.skip("librdkafka calls system function for kinit which does not pass harmful check in debug build")
         yield cluster
     finally:
         cluster.shutdown()