aboutsummaryrefslogtreecommitdiff
path: root/external
Commit message (Expand)AuthorAgeFilesLines
* SPARK-6182 [BUILD] spark-parent pom needs to be published for both 2.10 and 2.11Sean Owen2015-03-057-7/+7
* [Streaming][Minor] Remove useless type signature of Java Kafka direct stream APISaisai Shao2015-02-271-1/+1
* [SPARK-6027][SPARK-5546] Fixed --jar and --packages not working for KafkaUtil...Tathagata Das2015-02-261-1/+28
* [SPARK-5666][streaming][MQTT streaming] some trivial fixesprabs2015-02-253-20/+21
* [SPARK-5993][Streaming][Build] Fix assembly jar location of kafka-assemblyTathagata Das2015-02-241-4/+0
* SPARK-4682 [CORE] Consolidate various 'Clock' classesSean Owen2015-02-195-8/+7
* [SPARK-5731][Streaming][Test] Fix incorrect test in DirectKafkaStreamSuiteTathagata Das2015-02-171-12/+16
* SPARK-5850: Remove experimental label for Scala 2.11 and FlumePollingStreamPatrick Wendell2015-02-161-8/+0
* [HOTFIX] Ignore DirectKafkaStreamSuite.Reynold Xin2015-02-131-4/+4
* SPARK-5728 [STREAMING] MQTTStreamSuite leaves behind ActiveMQ database filesSean Owen2015-02-111-0/+1
* [SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead o...cody koeninger2015-02-114-66/+287
* [SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka streamTathagata Das2015-02-0915-262/+864
* [SPARK-4905][STREAMING] FlumeStreamSuite fix.Hari Shreedharan2015-02-091-4/+3
* [SPARK-4707][STREAMING] Reliable Kafka Receiver can lose data if the blo...Hari Shreedharan2015-02-041-4/+23
* [SPARK-4964] [Streaming] Exactly-once semantics for Kafkacody koeninger2015-02-0412-6/+1376
* [SPARK-5153][Streaming][Test] Increased timeout to deal with flaky KafkaStrea...Tathagata Das2015-02-031-1/+1
* [SPARK-5154] [PySpark] [Streaming] Kafka streaming support in PythonDavies Liu2015-02-021-0/+106
* [SPARK-4631][streaming][FIX] Wait for a receiver to start before publishing t...Iulian Dragos2015-02-022-15/+46
* [SPARK-5006][Deploy]spark.port.maxRetries doesn't workWangTaoTheTonic2015-01-132-2/+3
* [Minor]Resolve sbt warnings during build (MQTTStreamSuite.scala).GuoQiang Li2015-01-101-0/+1
* [Minor] Fix import order and other coding stylebilna2015-01-091-6/+11
* [SPARK-4048] Enhance and extend hadoop-provided profile.Marcelo Vanzin2015-01-083-34/+4
* SPARK-4159 [CORE] Maven build doesn't run JUnit test suitesSean Owen2015-01-0612-81/+11
* [SPARK-4631] unit test for MQTTbilna2015-01-042-15/+101
* [SPARK-1010] Clean up uses of System.setProperty in unit testsJosh Rosen2014-12-304-8/+24
* fixed spelling errors in documentationPeter Klipfel2014-12-141-3/+3
* [SPARK-3154][STREAMING] Replace ConcurrentHashMap with mutable.HashMap and re...zsxwing2014-12-081-11/+12
* [SPARK-4632] version updatePrabeesh K2014-11-301-2/+2
* SPARK-3962 Marked scope as provided for external projects.Prashant Sharma2014-11-1914-48/+264
* Bumping version to 1.3.0-SNAPSHOT.Marcelo Vanzin2014-11-186-6/+6
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-146-132/+587
* Support cross building for Scala 2.11Prashant Sharma2014-11-111-5/+0
* [SPARK-2492][Streaming] kafkaReceiver minor changes to align with Kafka 0.8jerryshao2014-11-112-36/+5
* [SPARK-4295][External]Fix exception in SparkSinkSuitemaji20142014-11-112-0/+30
* [SPARK-4183] Close transport-related resources between SparkContextsAaron Davidson2014-11-021-5/+10
* [SPARK-4080] Only throw IOException from [write|read][Object|External]Josh Rosen2014-10-241-2/+2
* [SPARK-3912][Streaming] Fixed flakyFlumeStreamSuiteTathagata Das2014-10-131-64/+102
* [SPARK-3748] Log thread name in unit test logsReynold Xin2014-10-015-5/+5
* SPARK-3744 [STREAMING] FlumeStreamSuite will fail during port contentionSean Owen2014-09-301-10/+15
* [SPARK-3686][STREAMING] Wait for sink to commit the channel before check...Hari Shreedharan2014-09-254-10/+48
* [SPARK-3615][Streaming]Fix Kafka unit test hard coded Zookeeper port issuejerryshao2014-09-242-14/+34
* [SPARK-3397] Bump pom.xml version number of master branch to 1.2.0-SNAPSHOTGuoQiang Li2014-09-066-6/+6
* [Minor]Remove extra semicolon in FlumeStreamSuite.scalaGuoQiang Li2014-09-041-5/+5
* [SPARK-3154][STREAMING] Make FlumePollingInputDStream shutdown cleaner.Hari Shreedharan2014-08-275-86/+236
* SPARK-2798 [BUILD] Correct several small errors in Flume module pom.xml filesSean Owen2014-08-252-15/+12
* [SPARK-3169] Removed dependency on spark streaming test from spark flume sinkTathagata Das2014-08-222-11/+17
* [SPARK-3054][STREAMING] Add unit tests for Spark Sink.Hari Shreedharan2014-08-204-2/+212
* [HOTFIX][STREAMING] Allow the JVM/Netty to decide which port to bind to in Fl...Hari Shreedharan2014-08-172-29/+34
* [HOTFIX][Streaming] Handle port collisions in flume polling testAndrew Or2014-08-061-1/+31
* [SPARK-1022][Streaming][HOTFIX] Fixed zookeeper dependency of KafkaTathagata Das2014-08-051-0/+4
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-03 17:34:51 +0000