Can you show all the code?  This works for me.

On Tue, Sep 12, 2017 at 12:05 AM, 张万新 <> wrote:
The spark version is 2.2.0

Michael Armbrust <>于2017年9月12日周二 下午12:32写道:
Which version of spark?

On Mon, Sep 11, 2017 at 8:27 PM, 张万新 <> wrote:
Thanks for reply, but using this method I got an exception:

"Exception in thread "main" org.apache.spark.sql.streaming.StreamingQueryException: nondeterministic expressions are only allowed in

Project, Filter, Aggregate or Window"

Can you give more advice?

Michael Armbrust <>于2017年9月12日周二 上午4:48写道:
import org.apache.spark.sql.functions._

df.withColumn("window", window(current_timestamp(), "15 minutes"))

On Mon, Sep 11, 2017 at 3:03 AM, 张万新 <> wrote:

In structured streaming how can I add a column to a dataset with current system time aligned with 15 minutes?