wangsan created SPARK-22503: ------------------------------- Summary: Using current processing time to generate windows in streaming processing Key: SPARK-22503 URL: https://issues.apache.org/jira/browse/SPARK-22503 Project: Spark Issue Type: Improvement Components: Structured Streaming Affects Versions: 2.3.0 Reporter: wangsan
There are cases we want to use processing time to generate windows in stream processing, but `current_timestamp()` are not allowed in `window()` function now. When using `current_timestamp` in `window` function, the exception tells "nondeterministic expressions are only allowed in Project, Filter, Aggregate or Window". -- This message was sent by Atlassian JIRA (v6.4.14#64029) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org