Marton Greber has uploaded this change for review. ( http://gerrit.cloudera.org:8080/24791
Change subject: [spark] KuduSink: honor auth and encryption opts ...................................................................... [spark] KuduSink: honor auth and encryption opts KuduSink captured requireAuthentication and encryptionPolicy in its constructor but never passed them to the KuduContext it created, so the context always fell back to the defaults (no authentication required, OPTIONAL encryption). As a result streaming writes silently ignored the kudu.requireAuthentication and kudu.encryptionPolicy options, unlike the batch read path in KuduRelation which forwards them correctly. Forward both options into the KuduContext, matching KuduRelation. Add StreamingTest coverage against an insecure cluster: requiring authentication or encryption must now fail the write instead of silently proceeding; both new tests fail without the fix. Co-Authored-By: Claude Opus 4.8 Change-Id: I661a45fe327d2d8adca5898f211b14233d5d813f --- M java/kudu-spark/src/main/scala/org/apache/kudu/spark/kudu/DefaultSource.scala M java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/StreamingTest.scala 2 files changed, 82 insertions(+), 1 deletion(-) git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/91/24791/1 -- To view, visit http://gerrit.cloudera.org:8080/24791 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: kudu Gerrit-Branch: master Gerrit-MessageType: newchange Gerrit-Change-Id: I661a45fe327d2d8adca5898f211b14233d5d813f Gerrit-Change-Number: 24791 Gerrit-PatchSet: 1 Gerrit-Owner: Marton Greber <[email protected]>
