HyukjinKwon commented on code in PR #37917:
URL: https://github.com/apache/spark/pull/37917#discussion_r973833478
##########
sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala:
##########
@@ -1599,9 +1599,18 @@ private[sql] object QueryExecutionErrors extends
QueryErrorsBase {
s"$commitProtocol does not support adding files with an absolute path")
}
- def microBatchUnsupportedByDataSourceError(srcName: String): Throwable = {
+ def microBatchUnsupportedByDataSourceError(
+ srcName: String,
+ disabledSources: String,
+ table: Table): Throwable = {
new UnsupportedOperationException(
- s"Data source $srcName does not support microbatch processing.")
+ s"""
+ |Data source $srcName does not support microbatch processing.
+ |
+ |It could be the data source is disabled at
spark.sql.streaming.disabledV2MicroBatchReaders
Review Comment:
Should better use `SQLConf.get.DISABLED_V2_STREAMING_MICROBATCH_READERS.key`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
