spark-instrumented-optimizer/python/pyspark/streaming
cody koeninger b127ff8a0c [SPARK-2808] [STREAMING] [KAFKA] cleanup tests from
see if requiring producer acks eliminates the need for waitUntilLeaderOffset calls in tests

Author: cody koeninger <cody@koeninger.org>

Closes #5921 from koeninger/kafka-0.8.2-test-cleanup and squashes the following commits:

1e89dc8 [cody koeninger] Merge branch 'master' into kafka-0.8.2-test-cleanup
4662828 [cody koeninger] [Streaming][Kafka] filter mima issue for removal of method from private test class
af1e083 [cody koeninger] Merge branch 'master' into kafka-0.8.2-test-cleanup
4298ac2 [cody koeninger] [Streaming][Kafka] update comment to trigger jenkins attempt
1274afb [cody koeninger] [Streaming][Kafka] see if requiring producer acks eliminates the need for waitUntilLeaderOffset calls in tests
2015-06-07 21:42:45 +01:00
..
__init__.py [SPARK-2377] Python API for Streaming 2014-10-12 02:46:56 -07:00
context.py [SPARK-6949] [SQL] [PySpark] Support Date/Timestamp in Column expression 2015-04-21 00:08:18 -07:00
dstream.py [SPARK-4897] [PySpark] Python 3 support 2015-04-16 16:20:57 -07:00
kafka.py [SPARK-6657] [PYSPARK] Fix doc warnings 2015-05-18 08:35:14 -07:00
tests.py [SPARK-2808] [STREAMING] [KAFKA] cleanup tests from 2015-06-07 21:42:45 +01:00
util.py [SPARK-4897] [PySpark] Python 3 support 2015-04-16 16:20:57 -07:00