34 Pull requests merged by 22 people

• [FLINK-35199][table] Support the execution of create materialized table in full refresh mode

  #24866 merged Jun 1, 2024

• [FLINK-35483][runtime] Fix unstable BatchJobRecoveryTest.

  #24871 merged May 31, 2024

• [FLINK-32142][build][flink-runtime-web] Upgrade frontend-maven-plugin...

  #22614 merged May 31, 2024

• [1.18][FLINK-35351][checkpoint] Fix fail during restore from unaligned checkpoint with custom partitioner

  #24865 merged May 31, 2024

• [1.19][FLINK-35351][checkpoint] Fix fail during restore from unaligned checkpoint with custom partitioner

  #24864 merged May 31, 2024

• [doc]Flink sql gettingstarted Expression 'dept_id' is not being grouped and sql-queries-overview TableDescriptor Missing required options are: path

  #24841 merged May 31, 2024

• [hotfix][docs-zh] maven should require v3.8.6, not higher

  #24863 merged May 31, 2024

• [FLINK-35399][doc] Update the batch job recovery documentation.

  #24872 merged May 30, 2024

• [BP-1.19][FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib"

  #24792 merged May 30, 2024

• [FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib"

  #24791 merged May 30, 2024

• [FLINK-26808][1.19] Limit FileUploadHandler to multipart routes

  #24859 merged May 30, 2024

• [FLINK-35484][doc-ci] Flink document file had removed but website can access

  #24870 merged May 30, 2024

• [BP-1.17][FLINK-34379][table] Fix adding catalogtable logic

  #24862 merged May 30, 2024

• [BP-1.18][FLINK-34379][table] Fix adding catalogtable logic

  #24861 merged May 30, 2024

• [BP-1.19][FLINK-34379][table] Fix adding catalogtable logic

  #24860 merged May 30, 2024

• [FLINK-32088][checkpoint] Space control in file merging

  #24807 merged May 30, 2024

• [FLINK-35399][doc] Add documents for batch job recovery from jobMaster failover.

  #24855 merged May 30, 2024

• [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions

  #24374 merged May 29, 2024

• [FLINK-35348][table] Introduce refresh materialized table rest api

  #24844 merged May 29, 2024

• [FLINK-35351][checkpoint] Fix fail during restore from unaligned checkpoint with custom partitioner

  #24857 merged May 29, 2024

• [FLINK-35454] Allow connector classes to depend on internal Flink util classes

  #24843 merged May 28, 2024

• [FLINK-26808] Limit FileUploadHandler to multipart routes

  #24856 merged May 28, 2024

• [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode

  #24849 merged May 28, 2024

• [hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359

  #24850 merged May 28, 2024

• [FLINK-35457][checkpoint] Hotfix! close physical file under the protection of lock

  #24846 merged May 28, 2024

• [FLINK-35465][runtime] Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

  #24771 merged May 28, 2024

• [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type

  #24795 merged May 27, 2024

• [FLINK-34379][table] Fix adding catalogtable logic

  #24788 merged May 27, 2024

• [FLINK-35403] Allow Skipping Invocation of Function Calls While Constant-folding

  #24814 merged May 27, 2024

• [FLINK-34993] parser changes to support model CRUD sql

  #24769 merged May 27, 2024

• [FLINK-35342][table] Fix MaterializedTableStatementITCase test can check for wrong status

  #24799 merged May 27, 2024

• [FLINK-35426][table-planner] Change the distribution of DynamicFilteringDataCollector to Broadcast

  #24830 merged May 27, 2024

• [FLINK-34123][core][type] Introduce built-in serialization support for map and lists

  #24634 merged May 27, 2024

• [hotfix][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context

  #24838 merged May 27, 2024

11 Pull requests opened by 10 people

• [FLINK-35453][core] StreamReader Charset fix with UTF8 in core files

  #24842 opened May 26, 2024

• [FLINK-35068][core][type] Introduce built-in serialization support for java.util.Set

  #24845 opened May 27, 2024

• [FLINK-35427][json] Support fail-on-unknown-field config in json format

  #24848 opened May 27, 2024

• [FLINK-33607][build]: Add checksum verification for Maven wrapper

  #24852 opened May 28, 2024

• [hotfix][docs] Fix typo in alter.md

  #24858 opened May 28, 2024

• [hotfix] A couple of hotfixes

  #24868 opened May 29, 2024

• [FLINK-34559] Limit Global & Local Aggregation buffers

  #24869 opened May 29, 2024

• [FLINK-32081][checkpoint] Compatibility between file-merging on and off across job runs

  #24873 opened May 31, 2024

• [FLINK-35475][runtime] Introduce isInternalSorterSupport to OperatorA…

  #24874 opened May 31, 2024

• [FLINK-35282] Upgrade pyarrow and beam

  #24875 opened May 31, 2024

• [FLINK-35282] Upgrade pyarrow and beam

  #24876 opened May 31, 2024

22 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• FLINK-35311 Draft pr for initial review of apicurio

  #24715 commented on May 29, 2024 • 14 new comments

• [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework

  #24471 commented on May 31, 2024 • 11 new comments

• [FLINK-35435] Add timeout Configuration to Async Sink

  #24839 commented on May 31, 2024 • 10 new comments

• [FLINK-35049][state] Implement Map Async State API for ForStStateBackend

  #24812 commented on May 27, 2024 • 6 new comments

• [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function.

  #24773 commented on Jun 1, 2024 • 6 new comments

• [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow

  #24426 commented on May 29, 2024 • 5 new comments

• [FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format

  #24730 commented on May 30, 2024 • 5 new comments

• [FLINK-35412][State/Runtime] Batch execution of async state request callback

  #24832 commented on May 31, 2024 • 4 new comments

• [FLINK-35406] Use inner serializer when casting RAW type to BINARY or…

  #24818 commented on May 31, 2024 • 4 new comments

• [FLINK-33212][runtime] add job status changed listener for lineage

  #24754 commented on May 29, 2024 • 4 new comments

• [FLINK-34239][core] Add copy() method for SerializerConfig

  #24544 commented on May 30, 2024 • 3 new comments

• [FLINK-31606][docs-zh] Translate 'sqlClient.md' pages into chinese

  #22264 commented on May 27, 2024 • 2 new comments

• [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese

  #24822 commented on May 31, 2024 • 2 new comments

• [FLINK-35440][Table SQL / JDBC] feat(flink-connection): support isValid for tableau

  #24836 commented on May 31, 2024 • 1 new comment

• [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core

  #24685 commented on Jun 1, 2024 • 1 new comment

• [FLINK-35075][table] Migrate TwoStageOptimizedAggregateRule to java

  #24650 commented on May 27, 2024 • 1 new comment

• [FLINK-31664] Implement ARRAY_INTERSECT function

  #24526 commented on May 27, 2024 • 1 new comment

• [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

  #9097 commented on May 25, 2024 • 1 new comment

• [FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall…

  #24736 commented on May 29, 2024 • 0 new comments

• [FLINK-34977][API] Introduce State Access on DataStream API V2

  #24725 commented on May 31, 2024 • 0 new comments

• [FLINK-33211][table] support flink table lineage

  #24618 commented on Jun 1, 2024 • 0 new comments

• [FLINK-17224][table] Support precision for TIME

  #22775 commented on May 29, 2024 • 0 new comments