Cyberness opened a new pull request, #93:
URL: https://github.com/apache/flink-connector-aws/pull/93
## Purpose of the change
Create KryoSerializer for SequenceNumber class explicitly to allow disabling
of Generic Types via disableGenericTypes() call.
## Brief change log
Create KinesisStateUtil class with static method createShardsStateSerializer
that explicitly assigns KryoSerializer to SequenceNumber class and use this
method to initialize state
Create unit test that checks for compatibility of previous TypeInformation
based serializer and explicitly created KryoSerializer
Replace Mokito calls with utility MockStreamingRuntimeContext to improve
testability and unify initialization method of Streaming Runtime Context
## Verifying this change
This change added tests and can be verified as follows:
- *Added unit tests*
- *Manually verified by running the Kinesis connector on a local Flink
cluster.*
## Significant changes
- [ ] Dependencies have been added or upgraded
- [ ] Public API has been changed (Public API is any class annotated with
`@Public(Evolving)`)
- [ ] Serializers have been changed
- [ ] New feature has been introduced
- If yes, how is this documented? (not applicable / docs / JavaDocs / not
documented)
--
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]
