This is an automated email from the ASF dual-hosted git repository. zakelly pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit b88a6cac675a6acf6e2e8a62d225f5db2057f709 Author: Zakelly <[email protected]> AuthorDate: Fri Jan 31 00:38:31 2025 +0800 [FLINK-37222][Test] Introduce simple test submitting nexmark sql via sql client --- .../apache/flink/table/client/SqlClientTest.java | 8 ++ .../src/test/resources/nexmark.sql | 116 +++++++++++++++++++++ 2 files changed, 124 insertions(+) diff --git a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java index d8f270a8dbe..653d1528620 100644 --- a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java +++ b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java @@ -214,6 +214,14 @@ class SqlClientTest extends SqlClientTestBase { } } + @Test + void testExecuteNexmark() throws Exception { + final URL sqlFile = getClass().getClassLoader().getResource("nexmark.sql"); + String[] args = new String[] {"-f", sqlFile.getPath()}; + String output = runSqlClient(args); + assertThat(output).doesNotContain("java.lang.AssertionError"); + } + @Test void testDisplayMultiLineSqlInInteractiveMode() throws Exception { List<String> statements = diff --git a/flink-table/flink-sql-client/src/test/resources/nexmark.sql b/flink-table/flink-sql-client/src/test/resources/nexmark.sql new file mode 100644 index 00000000000..5475f471dd9 --- /dev/null +++ b/flink-table/flink-sql-client/src/test/resources/nexmark.sql @@ -0,0 +1,116 @@ +-- Licensed to the Apache Software Foundation (ASF) under one +-- or more contributor license agreements. See the NOTICE file +-- distributed with this work for additional information +-- regarding copyright ownership. The ASF licenses this file +-- to you under the Apache License, Version 2.0 (the +-- "License"); you may not use this file except in compliance +-- with the License. You may obtain a copy of the License at +-- +-- http://www.apache.org/licenses/LICENSE-2.0 +-- +-- Unless required by applicable law or agreed to in writing, software +-- distributed under the License is distributed on an "AS IS" BASIS, +-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +-- See the License for the specific language governing permissions and +-- limitations under the License. + +CREATE TABLE datagen +( + event_type int, + person ROW< + id BIGINT, + name VARCHAR, + emailAddress VARCHAR, + creditCard VARCHAR, + city VARCHAR, + state VARCHAR, + `dateTime` TIMESTAMP(3), + extra VARCHAR>, + auction ROW< + id BIGINT, + itemName VARCHAR, + description VARCHAR, + initialBid BIGINT, + reserve BIGINT, + `dateTime` TIMESTAMP(3), + expires TIMESTAMP(3), + seller BIGINT, + category BIGINT, + extra VARCHAR>, + bid ROW< + auction BIGINT, + bidder BIGINT, + price BIGINT, + channel VARCHAR, + url VARCHAR, + `dateTime` TIMESTAMP(3), + extra VARCHAR>, + `dateTime` AS + CASE + WHEN event_type = 0 THEN person.`dateTime` + WHEN event_type = 1 THEN auction.`dateTime` + ELSE bid.`dateTime` + END, + WATERMARK FOR `dateTime` AS `dateTime` - INTERVAL '4' SECOND +) WITH ( + 'connector' = 'datagen', + 'number-of-rows' = '10' +); +CREATE VIEW person AS +SELECT person.id, + person.name, + person.emailAddress, + person.creditCard, + person.city, + person.state, + `dateTime`, + person.extra +FROM datagen +WHERE event_type = 0; + +CREATE VIEW auction AS +SELECT auction.id, + auction.itemName, + auction.description, + auction.initialBid, + auction.reserve, + `dateTime`, + auction.expires, + auction.seller, + auction.category, + auction.extra +FROM datagen +WHERE event_type = 1; + +CREATE VIEW bid AS +SELECT bid.auction, + bid.bidder, + bid.price, + bid.channel, + bid.url, + `dateTime`, + bid.extra +FROM datagen +WHERE event_type = 2; + + +CREATE TABLE nexmark_q7 +( + auction BIGINT, + bidder BIGINT, + price BIGINT, + `dateTime` TIMESTAMP(3), + extra VARCHAR +) WITH ( + 'connector' = 'blackhole' +); + +INSERT INTO nexmark_q7 +SELECT B.auction, B.price, B.bidder, B.`dateTime`, B.extra +from bid B + JOIN (SELECT MAX(price) AS maxprice, window_end as `dateTime` + FROM TABLE( + TUMBLE(TABLE bid, DESCRIPTOR(`dateTime`), INTERVAL '10' SECOND)) + GROUP BY window_start, window_end) B1 + ON B.price = B1.maxprice +WHERE B.`dateTime` BETWEEN B1.`dateTime` - INTERVAL '10' SECOND AND B1.`dateTime`;
