You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2023/10/11 21:24:00 UTC
[jira] [Created] (FLINK-33248) Calling CURRENT_WATERMARK without parameters gives IndexOutOfBoundsException
Bonnie Varghese created FLINK-33248:
---------------------------------------
Summary: Calling CURRENT_WATERMARK without parameters gives IndexOutOfBoundsException
Key: FLINK-33248
URL: https://issues.apache.org/jira/browse/FLINK-33248
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Reporter: Bonnie Varghese
Create a table
{code:java}
Flink SQL> CREATE TABLE T (ts TIMESTAMP(3)) WITH ('connector'='values', 'bounded'='true');
[INFO] Execute statement succeed. {code}
Select CURRENT_WATERMARK without parameters
{code:java}
Flink SQL> SELECT ts, CURRENT_WATERMARK() FROM T;
[ERROR] Could not execute SQL statement. Reason:
java.lang.IndexOutOfBoundsException: Index 0 out of bounds for length 0 {code}
{*}Expected Behavior{*}:
It should return a SqlValidatorException: No match found for function signature CURRENT_WATERMARK()
This is inline with other functions which expects a parameter
Example:
{code:java}
Flink SQL> SELECT ARRAY_JOIN();
[ERROR] Could not execute SQL statement. Reason:
org.apache.calcite.sql.validate.SqlValidatorException: No match found for function signature ARRAY_JOIN {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)