spark git commit: [SPARK-18497][SS] Make ForeachSink support watermark

2016-11-18 Thread tdas
Repository: spark Updated Branches: refs/heads/branch-2.1 4b1df0e89 -> b4bad04c5 [SPARK-18497][SS] Make ForeachSink support watermark ## What changes were proposed in this pull request? The issue in ForeachSink is the new created DataSet still uses the old QueryExecution. When

spark git commit: [SPARK-18497][SS] Make ForeachSink support watermark

2016-11-18 Thread tdas
Repository: spark Updated Branches: refs/heads/master 6f7ff7509 -> 2a40de408 [SPARK-18497][SS] Make ForeachSink support watermark ## What changes were proposed in this pull request? The issue in ForeachSink is the new created DataSet still uses the old QueryExecution. When