This is an automated email from the ASF dual-hosted git repository.
gaborgsomogyi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d61575e80f9 [FLINK-37545][metrics] Fix StackOverflowError when using
MetricGroup in custom WatermarkStrategy
add 79254c1a340 [FLINK-37674][state] Add generic type information handling
for state SQL
No new revisions were added by this update.
Summary of changes:
docs/content/docs/libs/state_processor_api.md | 34 +++--
flink-libraries/flink-state-processing-api/pom.xml | 50 +++++++
.../state/table/SavepointConnectorOptions.java | 57 ++++++--
.../table/SavepointDataStreamScanProvider.java | 20 ++-
.../state/table/SavepointDynamicTableSource.java | 14 +-
.../table/SavepointDynamicTableSourceFactory.java | 153 ++++++++++++++++-----
.../table/SavepointTypeInformationFactory.java | 11 +-
.../state/table/StateValueColumnConfiguration.java | 23 ++--
...GenericAvroSavepointTypeInformationFactory.java | 15 +-
.../table/SavepointDynamicTableSourceTest.java | 54 +++++++-
...pecificAvroSavepointTypeInformationFactory.java | 16 +--
.../src/test/resources/avro/AvroRecord.avsc | 17 ++-
.../src/test/resources/table-state-avro/_metadata | Bin 0 -> 26076 bytes
13 files changed, 352 insertions(+), 112 deletions(-)
copy
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/PartitionedContext.java
=>
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointTypeInformationFactory.java
(72%)
copy
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/PojoGenericTypeSerializerTest.java
=>
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/table/GenericAvroSavepointTypeInformationFactory.java
(62%)
copy
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/PojoGenericTypeSerializerTest.java
=>
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/table/SpecificAvroSavepointTypeInformationFactory.java
(62%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotState.java
=>
flink-libraries/flink-state-processing-api/src/test/resources/avro/AvroRecord.avsc
(81%)
create mode 100644
flink-libraries/flink-state-processing-api/src/test/resources/table-state-avro/_metadata
