Google Git
Sign in
apache / flink / HEAD
  1. a8ec1b5 [FLINK-37091][table-common] Remove deprecated interface CatalogLock (#25947) by Ron · 6 minutes ago master
  2. 3a2e6a0 [FLINK-37083][e2e] Fix failed SqlYARNApplicationITCase on AZP (#25936) by Shengkai · 7 minutes ago
  3. c730292 [FLINK-36862][table] Implement additional `TO_TIMESTAMP_LTZ` functions by Yiyu Tian · 5 hours ago
  4. 631e2e2 [FLINK-37019][tests] Bump junit5 to 5.11.4 by Sergey Nuyanzin · 5 hours ago
  5. 78ea6ec [FLINK-37089][Runtime] Prioritize the record context and queue in order by Zakelly · 3 days ago
  6. 0bfbef6 [FLINK-37089][Runtime] Avoid deadlock draining for derived async processing by Zakelly · 3 days ago
  7. 7f1c201 [FLINK-36576][runtime] Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider by noorall · 9 weeks ago
  8. 4860f38 [FLINK-36576][runtime] Introduce BlockingInputInfo to provide more input information for parallelism decider by noorall · 10 weeks ago
  9. 082cfe8 [FLINK-36576][runtime] Introduce two correlations to allow operators to flexibly choose the data distribution algorithm by noorall · 10 weeks ago
  10. 81a1de1 [hotfix][runtime] ConsumedSubpartitionContext#getConsumedShuffleDescriptorRanges should return a non-overlapping result by noorall · 5 days ago
  11. 34924af [FLINK-36227] Restore compatibility with Logback 1.2 by Piotr Przybylski · 4 days ago
  12. 80a79bb [FLINK-36608][table-runtime] Add AdaptiveBroadcastJoinOptimizationStrategy to support adaptive broadcast join. by sunxia · 10 days ago
  13. 627395a [FLINK-36608][table-runtime] Add shouldReorderInputs method to AdaptiveJoin. by sunxia · 10 days ago
  14. 5d0cb98 [FLINK-36608][runtime] Expand the adaptive graph component to support adaptive broadcast join capability. by sunxia · 10 days ago
  15. 37c70c4 [FLINK-37024][task] Make cancel watchdog cover tasks stuck in DEPLOYING state (#25915) by Zhanghao Chen · 3 days ago
  16. 89c7c2b [FLINK-37085][table-planner] fix ut in AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery. by sunxia · 3 days ago
  17. b75d76e [FLINK-36946][Metrics] Optimize sink operator name truncate (#25832) by zhangmang · 3 days ago
  18. bceca90 [FLINK-36773][table] Introduce new Group Aggregate Operator with Async State API by Xuyang · 3 days ago
  19. 5e5d0d5 [FLINK-36707][table] Integrate PTF type inference into Calcite by Timo Walther · 3 days ago
  20. a79f2e2 [FLINK-37031][state/forst] Bump forstjni to 0.1.5 && make ForStFlinkFileSystem thread safe" (#25927) by Yanfei Lei · 3 days ago
  21. de40a75 [FLINK-36481][table] Remove deprecated method TableDescriptor#forManaged by xuyang · 5 days ago
  22. c13815f [FLINK-36171][table] Remove apis about ManagedTable by xuyang · 6 days ago
  23. 0975022 [FLINK-37082][table-planner] Disable adaptive join optimization when enable batch job progress recovery. by sunxia · 4 days ago
  24. 7597fe3 [FLINK-37030][Runtime/State] Support lazy initialization for state serializer in State V2 (#25918) by Zakelly · 4 days ago
  25. 42e2593 [FLINK-36871][runtime] add rescale metrics in scheduler (#25770) by Peter Huang · 4 days ago
  26. 7059ee5 [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) by Dawid Wysakowicz · 4 days ago
  27. 96a4e90 [FLINK-36483][table] Remove deprecated method TableResult#getTableSchema by xuyang · 5 days ago
  28. c2c0280 [FLINK-36480][table] Remove all deprecated methods in TableConfig by xuyang · 5 days ago
  29. 952d21f [FLINK-36478][table] Remove deprecated methods EnvironmentSettings#fromConfiguration and EnvironmentSettings#toConfiguration by xuyang · 5 days ago
  30. c0ad72f [FLINK-36477][table] Remove deprecated method BaseExpressions#cast by xuyang · 5 days ago
  31. 5e0e5a2 [FLINK-36994][table] Fix expand sql error when materialized table creation with UDTF queries by Feng Jin · 5 days ago
  32. 4420805 [FLINK-36994][table] Support executing ALTER MATERIALIZED TABLE AS operation by Feng Jin · 8 days ago
  33. 9260b33 [FLINK-36994][table] Support converting ALTER MATERIALIZED TABLE AS node to operation by Feng Jin · 8 days ago
  34. 342e3bf [FLINK-36994][table] Support parsing ALTER MATERIALIZED TABLE AS statement by Feng Jin · 8 days ago
  35. 329ad1e [FLINK-37029][docs] Fix the materialized table docs of full mode cron expression (#25917) by Ron · 5 days ago
  36. d5ee298 [FLINK-37014][docs] Fix typo in materialized table doc (#25904) by 皆非 · 5 days ago
  37. 1d934c1 [FLINK-36486] [table-api] Remove deprecated methods StreamTableEnvironment#registerDataStream by shalini · 5 days ago
  38. e85bb74 [FLINK-37016] ClusterEntrypoint can be closed before initialization by Chesnay Schepler · 7 days ago
  39. 4d57a12 [FLINK-36507][table-common] Remove the deprecated method LogicalTypeParser#parse (#25909) by Xuyang · 5 days ago
  40. 3ca52be [FLINK-36968][table-planner] Deduplicate data with the same pk in values lookup table used for testing (#25864) by Xuyang · 5 days ago
  41. 75c26e8 [FLINK-36960][test] Add WatermarkITCase for Generalized Watermark by Xu Huang · 6 weeks ago
  42. 52ef4ea [FLINK-36960][runtime] Combine Generalized Watermarks in StreamTaskNetworkInput for input channels by Xu Huang · 6 weeks ago
  43. 75fca0d [FLINK-36960][runtime] Process Generalized Watermarks in ProcessOperators by Xu Huang · 6 weeks ago
  44. 84e86b2 [FLINK-36960][runtime] Write and load the declared WatermarkDeclarations with StreamGraph and StreamConfig by Xu Huang · 6 weeks ago
  45. c5031d7 [FLINK-36960][API] Make Source is able to declare and output Generalized Watermarks by Xu Huang · 6 weeks ago
  46. 75d4230 [FLINK-36960][runtime] Introduce WatermarkEvent to propagate Generalized Watermarks within Stream by Xu Huang · 6 weeks ago
  47. 472eca8 [FLINK-36960][API] Introduce WatermarkManager in NonPartitionedContext by Xu Huang · 6 weeks ago
  48. 3462cf3 [FLINK-36960][runtime] Introduce InternalWatermarkDeclaration, WatermarkCombiner and Alignable interface by Xu Huang · 6 weeks ago
  49. 7915cb6 [FLINK-36960][API] Introduce WatermarkDeclaration and onWatermark callback in ProcessFunction by Xu Huang · 6 weeks ago
  50. 5c03fffe [FLINK-36960][API] Enable PartitionedContext to access NonPartitionedContext by Xu Huang · 6 weeks ago
  51. ad68d76 [FLINK-36960][API] Introduce WatermarkDeclaration for Generalized Watermark in DSv2 by Xu Huang · 6 weeks ago
  52. 473aff1 [FLINK-36960][API] Introduce Watermark and Combine Function for DSv2 Generalized Watermark by Xu Huang · 6 weeks ago
  53. 9720dcc [FLINK-37010][Runtime] Unify KeyedProcessFunction and the async one (#25901) by Zakelly · 5 days ago
  54. 63edfd6 [FLINK-36950][table] Migrate WindowPropertiesRules to java by Jacky Lau · 5 days ago
  55. 58047a8 [FLINK-36976] Bump snakeyaml to 2.3 by Sergey Nuyanzin · 9 days ago
  56. 98a36a7 [FLINK-36976] Upgrade jackson from 2.15.3 to 2.18.2 and kubernetes.client to 6.13.4 by Sergey Nuyanzin · 2 weeks ago
  57. 503ad9b [hotfix][docs] Add python docs for `create_table`/`create_temporary_table` by Sergey Nuyanzin · 6 days ago
  58. d432dff [FLINK-37007][table] Add missing createView methods to TableEnvironment by Sergey Nuyanzin · 2 weeks ago
  59. ae7184b [FLINK-36070][runtime/web] Show pending operators in overview page. by Yu Chen · 6 days ago
  60. 4c94d53 [FLINK-36070][runtime/web] Modifying web UI to adapt to Incremental JobGraph Generation by Yu Chen · 4 months ago
  61. 4a8b8c0 [FLINK-36760][sql-client] Supports to deploy script via sql client (#25754) by Shengkai · 6 days ago
  62. 7344916 [FLINK-36501][table-common] Remove all deprecated methods in `CatalogFactory` (#25579) by Feng Jin · 6 days ago
  63. f0c8f18 [FLINK-22091][yarn] Make Flink on YARN honor env.java.home (#25877) by Zhanghao Chen · 6 days ago
  64. 9878e56 [FLINK-36935][state/forst] Implement fast link for ForStFileSystem (#25818) by Yanfei Lei · 7 days ago
  65. c3d56df [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension by Matthias Pohl · 2 weeks ago
  66. 81f882b [FLINK-36989][runtime] Fix scheduler benchmark regression caused by ConsumedSubpartitionContext by noorall · 11 days ago
  67. 3084561 [FLINK-36759][sql-gateway] Add REST API to deploy script in application mode (#25730) by Shengkai · 8 days ago
  68. f08e5ec [FLINK-36007][table] Apply changes from FLINK-36277 to AdaptiveJoin by Sergey Nuyanzin · 9 days ago
  69. ec169a8 [hotfix][docs] In match_recognize docs, remove extracting time attributes from list of limitations by David Anderson · 11 days ago
  70. bbbd160 [FLINK-36277][table] Create a DynamicTableSource instead of registering a legacy TableSource in tests and remove TableEnvironmentInternal#registerTableSourceInternal by xuyang · 11 days ago
  71. c7b6212 [FLINK-36277][table] Remove all blocking subclasses of TableSource related to the removal of TableEnvironmentInternal#registerTableSourceInternal, except TestTableSource in tests. by xuyang · 11 days ago
  72. 1a3fda6 [FLINK-36277][table] Remove WithoutTimeAttributesTableSourceFactory, TestDataTypeTableSourceWithTimeFactory, TestDataTypeTableSourceFactory and TestTemporalTable(in LookupJoinTest) to prepare removing TableEnvironmentInternal#registerTableSourceInternal by xuyang · 10 weeks ago
  73. ea10556 [FLINK-36500][table-common] Remove all deprecated methods in CallExpression by Jeyassri Balachandran · 10 days ago
  74. 4263ad3 [FLINK-36484] [table-api] Remove deprecated methods StreamTableEnvironment#registerFunction (#25529) by Ammu · 10 days ago
  75. fafd86c [FLINK-36850][runtime] Disable adaptive batch execution when batch job progress recovery is enabled. by JunRuiLee · 2 weeks ago
  76. 80c748f [FLINK-36850][streaming-java] Support IntermediateDataSetID generated from source JobVertexID and consumer stream node id. by JunRuiLee · 2 weeks ago
  77. 49d0a75 [FLINK-36607][table-planner] Introduce AdaptiveJoinProcessor to inject adaptive join node. by sunxia · 10 weeks ago
  78. c1d2ddc [FLINK-36607][table-planner] Introduce ExecNode for adaptive join. by sunxia · 10 weeks ago
  79. 2b48260 [FLINK-36607][table-planner] Introduce configuration options for adaptive broadcast join. by sunxia · 10 weeks ago
  80. c3daf84 [FLINK-36269][python] Remove usage about TableEnvironmentInternal#fromTableSource in python module (#25322) by Xuyang · 11 days ago
  81. b700f1c [FLINK-36758][sql-gateway] Introduce driver to load the application in application mode (#25724) by Shengkai · 11 days ago
  82. 4952b58 [FLINK-36120][Runtime] Declare context variables without the ability of serialization by Zakelly · 3 weeks ago
  83. 47cdb03 [FLINK-36120][Runtime] Introduce internal async version of KeyedProcessFunction by Zakelly · 3 weeks ago
  84. 61cabed [FLINK-36120][Runtime] Declaring basic processing by chain by Zakelly · 3 weeks ago
  85. 5513369 [FLINK-36120][Runtime/State] Declaring local variables in async processing by Zakelly · 3 weeks ago
  86. b50a25f [FLINK-36120][Runtime] Declarative callbacks for async state processing by Zakelly · 3 weeks ago
  87. 73afb6e [FLINK-36491][table-common] Remove the deprecated method in DataStreamSinkProvider (#25564) by Gantigmaa Selenge · 11 days ago
  88. 0c38739 [FLINK-36490][table-common] Remove the deprecated method in DataStreamScanProvider (#25563) by Gantigmaa Selenge · 11 days ago
  89. 1fc886b [FLINK-36961][state/forst] Wait ForSt state excutor shutdown when disposing (#25854) by Yanfei Lei · 12 days ago
  90. 08990c7 [FLINK-36069][runtime/rest] Extending job detail rest API to expose json stream graph by Yu Chen · 4 months ago
  91. cb75a58 [FLINK-36951][table] Migrate ProjectSemiAntiJoinTransposeRule to java by Jacky Lau · 2 weeks ago
  92. e26d721 [FLINK-36954][table] Migrate CalcRankTransposeRule to java by Jacky Lau · 2 weeks ago
  93. 59ef8d6 [FLINK-36955][table] Migrate RewriteIntersectAllRule to java by Jacky Lau · 2 weeks ago
  94. 9b12ec0 [FLINK-33117][docs] Fix scala example for `NamedParameterClass` by Sergey Nuyanzin · 2 weeks ago
  95. 60b23d1 [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java by Sergey Nuyanzin · 2 weeks ago
  96. 358516c [hotfix][docs] Fix typo in Amazon S3 Access Credential by Hyungstler · 2 weeks ago
  97. 1e9e848 [FLINK-36966][tests] Bump mockito to 5.14.2 by Sergey Nuyanzin · 2 weeks ago
  98. 3f24704 [FLINK-36880][network] Hybrid shuffle supports job master failover if only external tier used. by Weijie Guo · 4 weeks ago
  99. 662e2be [FLINK-36880][network] Handle the finished vertex in InputConsumableDecider by Weijie Guo · 3 weeks ago
  100. dacb848 [FLINK-34505][table] Migrate WindowGroupReorderRule to java by Jacky Lau · 2 weeks ago