This is an automated email from the ASF dual-hosted git repository. iemejia pushed a commit to branch branch-1.12 in repository https://gitbox.apache.org/repos/asf/avro.git
commit f1f7908d2a3e0cb6c51634a50b43c59694867fe2 Author: Sai Asish Y <[email protected]> AuthorDate: Fri Apr 17 02:07:24 2026 -0700 fix 'occured' -> 'occurred' typos in error messages across C# and Python IPC (#3733) - 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 <[email protected]> --- 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 9bd03d2975..21d1759717 100644 --- a/lang/csharp/src/apache/ipc/HttpListenerServer.cs +++ b/lang/csharp/src/apache/ipc/HttpListenerServer.cs @@ -77,7 +77,7 @@ namespace Avro.ipc // 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 6caac6abe9..37ce55fe31 100644 --- a/lang/py/avro/tether/tether_task.py +++ b/lang/py/avro/tether/tether_task.py @@ -422,7 +422,7 @@ class TetherTask(abc.ABC): """ 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 @@ class TetherTask(abc.ABC): 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 410f6c00e4..f3328210c8 100644 --- a/lang/py/avro/tether/tether_task_runner.py +++ b/lang/py/avro/tether/tether_task_runner.py @@ -67,7 +67,7 @@ class TaskRunnerResponder(avro.ipc.Responder): 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 @@ class TaskRunnerResponder(avro.ipc.Responder): self.log.warning("TetherTaskRunner: Received unknown message %s", message.name) except Exception as e: - 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)
