Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion lang/csharp/src/apache/ipc/HttpListenerServer.cs
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}
}

Expand Down
4 changes: 2 additions & 2 deletions lang/py/avro/tether/tether_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand All @@ -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()

Expand Down
4 changes: 2 additions & 2 deletions lang/py/avro/tether/tether_task_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand All @@ -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)

Expand Down
Loading