[ https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexander Fedulov updated FLINK-32694: -------------------------------------- Description: * SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProgram (org.apache.flink.deployment) * StatefulSequenceSource (org.apache.flink.streaming.api.functions.source) * ArrowSourceFunction (org.apache.flink.table.runtime.arrow.sources) * InputFormatSourceFunction (org.apache.flink.streaming.api.functions.source) * -EventsGeneratorSource (org.apache.flink.streaming.examples.statemachine.generator)- resolved in FLINK-32670 * FromSplittableIteratorFunction (org.apache.flink.streaming.api.functions.source) * DataGeneratorSource (org.apache.flink.streaming.api.functions.source.datagen) * – Tests: * MySource in StatefulStreamingJob (org.apache.flink.test) * RandomLongSource in StickyAllocationAndLocalRecoveryTestJob (org.apache.flink.streaming.tests) * SequenceGeneratorSource (org.apache.flink.streaming.tests) * TtlStateUpdateSource (org.apache.flink.streaming.tests) * StringSourceFunction in NettyShuffleMemoryControlTestProgram (org.apache.flink.streaming.tests) was: * SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProgram (org.apache.flink.deployment) * StatefulSequenceSource (org.apache.flink.streaming.api.functions.source) * ArrowSourceFunction (org.apache.flink.table.runtime.arrow.sources) * InputFormatSourceFunction (org.apache.flink.streaming.api.functions.source) * EventsGeneratorSource (org.apache.flink.streaming.examples.statemachine.generator) * FromSplittableIteratorFunction (org.apache.flink.streaming.api.functions.source) * DataGeneratorSource (org.apache.flink.streaming.api.functions.source.datagen) * -- Tests: * MySource in StatefulStreamingJob (org.apache.flink.test) * RandomLongSource in StickyAllocationAndLocalRecoveryTestJob (org.apache.flink.streaming.tests) * SequenceGeneratorSource (org.apache.flink.streaming.tests) * TtlStateUpdateSource (org.apache.flink.streaming.tests) * StringSourceFunction in NettyShuffleMemoryControlTestProgram (org.apache.flink.streaming.tests) > Migrate classes that implement ParallelSourceFunction to Source V2 API > ---------------------------------------------------------------------- > > Key: FLINK-32694 > URL: https://issues.apache.org/jira/browse/FLINK-32694 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Common > Reporter: Alexander Fedulov > Assignee: Alexander Fedulov > Priority: Major > > > * SimpleEndlessSourceWithBloatedState in HeavyDeploymentStressTestProgram > (org.apache.flink.deployment) > * StatefulSequenceSource (org.apache.flink.streaming.api.functions.source) > * ArrowSourceFunction (org.apache.flink.table.runtime.arrow.sources) > * InputFormatSourceFunction (org.apache.flink.streaming.api.functions.source) > * -EventsGeneratorSource > (org.apache.flink.streaming.examples.statemachine.generator)- resolved in > FLINK-32670 > * FromSplittableIteratorFunction > (org.apache.flink.streaming.api.functions.source) > * DataGeneratorSource > (org.apache.flink.streaming.api.functions.source.datagen) > * – Tests: > * MySource in StatefulStreamingJob (org.apache.flink.test) > * RandomLongSource in StickyAllocationAndLocalRecoveryTestJob > (org.apache.flink.streaming.tests) > * SequenceGeneratorSource (org.apache.flink.streaming.tests) > * TtlStateUpdateSource (org.apache.flink.streaming.tests) > * StringSourceFunction in NettyShuffleMemoryControlTestProgram > (org.apache.flink.streaming.tests) -- This message was sent by Atlassian Jira (v8.20.10#820010)