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)