Commits

Branch selector

 master

User selector

JingsongLi

Datepicker

All time

Commit History

Commits on Jul 6, 2022

• [FLINK-28322][table-api] DataStreamScan(Sink)Provider's new method is not compatible

  Show description for 03a1a42
  JingsongLi

  committed
  03a1a42

Commits on Mar 24, 2022

• [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

  Show description for 7d7a111
  JingsongLi

  authored
  7d7a111

Commits on Mar 9, 2022

• [FLINK-26531][kafka] KafkaWriterITCase.testMetadataPublisher failed on azure

  Show description for 92a6850
  

  JingsongLi

  authored and

  gaoyunhaii

  committed
  92a6850

Commits on Feb 9, 2022

• [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

  Show description for bb1e504
  JingsongLi

  authored
  bb1e504

Commits on Dec 23, 2021

• [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

  Show description for 11f74d8
  JingsongLi

  authored
  11f74d8

Commits on Dec 17, 2021

• [FLINK-25174][table] Implement callback for managed table

  Show description for f01e911
  JingsongLi

  committed
  f01e911

• [FLINK-25174][table] Introduce ManagedTableFactory

  JingsongLi

  committed
  6d231b0

• [FLINK-25174][table-api] Introduce Catalog.supportsManagedTable

  JingsongLi

  committed
  8614ece

• [FLINK-25175][table-api] Introduce TableDescriptor.forConnector

  JingsongLi

  committed
  10805af

Commits on Dec 2, 2021

• [FLINK-25071][parquet] SerializableConfiguration should not load resources

  Show description for ea7a356
  JingsongLi

  authored
  ea7a356

Commits on Nov 29, 2021

• [FLINK-24763][parquet] Ignore unstable ParquetFileSystemITCase.testLimitableBulkFormat

  Show description for c1b1192
  JingsongLi

  authored
  c1b1192

Commits on Nov 24, 2021

• [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

  Show description for a547793
  JingsongLi

  authored
  a547793

Commits on Nov 16, 2021

• [FLINK-24839][fs-connector] Increase Timeout of FsStreamingSinkITCaseBase to 240

  Show description for 44378fa
  JingsongLi

  authored
  44378fa

Commits on Jul 1, 2021

• [FLINK-23142][table] UpdatableTopNFunction output wrong order in the same unique key

  Show description for a40abc7
  JingsongLi

  authored
  a40abc7

Commits on Jun 29, 2021

• [FLINK-23054][table] Add SinkUpsertMaterialize before upsert sink to resolve change log disorder

  Show description for 5fdc01e
  JingsongLi

  committed
  5fdc01e

• [FLINK-23054][table] Join unique/pk optimization should based on upsert key

  JingsongLi

  committed
  992340e

• [FLINK-23054][table] Rank update optimization should based on upsert key

  JingsongLi

  committed
  4642c1f

• [FLINK-23054][table] TemporalJoinRewrite should based on upsert key

  JingsongLi

  committed
  e1117f0

Commits on Jun 21, 2021

• [FLINK-22901][table] Introduce getUpsertKeys in FlinkRelMetadataQuery

  Show description for 5957812
  JingsongLi

  authored
  5957812

Commits on Jun 17, 2021

• [FLINK-22899][table] ValuesUpsertSinkFunction needs to use global upsert

  Show description for 3a40361
  JingsongLi

  authored
  3a40361

Commits on Jun 15, 2021

• [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

  Show description for eb8c466
  JingsongLi

  authored
  eb8c466

Commits on May 18, 2021

• [FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction

  Show description for 057f86b
  JingsongLi

  authored
  057f86b

Commits on Apr 26, 2021

• [FLINK-19449][table-planner] LEAD/LAG cannot work correctly in streaming mode

  Show description for 075b0b2
  JingsongLi

  committed
  075b0b2

• [FLINK-19449][table] Pass isBounded to AggFunctionFactory

  JingsongLi

  committed
  bf8f998

• [FLINK-19449][table] Introduce LinkedListSerializer

  JingsongLi

  committed
  9b9d4f0

• [FLINK-19449][doc] Fix wrong document for lead and lag

  JingsongLi

  committed
  362f4ae

Commits on Apr 22, 2021

• [FLINK-22168][table] Partition insert can not work with union all

  Show description for 04ce600
  JingsongLi

  authored
  04ce600

Commits on Apr 14, 2021

• [FLINK-22167][table-planner] Partial insert not works when complex fields reorder

  Show description for 73e777b
  JingsongLi

  authored
  73e777b

• [FLINK-21032][table] Not use ParallelFiniteTestSource in CompactionITCaseBase

  Show description for cf2a4e4
  JingsongLi

  authored
  cf2a4e4

• [FLINK-17371][table-runtime] Add cases for decimal casting

  Show description for dd71937
  JingsongLi

  authored
  dd71937

Commits on Apr 13, 2021

• [FLINK-17803][table] Should throw a readable exception when group by Map type

  Show description for 3f72fd2
  JingsongLi

  authored
  3f72fd2

• [FLINK-22202][parquet] Thread safety in ParquetColumnarRowInputFormat

  Show description for 413ff6a
  JingsongLi

  authored
  413ff6a

• [FLINK-22166][table] Empty values with sort willl fail

  Show description for 0e82a99
  JingsongLi

  authored
  0e82a99

Commits on Apr 12, 2021

• [FLINK-17371][table-runtime] Open testDefaultDecimalCasting case in DecimalTypeTest

  Show description for f6fc769
  JingsongLi

  authored
  f6fc769

• [FLINK-20230][table] FileSystemOutputFormat should delete file using FileSystemFactory

  Show description for 562f31a
  JingsongLi

  authored
  562f31a

Pagination

PreviousNext