diff options
| author | Kunal Khamar <kkhamar@outlook.com> | 2017-03-17 16:16:22 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2017-03-17 16:16:22 -0700 |
| commit | 3783539d7ab83a2a632a9f35ca66ae39d01c28b6 (patch) | |
| tree | 3a0116afdb691aedd54ae25cb0924affafa49289 /sql/core/src/test/resources/structured-streaming/checkpoint-version-2.1.0/offsets/1 | |
| parent | 7de66bae58733595cb88ec899640f7acf734d5c4 (diff) | |
| download | spark-3783539d7ab83a2a632a9f35ca66ae39d01c28b6.tar.gz spark-3783539d7ab83a2a632a9f35ca66ae39d01c28b6.tar.bz2 spark-3783539d7ab83a2a632a9f35ca66ae39d01c28b6.zip | |
[SPARK-19873][SS] Record num shuffle partitions in offset log and enforce in next batch.
## What changes were proposed in this pull request?
If the user changes the shuffle partition number between batches, Streaming aggregation will fail.
Here are some possible cases:
- Change "spark.sql.shuffle.partitions"
- Use "repartition" and change the partition number in codes
- RangePartitioner doesn't generate deterministic partitions. Right now it's safe as we disallow sort before aggregation. Not sure if we will add some operators using RangePartitioner in future.
## How was this patch tested?
- Unit tests
- Manual tests
- forward compatibility tested by using the new `OffsetSeqMetadata` json with Spark v2.1.0
Author: Kunal Khamar <kkhamar@outlook.com>
Closes #17216 from kunalkhamar/num-partitions.
Diffstat (limited to 'sql/core/src/test/resources/structured-streaming/checkpoint-version-2.1.0/offsets/1')
| -rw-r--r-- | sql/core/src/test/resources/structured-streaming/checkpoint-version-2.1.0/offsets/1 | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/sql/core/src/test/resources/structured-streaming/checkpoint-version-2.1.0/offsets/1 b/sql/core/src/test/resources/structured-streaming/checkpoint-version-2.1.0/offsets/1 new file mode 100644 index 0000000000..10b5774746 --- /dev/null +++ b/sql/core/src/test/resources/structured-streaming/checkpoint-version-2.1.0/offsets/1 @@ -0,0 +1,3 @@ +v1 +{"batchWatermarkMs":0,"batchTimestampMs":1489180209261} +2
\ No newline at end of file |