[FLINK-4374] GroupReduce Broken for null Date - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Major
Resolution: Abandoned
Affects Version/s: None
Fix Version/s: None
Component/s: API / DataSet
Labels:
- stale-assigned

Description

The GroupReduceITCase has an error that allows a problem with null Dates to go uncovered:
If I set the parallelism to 1 in testDateNullException() and all keys actually end up on the same operator, then there is a problem in the de/serialization.

It seems that null values are somehow skipped by the serialization process (e.g. maybe no null indicator is written), which leads to wrong deserializations.