From 8b248dc3ebd5070949f22434d06433a45173205c Mon Sep 17 00:00:00 2001 From: Sai Asish Y Date: Fri, 17 Apr 2026 01:16:28 -0700 Subject: [PATCH] AVRO: fix 'occured' -> 'occurred' typos across C# and Python IPC - lang/csharp/.../HttpListenerServer.cs: Debug.Print message in the HTTP listener when the per-request handler throws. - lang/py/.../tether/tether_task_runner.py: two log.error messages emitted from TetherTaskRunner.process_message when the partition message fails to parse or any other exception propagates. - lang/py/.../tether/tether_task.py: two log messages emitted from TetherTask.fail when the task reports failure / fails to send the fail message back to the output server. No functional changes. Signed-off-by: Sai Asish Y --- lang/csharp/src/apache/ipc/HttpListenerServer.cs | 2 +- lang/py/avro/tether/tether_task.py | 4 ++-- lang/py/avro/tether/tether_task_runner.py | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/lang/csharp/src/apache/ipc/HttpListenerServer.cs b/lang/csharp/src/apache/ipc/HttpListenerServer.cs index 9bd03d2975a..21d1759717c 100644 --- a/lang/csharp/src/apache/ipc/HttpListenerServer.cs +++ b/lang/csharp/src/apache/ipc/HttpListenerServer.cs @@ -77,7 +77,7 @@ protected void HttpListenerCallback(IAsyncResult result) // ExceptionHandler(ex, result); //else // Debug.Print("Exception occured while processing a request, no exception handler was provided - ignoring", ex); - Debug.Print("Exception occured while processing a web request, skipping this request: ", ex); + Debug.Print("Exception occurred while processing a web request, skipping this request: ", ex); } } diff --git a/lang/py/avro/tether/tether_task.py b/lang/py/avro/tether/tether_task.py index 884790e4e69..8d16b92b21f 100644 --- a/lang/py/avro/tether/tether_task.py +++ b/lang/py/avro/tether/tether_task.py @@ -422,7 +422,7 @@ def fail(self, message): """ Call to fail the task. """ - self.log.error("TetherTask.fail: failure occured message follows:\n%s", message) + self.log.error("TetherTask.fail: failure occurred message follows:\n%s", message) try: message = message.decode() except AttributeError: @@ -431,7 +431,7 @@ def fail(self, message): try: self.outputClient.request("fail", {"message": message}) except Exception: - self.log.exception("TetherTask.fail: an exception occured while trying to send the fail message to the output server.") + self.log.exception("TetherTask.fail: an exception occurred while trying to send the fail message to the output server.") self.close() diff --git a/lang/py/avro/tether/tether_task_runner.py b/lang/py/avro/tether/tether_task_runner.py index bd98cb46339..481b3c620a3 100644 --- a/lang/py/avro/tether/tether_task_runner.py +++ b/lang/py/avro/tether/tether_task_runner.py @@ -67,7 +67,7 @@ def invoke(self, message, request): try: self.task.partitions = request["partitions"] except Exception: - self.log.error("Exception occured while processing the partitions message: Message:\n%s", traceback.format_exc()) + self.log.error("Exception occurred while processing the partitions message: Message:\n%s", traceback.format_exc()) raise elif message.name == "input": self.log.info("TetherTaskRunner: Received input") @@ -84,7 +84,7 @@ def invoke(self, message, request): self.log.warning("TetherTaskRunner: Received unknown message %s", message.name) except Exception: - self.log.error("Error occured while processing message: %s", message.name) + self.log.error("Error occurred while processing message: %s", message.name) e = traceback.format_exc() self.task.fail(e)