BRinging back the commit that was lost because of bad merge. (#2122)

confluentinc · Nov 7, 2018 · 6d3ed83 · 6d3ed83
1 parent a15506f
commit 6d3ed83
Show file tree

Hide file tree

Showing 2 changed files with 669 additions and 645 deletions.
diff --git a/ksql-engine/src/test/resources/query-validation-tests/project-filter.json b/ksql-engine/src/test/resources/query-validation-tests/project-filter.json
@@ -60,6 +60,29 @@
         {"topic": "S1", "key": 0, "timestamp": 0, "value": {"ID":4}}
       ]
     },
+    {
+      "name": "WHERE with many comparisons. This tests the fix for #1784",
+      "statements": [
+        "CREATE STREAM events (id int, field0 varchar) WITH (KAFKA_TOPIC='events', VALUE_FORMAT='json');",
+        "CREATE STREAM eventstest AS SELECT id, 'x_0' AS field1, field0 FROM events WHERE ((id=1 OR id=2 OR id=3 OR id=4) AND (field0='0x10' OR field0='0x11' OR field0='0x12' OR field0='0x13' OR field0='0x14' OR field0='0x15' OR field0='0x16' OR field0='0x17' OR field0='0x18' OR field0='0x19' OR field0='0x1A' OR field0='0x1B' OR field0='0x1C' OR field0='0x1D' OR field0='0x1E' OR field0='0x1F' OR field0='0x20' OR field0='0x21' OR field0='0x22' OR field0='0x23' OR field0='0x24' OR field0='0x25' OR field0='0x26' OR field0='0x27' OR field0='0x28' OR field0='0x29' OR field0='0x2A' OR field0='0x2B' OR field0='0x2C' OR field0='0x2D' OR field0='0x2E' OR field0='0x2F' OR field0='0x30' OR field0='0x31' OR field0='0x32' OR field0='0x33' OR field0='0x34' OR field0='0x35' OR field0='0x36' OR field0='0x37' OR field0='0x38' OR field0='0x39' OR field0='0x3A' OR field0='0x3B' OR field0='0x3C' OR field0='0x3D' OR field0='0x3E' OR field0='0x3F'));"
+      ],
+      "inputs": [
+        {
+          "topic": "events",
+          "key": 0,
+          "value": {"id": 1, "field0": "0x10"},
+          "timestamp": 0
+        }
+      ],
+      "outputs": [
+        {
+          "topic": "EVENTSTEST",
+          "key": 0,
+          "value": {"ID": 1, "FIELD1": "x_0", "FIELD0": "0x10"},
+          "timestamp": 0
+        }
+      ]
+    },
     {
       "name": "project and negative filter",
       "statements": [