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
Commit message (
Expand
)
Author
Age
Files
Lines
*
[SPARK-19646][CORE][STREAMING] binaryRecords replicates records in scala API
Sean Owen
2017-02-20
2
-13
/
+13
*
[SPARK-19534][TESTS] Convert Java tests to use lambdas, Java 8 features
Sean Owen
2017-02-19
5
-500
/
+162
*
[SPARK-19450] Replace askWithRetry with askSync.
jinxing
2017-02-19
2
-5
/
+5
*
[SPARK-19550][BUILD][CORE][WIP] Remove Java 7 support
Sean Owen
2017-02-16
2
-1
/
+896
*
[SPARK-19520][STREAMING] Do not encrypt data written to the WAL.
Marcelo Vanzin
2017-02-13
4
-21
/
+69
*
[SPARK-19347] ReceiverSupervisorImpl can add block to ReceiverTracker multipl...
jinxing
2017-02-01
1
-1
/
+1
*
[SPARK-19402][DOCS] Support LaTex inline formula correctly and fix warnings i...
hyukjinkwon
2017-02-01
1
-1
/
+1
*
[SPARK-19330][DSTREAMS] Also show tooltip for successful batches
Liwei Lin
2017-01-24
1
-2
/
+2
*
[SPARK-19182][DSTREAM] Optimize the lock in StreamingJobProgressListener to n...
uncleGen
2017-01-18
2
-8
/
+13
*
[SPARK-18905][STREAMING] Fix the issue of removing a failed jobset from JobSc...
CodingCat
2017-01-16
1
-6
/
+8
*
[SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...
hyukjinkwon
2017-01-10
2
-3
/
+17
*
[MINOR][DOCS] Remove consecutive duplicated words/typo in Spark Repo
Niranjan Padmanabhan
2017-01-04
5
-6
/
+6
*
[SPARK-18537][WEB UI] Add a REST api to serve spark streaming information
saturday_s
2016-12-22
22
-4
/
+676
*
[FLAKY-TEST] InputStreamsSuite.socket input stream
Burak Yavuz
2016-12-21
1
-32
/
+23
*
[SPARK-17807][CORE] split test-tags into test-JAR
Ryan Williams
2016-12-21
1
-0
/
+11
*
[SPARK-18954][TESTS] Fix flaky test: o.a.s.streaming.BasicOperationsSuite rdd...
Shixiong Zhu
2016-12-21
2
-44
/
+73
*
[SPARK-18031][TESTS] Fix flaky test ExecutorAllocationManagerSuite.basic func...
Shixiong Zhu
2016-12-21
1
-4
/
+32
*
[SPARK-18695] Bump master branch version to 2.2.0-SNAPSHOT
Reynold Xin
2016-12-02
1
-1
/
+1
*
[SPARK-18617][SPARK-18560][TESTS] Fix flaky test: StreamingContextSuite. Rece...
Shixiong Zhu
2016-12-01
1
-1
/
+3
*
[SPARK-18617][SPARK-18560][TEST] Fix flaky test: StreamingContextSuite. Recei...
Shixiong Zhu
2016-11-30
1
-26
/
+8
*
[SPARK-18617][CORE][STREAMING] Close "kryo auto pick" feature for Spark Strea...
uncleGen
2016-11-29
1
-0
/
+47
*
[SPARK-18615][DOCS] Switch to multi-line doc to avoid a genjavadoc bug for ba...
hyukjinkwon
2016-11-29
1
-2
/
+6
*
[SPARK-3359][DOCS] Make javadoc8 working for unidoc/genjavadoc compatibility ...
hyukjinkwon
2016-11-29
4
-7
/
+7
*
[SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...
hyukjinkwon
2016-11-19
6
-33
/
+35
*
[SPARK-18423][STREAMING] ReceiverTracker should close checkpoint dir when sto...
hyukjinkwon
2016-11-15
1
-0
/
+10
*
[SPARK-13027][STREAMING] Added batch time as a parameter to updateStateByKey
Aaditya Ramesh
2016-11-15
4
-20
/
+126
*
[SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e...
wm624@hotmail.com
2016-11-10
2
-0
/
+2
*
[SPARK-18191][CORE] Port RDD API to use commit protocol
jiangxingbo
2016-11-08
2
-4
/
+6
*
[SPARK-14914][CORE] Fix Resource not closed after using, mostly for unit tests
Hyukjin Kwon
2016-11-07
5
-7
/
+17
*
[SPARK-18076][CORE][SQL] Fix default Locale used in DateFormat, NumberFormat ...
Sean Owen
2016-11-02
1
-3
/
+5
*
[SPARK-18204][WEBUI] Remove SparkUI.appUIAddress
Jacek Laskowski
2016-11-02
1
-6
/
+6
*
[SPARK-17638][STREAMING] Stop JVM StreamingContext when the Python process is...
Shixiong Zhu
2016-09-22
3
-2
/
+35
*
[SPARK-17365][CORE] Remove/Kill multiple executors together to reduce RPC cal...
Dhruve Ashar
2016-09-22
3
-4
/
+12
*
[SPARK-4563][CORE] Allow driver to advertise a different network address.
Marcelo Vanzin
2016-09-21
2
-2
/
+4
*
[SPARK-17359][SQL][MLLIB] Use ArrayBuffer.+=(A) instead of ArrayBuffer.append...
Liwei Lin
2016-09-07
1
-1
/
+1
*
[SPARK-17110] Fix StreamCorruptionException in BlockManager.getRemoteValues()
Josh Rosen
2016-09-06
2
-3
/
+5
*
[SPARK-17308] Improved the spark core code by replacing all pattern match on ...
Shivansh
2016-09-04
1
-3
/
+4
*
[SPARK-17038][STREAMING] fix metrics retrieval source of 'lastReceivedBatch'
Xin Ren
2016-08-17
2
-3
/
+6
*
[SPARK-16736][CORE][SQL] purge superfluous fs calls
Steve Loughran
2016-08-17
3
-30
/
+38
*
[SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu...
Holden Karau
2016-08-08
1
-1
/
+0
*
[SPARK-15869][STREAMING] Fix a potential NPE in StreamingJobProgressListener....
Shixiong Zhu
2016-08-01
1
-1
/
+1
*
[SPARK-16694][CORE] Use for/foreach rather than map for Unit expressions whos...
Sean Owen
2016-07-30
1
-1
/
+1
*
[SPARK-15703][SCHEDULER][CORE][WEBUI] Make ListenerBus event queue size confi...
Dhruve Ashar
2016-07-26
1
-1
/
+4
*
[SPARK-16722][TESTS] Fix a StreamingContext leak in StreamingContextSuite whe...
Shixiong Zhu
2016-07-25
1
-3
/
+6
*
[SPARK-16416][CORE] force eager creation of loggers to avoid shutdown hook co...
Mikael Ståldal
2016-07-24
1
-0
/
+1
*
[SPARK-16487][STREAMING] Fix some batches might not get marked as fully proce...
Ahmed Mahran
2016-07-22
1
-1
/
+3
*
[SPARK-16395][STREAMING] Fail if too many CheckpointWriteHandlers are queued ...
Sean Owen
2016-07-19
1
-3
/
+10
*
[SPARK-16535][BUILD] In pom.xml, remove groupId which is redundant definition...
Xin Ren
2016-07-19
1
-1
/
+0
*
[SPARK-16477] Bump master version to 2.1.0-SNAPSHOT
Reynold Xin
2016-07-11
1
-1
/
+1
*
[SPARK-16129][CORE][SQL] Eliminate direct use of commons-lang classes in favo...
Sean Owen
2016-06-24
2
-7
/
+4
[next]