Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • Connectors / Common
    • None

    Description

      • 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)

      Attachments

        Activity

          People

            afedulov Alexander Fedulov
            afedulov Alexander Fedulov
            Votes:
            1 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: