gengliangwang commented on PR #45879:
URL: https://github.com/apache/spark/pull/45879#issuecomment-2037856614
@panbingkun this task should cover all the logWarning under the `connector`
directory:
```
spark/connector $ grep -r logWarning
./kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala:
logWarning(e.getMessage)
./kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala:
logWarning(e.getMessage)
./kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala:
logWarning(e.getMessage)
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchStream.scala:
logWarning(message + s". $INSTRUCTION_FOR_FAIL_ON_DATA_LOSS_FALSE")
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala:
logWarning(message + s". $INSTRUCTION_FOR_FAIL_ON_DATA_LOSS_FALSE")
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/producer/CachedKafkaProducer.scala:
case NonFatal(e) => logWarning("Error while closing kafka producer.", e)
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/producer/InternalKafkaProducerPool.scala:
logWarning(s"Released producer ${producer.id} is not a member of the
cache. Closing.")
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/producer/InternalKafkaProducerPool.scala:
logWarning("Ignoring Exception while shutting down pools from shutdown
hook", e)
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala:
logWarning(CUSTOM_GROUP_ID_ERROR_MESSAGE)
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala:
logWarning("Option 'groupIdPrefix' will be ignored as " +
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala:
logWarning("maxOffsetsPerTrigger option ignored in batch queries")
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala:
logWarning("minOffsetsPerTrigger option ignored in batch queries")
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala:
logWarning("maxTriggerDelay option ignored in batch queries")
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetReaderConsumer.scala:
logWarning("Found incorrect offsets in some partitions " +
./kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetReaderConsumer.scala:
logWarning("Retrying to fetch latest offsets because of incorrect
offsets")
....
```
--
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]
