aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-11627] Add initial input rate limit for spark streaming backpressure m...junhao2016-02-161-1/+8
* [SPARK-13280][STREAMING] Use a better logger name for FileBasedWriteAheadLog.Marcelo Vanzin2016-02-161-5/+15
* [SPARK-13172][CORE][SQL] Stop using RichException.getStackTrace it is deprecatedSean Owen2016-02-131-2/+2
* [SPARK-13170][STREAMING] Investigate replacing SynchronizedQueue as it is dep...Sean Owen2016-02-092-7/+10
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-094-19/+23
* [SPARK-13195][STREAMING] Fix NoSuchElementException when a state is not set b...Shixiong Zhu2016-02-041-1/+2
* [SPARK-12739][STREAMING] Details of batch in Streaming tab uses two Duration ...Mario Briggs2016-02-031-2/+2
* [SPARK-13121][STREAMING] java mapWithState mishandles scala OptionGabriele Nizzoli2016-02-021-1/+1
* [SPARK-6847][CORE][STREAMING] Fix stack overflow issue when updateStateByKey ...Shixiong Zhu2016-02-012-2/+10
* [SPARK-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...Sean Owen2016-01-263-8/+6
* [STREAMING][MINOR] Scaladoc + logsJacek Laskowski2016-01-234-6/+5
* [SPARK-11137][STREAMING] Make StreamingContext.stop() exception-safejayadevanmurali2016-01-231-4/+12
* [SPARK-12859][STREAMING][WEB UI] Names of input streams with receivers don't ...Alex Bozarth2016-01-231-1/+1
* [SPARK-7799][SPARK-12786][STREAMING] Add "streaming-akka" projectShixiong Zhu2016-01-203-332/+1
* [SPARK-12847][CORE][STREAMING] Remove StreamingListenerBus and post all Strea...Shixiong Zhu2016-01-203-22/+60
* [SPARK-10985][CORE] Avoid passing evicted blocks throughout BlockManagerJosh Rosen2016-01-181-4/+4
* [SPARK-12652][PYSPARK] Upgrade Py4J to 0.9.1Shixiong Zhu2016-01-121-10/+0
* [SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space b...Kousuke Saruta2016-01-1113-56/+56
* [SPARK-3873][BUILD] Enable import ordering error checking.Marcelo Vanzin2016-01-102-2/+2
* [SPARK-4819] Remove Guava's "Optional" from public APISean Owen2016-01-082-7/+8
* [SPARK-12591][STREAMING] Register OpenHashMapBasedStateMap for KryoShixiong Zhu2016-01-071-21/+50
* [SPARK-12510][STREAMING] Refactor ActorReceiver to support JavaShixiong Zhu2016-01-072-12/+56
* [STREAMING][MINOR] More contextual information in logs + minor code i…Jacek Laskowski2016-01-078-66/+61
* [SPARK-7689] Remove TTL-based metadata cleaning in Spark 2.0Josh Rosen2016-01-062-15/+2
* [SPARK-12604][CORE] Java count(AprroxDistinct)ByKey methods return Scala Long...Sean Owen2016-01-062-12/+13
* Revert "[SPARK-12672][STREAMING][UI] Use the uiRoot function instead of defau...Shixiong Zhu2016-01-061-3/+2
* [SPARK-12672][STREAMING][UI] Use the uiRoot function instead of default root ...huangzhaowei2016-01-061-2/+3
* [SPARK-12511] [PYSPARK] [STREAMING] Make sure PythonDStream.registerSerialize...Shixiong Zhu2016-01-051-0/+12
* [SPARK-12608][STREAMING] Remove submitJobThreadPool since submitJob doesn't c...Shixiong Zhu2016-01-041-6/+1
* [SPARK-12513][STREAMING] SocketReceiver hang in Netcat exampleguoxu12312016-01-041-14/+24
* [SPARK-12481][CORE][STREAMING][SQL] Remove usage of Hadoop deprecated APIs an...Sean Owen2016-01-022-10/+3
* [SPARK-3873][STREAMING] Import order fixes for streaming.Marcelo Vanzin2015-12-3153-125/+126
* [MINOR] Fix typos in JavaStreamingContextShixiong Zhu2015-12-211-4/+4
* [SPARK-11749][STREAMING] Duplicate creating the RDD in file stream when recov...jhu-chang2015-12-171-5/+10
* [SPARK-12410][STREAMING] Fix places that use '.' and '|' directly in splitShixiong Zhu2015-12-171-1/+1
* [SPARK-12304][STREAMING] Make Spark Streaming web UI display more fri…proflin2015-12-151-1/+7
* [STREAMING][MINOR] Fix typo in function name of StateImpljerryshao2015-12-152-2/+2
* [SPARK-12273][STREAMING] Make Spark Streaming web UI list Receivers in orderproflin2015-12-111-2/+3
* [SPARK-11713] [PYSPARK] [STREAMING] Initial RDD updateStateByKey for PySparkBryan Cutler2015-12-101-2/+12
* [SPARK-12136][STREAMING] rddToFileName does not properly handle prefix and su...bomeng2015-12-101-6/+7
* [SPARK-12244][SPARK-12245][STREAMING] Rename trackStateByKey to mapWithState ...Tathagata Das2015-12-097-221/+230
* [SPARK-11932][STREAMING] Partition previous TrackStateRDD if partitioner not ...Tathagata Das2015-12-073-17/+53
* [SPARK-12106][STREAMING][FLAKY-TEST] BatchedWAL test transiently flaky when J...Burak Yavuz2015-12-071-2/+4
* [SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectlyShixiong Zhu2015-12-043-22/+12
* [SPARK-6990][BUILD] Add Java linting script; fix minor warningsDmitry Erastov2015-12-041-5/+5
* [SPARK-12122][STREAMING] Prevent batches from being submitted twice after rec...Tathagata Das2015-12-041-1/+2
* [SPARK-12001] Allow partially-stopped StreamingContext to be completely stoppedJosh Rosen2015-12-021-22/+27
* [SPARK-12087][STREAMING] Create new JobConf for every batch in saveAsHadoopFilesTathagata Das2015-12-011-1/+2
* [SPARK-12046][DOC] Fixes various ScalaDoc/JavaDoc issuesCheng Lian2015-12-016-52/+60
* [SPARK-11935][PYSPARK] Send the Python exceptions in TransformFunction and Tr...Shixiong Zhu2015-11-251-9/+43
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-03 04:55:07 +0000