Au-Miner opened a new pull request, #28795:
URL: https://github.com/apache/flink/pull/28795
## What is the purpose of the change
This PR fixes incorrect `JSON_OBJECTAGG` results when the key and value
reference the same input field. Previously, object keys could contain
additional escaped quotation marks.
## Brief change log
- Update `WrapJsonAggFunctionArgumentsRule#wrapJsonAggregate` to replace
only the value argument with its wrapped projection while preserving the
original `JSON_OBJECTAGG` key argument.
- Update the optimized plan snapshots for regular, group-window, and window
TVF aggregations.
## Verifying this change
`JsonAggregationFunctionsITCase` adds regression coverage for regular and
tumbling-window aggregations where the key and value use the same field.
The expected result is:
`{"A":"A","B":"B"}`
The `WrapJsonAggFunctionArgumentsRuleTest` plan snapshots verify that only
the value argument references the `JSON_STRING` projection.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): no
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? not applicable
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
