index
:
spark
2.12/build
SPARK-10001-hotfix
SPARK-10001-sigint
SPARK-14511-genjavadoc
SPARK-17647
WIP-SPARK-17647
escape
genjavadoc
macros
master
packages
scala-2.12
value-classes
Mirror of Apache Spark
about
summary
refs
log
tree
commit
diff
log msg
author
committer
range
path:
root
/
streaming
/
src
/
test
Commit message (
Expand
)
Author
Age
Files
Lines
*
SPARK-6338 [CORE] Use standard temp dir mechanisms in tests to avoid orphane...
Sean Owen
2015-03-20
5
-27
/
+14
*
[SPARK-6222][Streaming] Dont delete checkpoint data when doing pre-batch-star...
Tathagata Das
2015-03-19
1
-0
/
+133
*
[SPARK-6331] Load new master URL if present when recovering streaming context...
Tathagata Das
2015-03-17
2
-4
/
+19
*
[SPARK-6077] Remove streaming tab while stopping StreamingContext
lisurprise
2015-03-16
2
-55
/
+95
*
SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 edition
Sean Owen
2015-03-11
1
-0
/
+4
*
[SPARK-5943][Streaming] Update the test to use new API to reduce the warning
Saisai Shao
2015-02-23
2
-6
/
+6
*
SPARK-4682 [CORE] Consolidate various 'Clock' classes
Sean Owen
2015-02-19
8
-65
/
+57
*
SPARK-5795 [STREAMING] api.java.JavaPairDStream.saveAsNewAPIHadoopFiles may n...
Sean Owen
2015-02-16
1
-0
/
+18
*
[SPARK-5379][Streaming] Add awaitTerminationOrTimeout
zsxwing
2015-02-04
1
-0
/
+24
*
[SPARK-4969][STREAMING][PYTHON] Add binaryRecords to streaming
freeman
2015-02-03
1
-0
/
+51
*
[STREAMING] SPARK-4986 Wait for receivers to deregister and receiver job to t...
Jesper Lundgren
2015-02-03
1
-0
/
+58
*
Make sure only owner can read / write to directories created for the job.
Marcelo Vanzin
2015-02-02
1
-2
/
+2
*
SPARK-4430 [STREAMING] [TEST] Apache RAT Checks fail spuriously on test files
Sean Owen
2015-01-25
1
-7
/
+2
*
[SPARK-5315][Streaming] Fix reduceByWindow Java API not work bug
jerryshao
2015-01-22
1
-2
/
+18
*
[SPARK-5233][Streaming] Fix error replaying of WAL introduced bug
jerryshao
2015-01-22
1
-10
/
+10
*
[SPARK-5147][Streaming] Delete the received data WAL log periodically
Tathagata Das
2015-01-21
1
-31
/
+126
*
[SPARK-5297][Streaming] Fix Java file stream type erasure problem
jerryshao
2015-01-20
1
-5
/
+65
*
[SPARK-4803] [streaming] Remove duplicate RegisterReceiver message
Ilayaperumal Gopinathan
2015-01-20
1
-2
/
+2
*
SPARK-4159 [CORE] Maven build doesn't run JUnit test suites
Sean Owen
2015-01-06
1
-3
/
+2
*
[SPARK-1600] Refactor FileInputStream tests to remove Thread.sleep() calls an...
Josh Rosen
2015-01-06
4
-129
/
+236
*
[SPARK-4835] Disable validateOutputSpecs for Spark Streaming jobs
Josh Rosen
2015-01-04
1
-0
/
+39
*
[SPARK-4790][STREAMING] Fix ReceivedBlockTrackerSuite waits for old file...
Hari Shreedharan
2014-12-31
3
-4
/
+18
*
[SPARK-1010] Clean up uses of System.setProperty in unit tests
Josh Rosen
2014-12-30
1
-2
/
+6
*
[SPARK-4608][Streaming] Reorganize StreamingContext implicit to improve API c...
zsxwing
2014-12-25
5
-4
/
+35
*
SPARK-4297 [BUILD] Build warning fixes omnibus
Sean Owen
2014-12-24
1
-8
/
+8
*
[SPARK-4826] Fix generation of temp file names in WAL tests
Josh Rosen
2014-12-15
2
-17
/
+20
*
HOTFIX: Disabling failing block manager test
Patrick Wendell
2014-12-15
1
-5
/
+5
*
[SPARK-4196][SPARK-4602][Streaming] Fix serialization issue in PairDStreamFun...
Tathagata Das
2014-11-25
1
-2
/
+54
*
[SPARK-4601][Streaming] Set correct call site for streaming jobs so that it i...
Tathagata Das
2014-11-25
1
-1
/
+5
*
[SPARK-4518][SPARK-4519][Streaming] Refactored file stream to prevent files f...
Tathagata Das
2014-11-24
2
-50
/
+58
*
[SPARK-4482][Streaming] Disable ReceivedBlockTracker's write ahead log by def...
Tathagata Das
2014-11-19
1
-14
/
+36
*
[SPARK-4180] [Core] Prevent creation of multiple active SparkContexts
Josh Rosen
2014-11-17
2
-102
/
+136
*
[SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...
jerryshao
2014-11-14
1
-2
/
+6
*
[SPARK-4370] [Core] Limit number of Netty cores based on executor size
Aaron Davidson
2014-11-12
1
-1
/
+1
*
[SPARK-3660][STREAMING] Initial RDD for updateStateByKey transformation
Soumitra Kumar
2014-11-12
2
-4
/
+123
*
[SPARK-4301] StreamingContext should not allow start() to be called after cal...
Josh Rosen
2014-11-08
1
-6
/
+19
*
[SPARK-4242] [Core] Add SASL to external shuffle service
Aaron Davidson
2014-11-05
1
-1
/
+1
*
[SPARK-4029][Streaming] Update streaming driver to reliably save and recover ...
Tathagata Das
2014-11-05
3
-11
/
+254
*
[SPARK-2938] Support SASL authentication in NettyBlockTransferService
Aaron Davidson
2014-11-04
1
-0
/
+1
*
[SPARK-4183] Close transport-related resources between SparkContexts
Aaron Davidson
2014-11-02
1
-0
/
+4
*
[SPARK-4027][Streaming] WriteAheadLogBackedBlockRDD to read received either f...
Tathagata Das
2014-10-30
1
-0
/
+151
*
[SPARK-4028][Streaming] ReceivedBlockHandler interface to abstract the functi...
Tathagata Das
2014-10-30
2
-13
/
+279
*
[SPARK-4053][Streaming] Made the ReceiverSuite test more reliable, by fixing ...
Tathagata Das
2014-10-29
1
-14
/
+30
*
[SPARK-4080] Only throw IOException from [write|read][Object|External]
Josh Rosen
2014-10-24
1
-2
/
+2
*
[SPARK-4026][Streaming] Write ahead log management
Hari Shreedharan
2014-10-24
1
-0
/
+357
*
[SPARK-2805] Upgrade Akka to 2.3.4
Anand Avati
2014-10-10
1
-71
/
+0
*
SPARK-3811 [CORE] More robust / standard Utils.deleteRecursively, Utils.creat...
Sean Owen
2014-10-09
4
-9
/
+5
*
Revert "[SPARK-2805] Upgrade to akka 2.3.4"
Patrick Wendell
2014-10-09
1
-0
/
+71
*
[SPARK-2805] Upgrade to akka 2.3.4
Anand Avati
2014-10-08
1
-71
/
+0
*
[SPARK-3377] [SPARK-3610] Metrics can be accidentally aggregated / History se...
Kousuke Saruta
2014-10-03
1
-4
/
+10
[next]