Zhanghao Chen
Zhanghao Chen
## What is the purpose of the change Help user locate the container where a task is running on from Web UI by including port in the host info on...
## What is the purpose of the change Currently, the numRecordsIn & numBytesIn metrics for sources and the numRecordsOut & numBytesOut metrics for sinks are always 0 on the Flink...
## What is the purpose of the change Introduce built-in serialization support for map and lists, which falls back to Kyro previously. ## Brief change log Introduce built-in serialization support...
## What is the purpose of the change Make ListSerializer allow null values. Background: see [FLINK-35555](https://issues.apache.org/jira/browse/FLINK-35555). ## Brief change log - Add a binary mask for marking null values in...
Would it be possible to add Google Scholar as a social link?
Flink 2.0 has done a major Kryo 2.x -> 5.x upgrade and the new Flink is not compatible with older Kryo state. Reference data from version 1.x can be safely...
## What is the purpose of the change Perf: eliminate redundant field initialization of PojoSerializer. ## Brief change log Currently, PojoSerializer will first create a new POJO instance and initialize...
## What is the purpose of the change Currently, Flink Protobuf format does not discard unknown fields (and it does not even provide an option for that!). When the user...