Hi all, I've got one question considering custom partitioning in DataStream API. Is it possible to define/change parallelism when doing 'partitionCustom' transformation?
As far as I discovered there is no way how to call 'setParallelism()' on the 'PartitionTransformation' because it's hidden from the user. In another thread (http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Range-partitioning-td10947.html) I found a short notice about custom partitioner - 'a partitioning will only be valid to the point that you change the parallelism.' So the possibility of changing parallelism in the subsequent transformation won't solve my problem. How to make sure that both partitioner and number of partitions are valid for subsequent transformations? Thank you -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DataStream-partitionCustom-define-parallelism-tp12597.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
