druid/extensions-core
Kyle Larose db91961af7
kubernetes: restart watch on null response (#12233)
* kubernetes: restart watch on null response

Kubernetes watches allow a client to efficiently processes changes to
resources. However, they have some idiosyncrasies. In particular, they
can error out for various reasons leading to what would normally be seen
as an invalid result.

The Druid kubernetes node discovery subsystem does not handle a certain
case properly. The watch can return an item with a null object.  These
leads to a null pointer exception. When this happens, the provider needs
to restart the watch, because rerunning the watch from the same resource
version leads to the same result: yet another null pointer exception.

This commit changes the provider to handle null objects by restarting
the watch.

* review: add more coverage

This adds a bit more coverage to the K8sDruidNodeDiscoveryProvider watch
loop, and removes an unnecessay return.

* kubernetes: reduce logging verbosity

The log messages about items being NULL don't really deserve to be at a
level other than DEBUG since they are not actionable, particularly since
we automatically recover now. Move them to the DEBUG level.
2022-03-10 12:56:40 -08:00
..
avro-extensions Make ParseExceptions more informative (#12259) 2022-02-28 22:31:15 +05:30
azure-extensions Adding Shared Access resource support for azure (#12266) 2022-02-22 18:27:43 +05:30
datasketches latest datasketches-java-3.1.0 (#12224) 2022-03-01 17:14:42 -08:00
druid-aws-rds-extensions bump version to 0.23.0-SNAPSHOT (#11670) 2021-09-08 15:56:04 -07:00
druid-basic-security Set Content-Type for String based response (#12295) 2022-03-04 15:17:03 +08:00
druid-bloom-filter A new includeAllDimension flag for dimensionsSpec (#12276) 2022-02-25 18:27:48 -08:00
druid-kerberos Reduce use of mocking and simplify some tests (#12283) 2022-02-26 17:23:09 -08:00
druid-pac4j bump version to 0.23.0-SNAPSHOT (#11670) 2021-09-08 15:56:04 -07:00
druid-ranger-security Reduce use of mocking and simplify some tests (#12283) 2022-02-26 17:23:09 -08:00
ec2-extensions bump version to 0.23.0-SNAPSHOT (#11670) 2021-09-08 15:56:04 -07:00
google-extensions Lazy instantiation for segmentKillers, segmentMovers, and segmentArchivers (#12207) 2022-02-08 13:02:06 -08:00
hdfs-storage Lazy instantiation for segmentKillers, segmentMovers, and segmentArchivers (#12207) 2022-02-08 13:02:06 -08:00
histogram allow optimizing sql expressions and virtual columns (#12241) 2022-02-09 14:55:50 -08:00
kafka-extraction-namespace use a non-concurrent map for lookups-cached-global unless incremental updates are actually required (#12293) 2022-03-08 21:54:25 -08:00
kafka-indexing-service fix supervisor auto scaler config serde bug (#12317) 2022-03-09 16:17:12 -08:00
kinesis-indexing-service fix supervisor auto scaler config serde bug (#12317) 2022-03-09 16:17:12 -08:00
kubernetes-extensions kubernetes: restart watch on null response (#12233) 2022-03-10 12:56:40 -08:00
lookups-cached-global use a non-concurrent map for lookups-cached-global unless incremental updates are actually required (#12293) 2022-03-08 21:54:25 -08:00
lookups-cached-single bump version to 0.23.0-SNAPSHOT (#11670) 2021-09-08 15:56:04 -07:00
mysql-metadata-storage do not explode if mysql transient exception class does not exist (#12213) 2022-02-01 09:06:24 +05:30
orc-extensions Make ParseExceptions more informative (#12259) 2022-02-28 22:31:15 +05:30
parquet-extensions Always reopen stream in FileUtils.copyLarge, RetryingInputStream. (#12307) 2022-03-05 14:39:14 -08:00
postgresql-metadata-storage bump version to 0.23.0-SNAPSHOT (#11670) 2021-09-08 15:56:04 -07:00
protobuf-extensions Make ParseExceptions more informative (#12259) 2022-02-28 22:31:15 +05:30
s3-extensions Always reopen stream in FileUtils.copyLarge, RetryingInputStream. (#12307) 2022-03-05 14:39:14 -08:00
simple-client-sslcontext bump version to 0.23.0-SNAPSHOT (#11670) 2021-09-08 15:56:04 -07:00
stats Reduce use of mocking and simplify some tests (#12283) 2022-02-26 17:23:09 -08:00
testing-tools Replace use of PowerMock with Mockito (#12282) 2022-02-27 22:47:09 -08:00