add failing test [#CLICKHOUSE-2911]

dbms/tests/integration/helpers/cluster.py

@@ -113,7 +113,6 @@ class ClickHouseCluster:
 
         for instance in self.instances.values():
             instance.docker_client = None
-            instance.docker_id = None
             instance.ip_address = None
             instance.client = None
 

dbms/tests/integration/test_merge_table_over_distributed/configs/remote_servers.xml

+<yandex>
+    <remote_servers>
+        <test_cluster>
+            <shard>
+                <replica>
+                    <host>node1</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+            <shard>
+                <replica>
+                    <host>node2</host>
+                    <port>9000</port>
+                </replica>
+            </shard>
+        </test_cluster>
+    </remote_servers>
+</yandex>

dbms/tests/integration/test_merge_table_over_distributed/test.py

+from contextlib import contextmanager
+
+import pytest
+
+from helpers.cluster import ClickHouseCluster
+
+cluster = ClickHouseCluster(__file__)
+
+node1 = cluster.add_instance('node1', main_configs=['configs/remote_servers.xml'])
+node2 = cluster.add_instance('node2', main_configs=['configs/remote_servers.xml'])
+
+@pytest.fixture(scope="module")
+def started_cluster():
+    try:
+        cluster.start()
+
+        for node in (node1, node2):
+            node.query('''
+CREATE TABLE local_table(id UInt32, val String) ENGINE = TinyLog;
+''')
+
+        node1.query("INSERT INTO local_table VALUES (1, 'node1')")
+        node2.query("INSERT INTO local_table VALUES (2, 'node2')")
+
+        node1.query('''
+CREATE TABLE distributed_table(id UInt32, val String) ENGINE = Distributed(test_cluster, default, local_table);
+CREATE TABLE merge_table(id UInt32, val String) ENGINE = Merge(default, '^distributed_table')
+''')
+
+        yield cluster
+
+    finally:
+        cluster.shutdown()
+
+
+def test_global_in(started_cluster):
+    assert node1.query("SELECT val FROM distributed_table WHERE id GLOBAL IN (SELECT toUInt32(3 - id) FROM local_table)").rstrip() \
+        == 'node2'
+
+    assert node1.query("SELECT val FROM merge_table WHERE id GLOBAL IN (SELECT toUInt32(3 - id) FROM local_table)").rstrip() \
+        == 'node2'
+
+
+if __name__ == '__main__':
+    with contextmanager(started_cluster)() as cluster:
+        for name, instance in cluster.instances.items():
+            print name, instance.ip_address
+        raw_input("Cluster created, press any key to destroy...")