Commits

Branch selector

 master

User selector

reswqa

Datepicker

All time

Commit History

Commits on May 22, 2024

• [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context

  reswqa

  committed
  e502d23

  Copy full SHA for e502d23

• [FLINK-34549][API] Expose MetricGroup via RuntimeContext

  reswqa

  committed
  ff93e2a

  Copy full SHA for ff93e2a

• [FLINK-34549][API] Implement ProcessingTimeManager and expose it via PartitionedContext

  reswqa

  committed
  545a005

  Copy full SHA for 545a005

• [FLINK-34549][API] Implement StateManager and expose it via PartitionedContext

  reswqa

  committed
  c431efe

  Copy full SHA for c431efe

• [FLINK-34549][API] Implement TaskInfo and expose it via RuntimeContext

  reswqa

  committed
  0bc2041

  Copy full SHA for 0bc2041

• [FLINK-34549][API] Implement JobInfo and expose it via RuntimeContext

  reswqa

  committed
  ef7f1d0

  Copy full SHA for ef7f1d0

• [FLINK-34549][API] Split partition-wise context from RuntimeContext

  reswqa

  committed
  2b0e303

  Copy full SHA for 2b0e303

• [FLINK-34549][API] Introduce related components for runtime context

  reswqa

  committed
  c17440c

  Copy full SHA for c17440c

• [FLINK-34549][API] Introduces and implements ProcessConfigurable

  reswqa

  committed
  6691dc6

  Copy full SHA for 6691dc6

• [FLINK-34549][API] Introduce SlotSharingGroup for v2 and move MemorySize to flink-core-api

  reswqa

  committed
  1d73510

  Copy full SHA for 1d73510

• [hotfix] Temporarily revert the change that makes the v2 operator inherit from the async operator

  Show description for 4d7aeba
  reswqa

  committed
  4d7aeba

  Copy full SHA for 4d7aeba

Commits on Apr 26, 2024

• [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest

  reswqa

  committed
  4e6dbe2

  Copy full SHA for 4e6dbe2

Commits on Apr 25, 2024

• [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint.

  reswqa

  committed
  259aef0

  Copy full SHA for 259aef0

• [FLINK-31223][test] Abstract SqlClientTestBase.

  reswqa

  committed
  6392f81

  Copy full SHA for 6392f81

• [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.

  reswqa

  committed
  63f02a0

  Copy full SHA for 63f02a0

Commits on Apr 8, 2024

• [hotfix] Correct the option key for sortPartition

  reswqa

  committed
  32ab253

  Copy full SHA for 32ab253

• [hotfix] Document the field start from 1 for sortPartition

  reswqa

  committed
  2bfb7c0

  Copy full SHA for 2bfb7c0

Commits on Apr 5, 2024

• [FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17

  reswqa

  committed
  54550e3

  Copy full SHA for 54550e3

Commits on Apr 1, 2024

• [hotfix] Fix compile error in DataStreamV2SinkTransformation

  reswqa

  committed
  d271495

  Copy full SHA for d271495

• [FLINK-34548][API] Supports sink-v2 Sink

  reswqa

  committed
  2876249

  Copy full SHA for 2876249

• [FLINK-34548][API] Supports FLIP-27 Source

  reswqa

  committed
  056660e

  Copy full SHA for 056660e

• [FLINK-34548][API] Implement datastream

  reswqa

  committed
  ceafa5a

  Copy full SHA for ceafa5a

• [FLINK-34548][API] Implement process function's underlying operators

  reswqa

  committed
  4f71c5b

  Copy full SHA for 4f71c5b

• [FLINK-34548][API] Introduce ExecutionEnvironment

  reswqa

  committed
  e1147ca

  Copy full SHA for e1147ca

• [FLINK-34548][API] Introduce stream interface and move KeySelector to flink-core-api

  reswqa

  committed
  9fa74a8

  Copy full SHA for 9fa74a8

• [FLINK-34548][API] Introduce variants of ProcessFunction

  reswqa

  committed
  cedbcce

  Copy full SHA for cedbcce

• [FLINK-34548][API] Introduce ProcessFunction and RuntimeContext related interfaces

  reswqa

  committed
  13cfaa7

  Copy full SHA for 13cfaa7

• [FLINK-34548][API] Move Function interface to flink-core-api

  reswqa

  committed
  13790e0

  Copy full SHA for 13790e0

• [FLINK-34548][API] Create flink-core-api module and let flink-core depend on it

  reswqa

  committed
  59525e4

  Copy full SHA for 59525e4

• [FLINK-34548][API] Initialize the datastream v2 related modules

  reswqa

  committed
  5b2e923

  Copy full SHA for 5b2e923

Commits on Mar 11, 2024

• [FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError

  reswqa

  committed
  fcf61b9

  Copy full SHA for fcf61b9

Commits on Jan 26, 2024

• [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig

  reswqa

  committed
  84444d5

  Copy full SHA for 84444d5

Commits on Jan 19, 2024

• [hotfix] peekNextBufferSubpartitionId shouldn't throw UnsupportedDataTypeException

  

  reswqa

  authored and

  dawidwys

  committed
  8dd28a2

  Copy full SHA for 8dd28a2

Commits on Sep 14, 2023

• [FLINK-33076][network] Reduce serialization overhead of broadcast emit from ChannelSelectorRecordWriter.

  reswqa

  committed
  e77dc91

  Copy full SHA for e77dc91

• [hotfix] Parameterlize RecordWriterTest and migrate it to junit5

  reswqa

  committed
  e198c09

  Copy full SHA for e198c09

Pagination

Previous

Next