xuhuang created FLINK-36423:
-------------------------------
Summary: Support RichMapPartitionFunction on
KyedPartitionWindowedStream
Key: FLINK-36423
URL: https://issues.apache.org/jira/browse/FLINK-36423
Project: Flink
Issue Type: Bug
Reporter: xuhuang
In cases like the one below, the {{open}} method of the
RichMapPartitionFunction not be called, which can lead to unexpected errors
such as Null Pointer Error.
source.keyBy(xxxx).fullWindowPartition().mapPartition(new
RichMapPartition(xxxx) {
public void open(context) {
// some init operations, like object creation
}
public void mapPartition(xxxx) {
// actual computation logical
}
}
)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
