diff --git a/aliyun/log/odps_sink.py b/aliyun/log/odps_sink.py index 957d4d9..3ac7d07 100644 --- a/aliyun/log/odps_sink.py +++ b/aliyun/log/odps_sink.py @@ -72,7 +72,7 @@ def setFields(self, fields): def getPartitionColumn(self): return self.__params["partitionColumn"] - def setPartitionColumn(self, partitionColumn: list): + def setPartitionColumn(self, partitionColumn): self.__params["partitionColumn"] = partitionColumn def getParams(self):