[jira] [Created] (FLINK-19133) User provided partitioners are not initialized correctly

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-19133) User provided partitioners are not initialized correctly

Shang Yuanchun (Jira)
Dawid Wysakowicz created FLINK-19133:
----------------------------------------

             Summary: User provided partitioners are not initialized correctly
                 Key: FLINK-19133
                 URL: https://issues.apache.org/jira/browse/FLINK-19133
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.11.1
            Reporter: Dawid Wysakowicz
            Assignee: Dawid Wysakowicz
             Fix For: 1.12.0, 1.11.2


Reported in the ML: https://lists.apache.org/thread.html/r94275a7314d44154eb1ac16237906e0f097e8a9d8a5a937e8dcb5e85%40%3Cdev.flink.apache.org%3E

If a user provides a partitioner in combination with SerializationSchema it is not initialized correctly and has no access to the parallel instance index or number of parallel instances.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)