Yakov Goldberg created FLINK-4794: ------------------------------------- Summary: partition_by_hash() crashes if no parameter is provided Key: FLINK-4794 URL: https://issues.apache.org/jira/browse/FLINK-4794 Project: Flink Issue Type: Bug Components: Python API Reporter: Yakov Goldberg
partition_by_hash() crashes if no parameter is provided. Looks like a line of code was missed, check distinct() def distinct(self, *fields): f = None if len(fields) == 0: f = lambda x: (x,) fields = (0,) -- This message was sent by Atlassian JIRA (v6.3.4#6332)