Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103102481
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -195,6 +196,11 @@ class HDFSMetadataLog[T <: AnyRef
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103102422
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -268,6 +274,37 @@ class HDFSMetadataLog[T <: AnyRef
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103102416
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -18,6 +18,7 @@
package
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103102420
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -268,6 +274,37 @@ class HDFSMetadataLog[T <: AnyRef
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103102394
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala
---
@@ -100,7 +100,8 @@ private[kafka010] class
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103102389
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
---
@@ -226,7 +226,15 @@ class KafkaSourceSuite
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103098735
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala
---
@@ -100,7 +100,8 @@ private[kafka010] class
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103098803
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -18,6 +18,7 @@
package
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103098815
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -268,6 +274,37 @@ class HDFSMetadataLog[T <: AnyRef
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103098721
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
---
@@ -226,7 +226,15 @@ class KafkaSourceSuite
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103098789
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -195,6 +196,11 @@ class HDFSMetadataLog[T <: AnyRef
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17070#discussion_r103098816
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala
---
@@ -268,6 +274,37 @@ class HDFSMetadataLog[T <: AnyRef
GitHub user lw-lin opened a pull request:
https://github.com/apache/spark/pull/17070
[WIP][SS] Good error message for version mismatch in log files
## What changes were proposed in this pull request?
(Please fill in changes proposed in this fix)
## How was this
13 matches
Mail list logo
