Skip to content
Snippets Groups Projects
  • cody koeninger's avatar
    47864840
    [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2 · 47864840
    cody koeninger authored
    i don't think this should be merged until after 1.3.0 is final
    
    Author: cody koeninger <cody@koeninger.org>
    Author: Helena Edelson <helena.edelson@datastax.com>
    
    Closes #4537 from koeninger/wip-2808-kafka-0.8.2-upgrade and squashes the following commits:
    
    803aa2c [cody koeninger] [SPARK-2808][Streaming][Kafka] code cleanup per TD
    e6dfaf6 [cody koeninger] [SPARK-2808][Streaming][Kafka] pointless whitespace change to trigger jenkins again
    1770abc [cody koeninger] [SPARK-2808][Streaming][Kafka] make waitUntilLeaderOffset easier to call, call it from python tests as well
    d4267e9 [cody koeninger] [SPARK-2808][Streaming][Kafka] fix stderr redirect in python test script
    30d991d [cody koeninger] [SPARK-2808][Streaming][Kafka] remove stderr prints since it breaks python 3 syntax
    1d896e2 [cody koeninger] [SPARK-2808][Streaming][Kafka] add even even more logging to python test
    4c4557f [cody koeninger] [SPARK-2808][Streaming][Kafka] add even more logging to python test
    115aeee [cody koeninger] Merge branch 'master' into wip-2808-kafka-0.8.2-upgrade
    2712649 [cody koeninger] [SPARK-2808][Streaming][Kafka] add more logging to python test, see why its timing out in jenkins
    2b92d3f [cody koeninger] [SPARK-2808][Streaming][Kafka] wait for leader offsets in the java test as well
    3824ce3 [cody koeninger] [SPARK-2808][Streaming][Kafka] naming / comments per tdas
    61b3464 [cody koeninger] [SPARK-2808][Streaming][Kafka] delay for second send in boundary condition test
    af6f3ec [cody koeninger] [SPARK-2808][Streaming][Kafka] delay test until latest leader offset matches expected value
    9edab4c [cody koeninger] [SPARK-2808][Streaming][Kafka] more shots in the dark on jenkins failing test
    c70ee43 [cody koeninger] [SPARK-2808][Streaming][Kafka] add more asserts to test, try to figure out why it fails on jenkins but not locally
    1d10751 [cody koeninger] Merge branch 'master' into wip-2808-kafka-0.8.2-upgrade
    ed02d2c [cody koeninger] [SPARK-2808][Streaming][Kafka] move default argument for api version to overloaded method, for binary compat
    407382e [cody koeninger] [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2.1
    77de6c2 [cody koeninger] Merge branch 'master' into wip-2808-kafka-0.8.2-upgrade
    6953429 [cody koeninger] [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2
    2e67c66 [Helena Edelson] #SPARK-2808 Update to Kafka 0.8.2.0 GA from beta.
    d9dc2bc [Helena Edelson] Merge remote-tracking branch 'upstream/master' into wip-2808-kafka-0.8.2-upgrade
    e768164 [Helena Edelson] #2808 update kafka to version 0.8.2
    47864840
    History
    [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2
    cody koeninger authored
    i don't think this should be merged until after 1.3.0 is final
    
    Author: cody koeninger <cody@koeninger.org>
    Author: Helena Edelson <helena.edelson@datastax.com>
    
    Closes #4537 from koeninger/wip-2808-kafka-0.8.2-upgrade and squashes the following commits:
    
    803aa2c [cody koeninger] [SPARK-2808][Streaming][Kafka] code cleanup per TD
    e6dfaf6 [cody koeninger] [SPARK-2808][Streaming][Kafka] pointless whitespace change to trigger jenkins again
    1770abc [cody koeninger] [SPARK-2808][Streaming][Kafka] make waitUntilLeaderOffset easier to call, call it from python tests as well
    d4267e9 [cody koeninger] [SPARK-2808][Streaming][Kafka] fix stderr redirect in python test script
    30d991d [cody koeninger] [SPARK-2808][Streaming][Kafka] remove stderr prints since it breaks python 3 syntax
    1d896e2 [cody koeninger] [SPARK-2808][Streaming][Kafka] add even even more logging to python test
    4c4557f [cody koeninger] [SPARK-2808][Streaming][Kafka] add even more logging to python test
    115aeee [cody koeninger] Merge branch 'master' into wip-2808-kafka-0.8.2-upgrade
    2712649 [cody koeninger] [SPARK-2808][Streaming][Kafka] add more logging to python test, see why its timing out in jenkins
    2b92d3f [cody koeninger] [SPARK-2808][Streaming][Kafka] wait for leader offsets in the java test as well
    3824ce3 [cody koeninger] [SPARK-2808][Streaming][Kafka] naming / comments per tdas
    61b3464 [cody koeninger] [SPARK-2808][Streaming][Kafka] delay for second send in boundary condition test
    af6f3ec [cody koeninger] [SPARK-2808][Streaming][Kafka] delay test until latest leader offset matches expected value
    9edab4c [cody koeninger] [SPARK-2808][Streaming][Kafka] more shots in the dark on jenkins failing test
    c70ee43 [cody koeninger] [SPARK-2808][Streaming][Kafka] add more asserts to test, try to figure out why it fails on jenkins but not locally
    1d10751 [cody koeninger] Merge branch 'master' into wip-2808-kafka-0.8.2-upgrade
    ed02d2c [cody koeninger] [SPARK-2808][Streaming][Kafka] move default argument for api version to overloaded method, for binary compat
    407382e [cody koeninger] [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2.1
    77de6c2 [cody koeninger] Merge branch 'master' into wip-2808-kafka-0.8.2-upgrade
    6953429 [cody koeninger] [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2
    2e67c66 [Helena Edelson] #SPARK-2808 Update to Kafka 0.8.2.0 GA from beta.
    d9dc2bc [Helena Edelson] Merge remote-tracking branch 'upstream/master' into wip-2808-kafka-0.8.2-upgrade
    e768164 [Helena Edelson] #2808 update kafka to version 0.8.2