[flink-statefun] 01/01: [hotfix] Fix typo in error message

[sj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sjwiesman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git

commit bebf3d79fb5f5d1cca0bc80e9f4e683417793e93
Author: Rafi Aroch <ra...@gmail.com>
AuthorDate: Thu Apr 30 13:45:21 2020 +0300

    [hotfix] Fix typo in error message
    
    This closes #104
---
 statefun-python-sdk/statefun/core.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/statefun-python-sdk/statefun/core.py b/statefun-python-sdk/statefun/core.py
index 50c1492..8f6e856 100644
--- a/statefun-python-sdk/statefun/core.py
+++ b/statefun-python-sdk/statefun/core.py
@@ -224,7 +224,7 @@ def kinesis_egress_record(stream: str, value, partition_key: str, explicit_hash_
     if not value:
         raise ValueError("Missing value")
     if not partition_key:
-        raise ValueError("Missung partition key")
+        raise ValueError("Missing partition key")
     record = KinesisEgressRecord()
     record.stream = stream
     record.value_bytes = value.SerializeToString()