Alexander Fedulov created FLINK-32695: -----------------------------------------
Summary: Migrate SourceFunction in Tests to Source API Key: FLINK-32695 URL: https://issues.apache.org/jira/browse/FLINK-32695 Project: Flink Issue Type: Sub-task Components: Connectors / Common Reporter: Alexander Fedulov Assignee: Alexander Fedulov * ProcessingTimeServiceSource in StreamSourceOperatorLatencyMetricsTest (org.apache.flink.streaming.runtime.operators) * TestSourceFunction in CommonExecSinkITCase (org.apache.flink.table.planner.plan.nodes.exec.common) * CheckpointingNonParallelSourceWithListState in MigrationTestUtils (org.apache.flink.test.checkpointing.utils) * NonSerializableTupleSource in StreamingOperatorsITCase (org.apache.flink.test.streaming.api) * ImmediatelyFinishingSource in StreamTaskFinalCheckpointsTest (org.apache.flink.streaming.runtime.tasks) * SimpleStringGenerator in CheckpointedStreamingProgram (org.apache.flink.test.classloading.jar) * TupleSource in StreamingOperatorsITCase (org.apache.flink.test.streaming.api) * SystemExitSourceFunction in StreamTaskSystemExitTest (org.apache.flink.streaming.runtime.tasks) * EmptySource in SourceStreamTaskTest (org.apache.flink.streaming.runtime.tasks) * NumberSource in IgnoreInFlightDataITCase (org.apache.flink.test.checkpointing) * MyTimestampSource in TimestampITCase (org.apache.flink.test.streaming.runtime) * InfiniteTestSource in StreamTaskTimerITCase (org.apache.flink.test.streaming.runtime) * SavepointSource in SavepointReaderITTestBase (org.apache.flink.state.api) * Source in TimersSavepointITCase (org.apache.flink.test.checkpointing) * MyTimestampSourceInfinite in TimestampITCase (org.apache.flink.test.streaming.runtime) * TestSource in WithMasterCheckpointHookConfigTest (org.apache.flink.streaming.graph) * MockSourceFunction in StreamTaskTest (org.apache.flink.streaming.runtime.tasks) * MyCustomSourceFunction (org.apache.flink.python.util) * RowSourceFunction in StreamExecutionEnvironmentTest (org.apache.flink.streaming.api) * FromRowDataSourceFunction in TestValuesTableFactory (org.apache.flink.table.planner.factories) * CancelLockingSource in SourceStreamTaskTest (org.apache.flink.streaming.runtime.tasks) * LockStepSourceWithOneWmPerElement in SourceTaskTerminationTest (org.apache.flink.streaming.runtime.tasks) * NonStoppingSource in SourceStreamTaskTest (org.apache.flink.streaming.runtime.tasks) * FromElementSourceFunctionWithWatermark in TestValuesRuntimeFunctions (org.apache.flink.table.planner.factories) * TestSource in InterruptSensitiveRestoreTest (org.apache.flink.streaming.runtime.tasks) * SavepointSource in DataSetSavepointReaderITTestBase (org.apache.flink.state.api) * FailingCollectionSource (org.apache.flink.table.planner.runtime.utils) * SessionEventGeneratorDataSource in SessionWindowITCase (org.apache.flink.test.windowing.sessionwindows) * Source in BuiltInAggregateFunctionTestBase (org.apache.flink.table.planner.functions) * InterruptedSource in SourceStreamTaskTest (org.apache.flink.streaming.runtime.tasks) * MyNonWatermarkingSource in TimestampITCase (org.apache.flink.test.streaming.runtime) * NormalSource in NotifyCheckpointAbortedITCase (org.apache.flink.test.checkpointing) * MaxWatermarkSource (org.apache.flink.state.api.utils) * TestSource in RestoreUpgradedJobITCase (org.apache.flink.test.checkpointing) * InfiniteSource in StreamSourceOperatorWatermarksTest (org.apache.flink.streaming.runtime.operators) * InfiniteLongSourceFunction in JobCancelingITCase (org.apache.flink.test.cancelling) * TestSource in TypeFillTest (org.apache.flink.streaming.api) * ManuallyClosedSourceFunction in CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase (org.apache.flink.streaming.runtime.tasks) * GenericSourceFunction in YarnTestCacheJob (org.apache.flink.yarn.testjob) * MockSource in SourceStreamTaskTest (org.apache.flink.streaming.runtime.tasks) * DummySource in ReactiveModeITCase (org.apache.flink.test.scheduling) * Anonymous in testDisablingBufferTimeout() in BufferTimeoutITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testWatermarkForwarding() in SideOutputITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testCoGroup() in CoGroupJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testCoGroup() in CoGroupJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testJoin() in CoGroupJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testJoin() in CoGroupJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testSelfJoin() in CoGroupJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testTimestampExtractorWithAutoInterval() in TimestampITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testTimestampExtractorWithCustomWatermarkEmit() in TimestampITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testTimestampExtractorWithDecreasingCustomWatermarkEmit() in TimestampITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testTimestampExtractorWithLongMaxWatermarkFromSource() in TimestampITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testTimestampExtractorWithLongMaxWatermarkFromSource2() in TimestampITCase (org.apache.flink.test.streaming.runtime) * Anonymous in buildSourceStream() in IntervalJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testBoundedUnorderedStreamsStillJoinCorrectly() in IntervalJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in testBoundedUnorderedStreamsStillJoinCorrectly() in IntervalJoinITCase (org.apache.flink.test.streaming.runtime) * Anonymous in emitUntil() in CheckpointStoreITCase (org.apache.flink.test.checkpointing) * Anonymous in go() in Anonymous in setUp() in JobManagerMetricsITCase (org.apache.flink.runtime.metrics) * Anonymous in testSources() in StreamExecutionEnvironmentTest (org.apache.flink.streaming.api) * Anonymous in testParallelismBounds() in StreamExecutionEnvironmentTest (org.apache.flink.streaming.api) * Anonymous in getEnvironment() in ChangelogStateBackendLoadingTest (org.apache.flink.state.changelog) * Anonymous in getScanRuntimeProvider() in ScanSourceBase in TableFactoryHarness (org.apache.flink.table.planner.factories) * Anonymous in doTestPropagationFromCheckpointConfig() in CheckpointExceptionHandlerConfigurationTest (org.apache.flink.streaming.runtime.tasks) * CheckpointedSource in StatefulJobSavepointMigrationITCase (org.apache.flink.api.scala.migration) * FiniteTestSource (org.apache.flink.table.planner.runtime.stream) * CheckpointedSource (org.apache.flink.api.scala.migration) * EventTimeSourceFunction in TimeTestUtil$ (org.apache.flink.table.planner.runtime.utils) * in testReduceWindow() in WindowReduceITCase (org.apache.flink.streaming.api.scala) * in testReduceWithWindowFunction() in WindowReduceITCase (org.apache.flink.streaming.api.scala) * in testReduceWithProcessWindowFunction() in WindowReduceITCase (org.apache.flink.streaming.api.scala) * in testReduceAllWindow() in WindowReduceITCase (org.apache.flink.streaming.api.scala) * in testReduceAllWithWindowFunction() in WindowReduceITCase (org.apache.flink.streaming.api.scala) * in testReduceAllWithProcessWindowFunction() in WindowReduceITCase (org.apache.flink.streaming.api.scala) * in testRichWindowFunction() in WindowFunctionITCase (org.apache.flink.streaming.api.scala) * in testRichProcessWindowFunction() in WindowFunctionITCase (org.apache.flink.streaming.api.scala) * in testRichAllWindowFunction() in WindowFunctionITCase (org.apache.flink.streaming.api.scala) * in testRichProcessAllWindowFunction() in WindowFunctionITCase (org.apache.flink.streaming.api.scala) * in testCoGroup() in CoGroupJoinITCase (org.apache.flink.streaming.api.scala) * in testCoGroup() in CoGroupJoinITCase (org.apache.flink.streaming.api.scala) * in testJoin() in CoGroupJoinITCase (org.apache.flink.streaming.api.scala) * in testJoin() in CoGroupJoinITCase (org.apache.flink.streaming.api.scala) * in testSelfJoin() in CoGroupJoinITCase (org.apache.flink.streaming.api.scala) -- This message was sent by Atlassian Jira (v8.20.10#820010)