Hi, everyone. I am trying to do a stats query by F...
# troubleshooting
l
Hi, everyone. I am trying to do a stats query by Flink SQL Window TVF aggregation on an iceberg table with streaming read mode. How can I use table hints with Flink Window TVF? What's the correct syntax? Thanks in advance. πŸ₯Ί
Copy code
-- create connect table
CREATE TABLE default_catalog.default_database.`test_p` (
  id BIGINT,
  t BIGINT, 
  dt STRING,
  ts AS CAST(TO_TIMESTAMP_LTZ(t, 3) AS TIMESTAMP(3)),
  WATERMARK FOR ts AS ts - INTERVAL '5' SECOND
) 
PARTITIONED BY (dt)
WITH (
  'connector'='iceberg',
  ...
);

SET execution.runtime-mode = streaming;
SET table.dynamic-table-options.enabled = true;

/*+ OPTIONS('streaming'='true', 'monitor-interval'='15s')*/

-- Syntax error !
SELECT * FROM 
TABLE (
  TUMBLE(
    TABLE test_p ,
    DESCRIPTOR(ts),
    INTERVAL '5' MINUTES
  )
) /*+ OPTIONS('streaming'='true', 'monitor-interval'='15s')*/;
πŸ™‡β€β™‚οΈ 1
😭 1
πŸ™ 1