[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user asfgit closed the pull request at: https://github.com/apache/spark/pull/20253 --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161901973 --- Diff: external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaContinuousTest.scala --- @@ -0,0 +1,91 @@ +/* + * Licensed to the

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161901930 --- Diff: external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaContinuousTest.scala --- @@ -0,0 +1,91 @@ +/* + * Licensed to the

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161901653 --- Diff: external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaContinuousTest.scala --- @@ -0,0 +1,91 @@ +/* + * Licensed to the

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161901683 --- Diff: external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaContinuousTest.scala --- @@ -0,0 +1,91 @@ +/* + * Licensed to the

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161360701 --- Diff: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReader.scala --- @@ -0,0 +1,253 @@ +/* + *

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161359025 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDDIter.scala --- @@ -177,6 +176,7 @@ class

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161358227 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDDIter.scala --- @@ -177,6 +176,7 @@ class

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161358195 --- Diff: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReader.scala --- @@ -0,0 +1,253 @@ +/* + * Licensed to

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161357974 --- Diff: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReader.scala --- @@ -0,0 +1,253 @@ +/* + * Licensed to

[GitHub] spark pull request #20253: [SPARK-22908][SS] Roll forward continuous process...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/20253#discussion_r161357488 --- Diff: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReader.scala --- @@ -0,0 +1,253 @@ +/* + * Licensed to