issues  

Messages by Date

• 2025/04/05 Re: [PR] [FLINK-32776][flink-metrics]Add HTTP basic authentication support to PrometheusPushGatewayReporter [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-18592][Connectors/FileSystem] StreamingFileSink fails due to truncating HDFS file failure [flink] via GitHub
• 2025/04/05 [jira] [Comment Edited] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
• 2025/04/05 [jira] [Comment Edited] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL Shengkai Fang (Jira)
• 2025/04/05 Re: [PR] [FLINK-31523][sql-client] Merge sql script reader in client and gateway [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-36443][table][test] Improve flaky table source sink tests [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-17231][kubernetes]When using LB Service, the optimization of returning RestEndpoint [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. [flink-connector-kafka] via GitHub
• 2025/04/05 Re: [PR] [FLINK-32565][table] Support Cast From NUMBER to BYTES [flink] via GitHub
• 2025/04/05 Re: [PR] [hotfix][core] Add private constructor of FatalExitExceptionHandler [flink] via GitHub
• 2025/04/05 Re: [PR] [Flink-15873] [cep] fix matches result not returned when existing earlier partial matches [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-31500][table-planner] Move SqlAlterTableSchema conversion logic to SqlAlterTableSchemaConverter [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-29737][Table] Support DataGen on waveform function. [flink] via GitHub
• 2025/04/05 Re: [PR] [hotfix] [docs] Update gradle build script in the overview.md [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-36245][FOLLOWUP] Remove the @Deprecated for ArrowSourceFunction and SinkFunction [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37502][docs] Translate documentation for Disaggregated State Management into Chinese [flink] via GitHub
• 2025/04/05 Re: [PR] [Flink 29627][streaming][test] Adding new test to SinkITCase.java that will test SinkV1 architecture with Cluster recovery scenario. [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-30399) Enable connectors to use config docs generator Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-30524] Support full screen viewing on the Logs/Stdout/Thread D… [flink] via GitHub
• 2025/04/05 Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.3 in /flink-connectors/flink-connector-hive [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-27080) Enable builds for pull requests Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-16491][formats] Add compression support for ParquetAvroWriters [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37423][table] Support PTFs in Table API [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed Weijie Guo (Jira)
• 2025/04/05 Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-30743][docs] added RBAC hints to Kubernetes HA documentation [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-36684][cdc-connector][mysql] Support read changelog as append only mode [flink-cdc] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-32253][runtime] Update pending resource requests on nodes unblocked. [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-31377][table] Fix array_contains ArrayData.ElementGetter shoul… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-14934) Remove error log statement in ES connector Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-20899][table-planner][hotfix] use cost factory in RelOptCluster to create HepPlanner. [flink] via GitHub
• 2025/04/05 Re: [PR] [hotfix] Rename the variable `result` to `config` [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37524] Make ForStState Restore from previous StateMetaInfo [flink] via GitHub
• 2025/04/05 Re: [PR] Add support to pass Datadog API Key as environment variable [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-13194][docs] Add explicit clarification about thread-safety of state [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-34620][formats][protobuf] add support of recursive schemas to PbToRowTypeUtil [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37484][cdc-connector] unevenly chunk split also enables unbounded-chunk-first.enabled. [flink-cdc] via GitHub
• 2025/04/05 Re: [PR] [FLINK-28732][state] Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release Xintong Song (Jira)
• 2025/04/05 [jira] [Resolved] (FLINK-37550) Add 2.0 to PreviousDocs list Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-34612) Migrate StreamPhysicalValuesRule Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-35360] support Flink cdc pipeline Yarn application mode [flink-cdc] via GitHub
• 2025/04/05 Re: [PR] [FLINK-23583][table-common] Introduce SubRowData [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
• 2025/04/05 [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-36443) Flaky Test: assertEquals in PushPartitionIntoTableSourceScanRuleTest.testWithUdf ASF GitHub Bot (Jira)
• 2025/04/05 Re: [PR] [FLINK-33402] 2 CONTINUED [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer Weijie Guo (Jira)
• 2025/04/05 Re: [PR] .[FLINK-26133][docus] Fixed Kafka Connector deserializer demo code error [flink] via GitHub
• 2025/04/05 [jira] [Created] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving Maximilian Michels (Jira)
• 2025/04/05 Re: [PR] [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-29801] OperatorCoordinator need open the way to operate metric… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs Weijie Guo (Jira)
• 2025/04/05 [jira] [Created] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yue Ma (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive Weijie Guo (Jira)
• 2025/04/05 [jira] [Commented] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR Robert Metzger (Jira)
• 2025/04/05 Re: [PR] [FLINK-37540][table-planner] Introduce SupportsTargetColumnWriting sink ability [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-32509][core] Avoid using skip in InputStreamFSInputWrapper [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Yanquan Lv (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.15 [flink] via GitHub
• 2025/04/05 Re: [PR] Update hive_read_write.md [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37527] Add `KuduSource` documentation [flink-connector-kudu] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-32264) Add FIELD support in SQL & Table API Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-32159] AbstractColumnReader throws NPE [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-16762][python] Relocate Beam dependency [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned Matthias Pohl (Jira)
• 2025/04/05 Re: [PR] [hotfix][cdc-connector][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck. [flink-cdc] via GitHub
• 2025/04/05 Re: [PR] [FLINK-33719][table] Cleanup the usage of deprecated StreamTableEnvir… [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-29587][planner] fix planer fail to simplify conjunctive exclusiveFilter [flink] via GitHub
• 2025/04/05 [jira] [Created] (FLINK-37591) Add Some PruneEmptyRules Jacky Lau (Jira)
• 2025/04/05 Re: [PR] [FLINK-32435][runtime][test] Merges different test implementations of LeaderContender into a single generic one [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source Weijie Guo (Jira)
• 2025/04/05 Re: [PR] Add GraalSystems [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-23763][Deployment/YARN]Use yarn config in sql but not yarn mag… [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-29952][table-api]Append the detail of the exception when drop tamporary table. [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-21108][rest-client] Add basic & digest auth support to rest client [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37243] Adds main thread callback to AsyncWaitOperator [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37265][docs] Document of python elasticsearch connector exeample has a little mistake [flink-connector-elasticsearch] via GitHub
• 2025/04/05 Re: [PR] [FLINK-32908][state-changelog] Fix wrong materialization id setting w… [flink] via GitHub
• 2025/04/05 Re: [PR] [docs] kafka.md Fromat adjustment [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] via GitHub
• 2025/04/05 Re: [PR] [FLINK-35360] support Flink cdc pipeline Yarn application mode [flink-cdc] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-36186) Speed up RocksDB close during manual compaction Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references Weijie Guo (Jira)
• 2025/04/05 [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-28919][table] Add built-in generate_series function. [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-22246]when use HiveCatalog create table , can't set Table owne… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0 Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-25560][Connectors/HBase] Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versions in changelog mode. [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
• 2025/04/05 [jira] [Created] (FLINK-37590) Update the code of Python modules to adapt to Flink 2.0's pyFlink Yanquan Lv (Jira)
• 2025/04/05 Re: [PR] [FLINK-37572] Shuffle Event by bucket and tableid to avoid data skew. [flink-cdc] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-36245][FOLLOWUP] Remove the @Deprecated for ArrowSourceFunction and SinkFunction [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-36659] Bump to 2.0-preview1. [flink-connector-jdbc] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [Hotfix][docs] Update usages of RESET to new syntax [flink] via GitHub
• 2025/04/05 Re: [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37582] Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-26927][testutils] Improve FlinkContainers to better support JM restarting [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-15538] Separate decimal implementations into separate sub-classes [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-29699]Debezium format parsing supports converting strings at the end with Z and numbers to timestamp [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37416][BugFix][Connectors/DynamoDB] Fix state inconsistency issue in DDB connector when sending split finished event from reader -> enumerator [flink-connector-aws] via GitHub
• 2025/04/05 [jira] [Created] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform Yanquan Lv (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-28732) Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-31320][table]Modify DATE_FORMAT system (built-in) function to accepts DATEs [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [WIP][FLINK-29055][k8s] add K8S options for excluding the buildin decorators [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-28097) Remove bundling of formats-common in json/csv format Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-36947) Rate limiting the GetRecord call frequency ASF GitHub Bot (Jira)
• 2025/04/05 Re: [PR] [hotfix] [docs] fix typos and language in topn example [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-24169) Flaky local YARN tests relying on log files Weijie Guo (Jira)
• 2025/04/05 Re: [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2025/04/05 Re: [PR] [hotfix][example] Additional explanation of some CLI input parameters of example [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-27661][flink-metrics-prometheus]PrometheusPushGatewayReporter support http basic auth [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode Weijie Guo (Jira)
• 2025/04/05 Re: [PR] FLINK-33634 [flink-kubernetes-operator] via GitHub
• 2025/04/05 Re: [PR] add end-to-end-performance test [flink] via GitHub
• 2025/04/05 [PR] [FLINK-37531] Respect the design of chain programming for RpcServiceBuilder [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-14081][table-planner-blink] Support precision of TimeType [flink] via GitHub
• 2025/04/05 Re: [PR] Update overview.md [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37475] Drop ChangelogNormalize for piping from upsert source to sink [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-36339) Remove java serialization from SQL serializers Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37598][table] Support list and map state in PTFs [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-24386] Guard JobMaster against exceptions from starting the Op… [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-26498][TABLE][WINDOW]emit result when cleanupTime timer call onEventTime if allowlatency e… [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37521][runtime] Implement async state version of KeyedCoProcessOperator [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-23953] In the AvroSerializerSnapshot set the serializer compatibility to 'AS IS' in case when underlying Avro schemas are compatible [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader [flink] via GitHub
• 2025/04/05 [PR] [FLINK-37616][python] Fix incorrect unpickling of Row fields [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-20219][coordination] Shutdown cluster externally should only clean up the HA data if all the jobs have finished [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-34606) Migrate BatchPhysicalExpandRule Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-27449][Table] fix: The comment is lost when creating a Table from Datastream and Schema [flink] via GitHub
• 2025/04/05 Re: [PR] [hotfix][doc] Fix some errors in sql gateway docs [flink] via GitHub
• 2025/04/05 [PR] [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context [flink] via GitHub
• 2025/04/05 Re: [PR] [hotfix] Simplify the variable checkpointStatsSnapshotCacheExpireAfterWrite [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-32649][runtime/Metrics] fix the dimension order for promethues reporter [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state. [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-37609) Bump parquet libs to 1.15.1 Ferenc Csaky (Jira)
• 2025/04/05 [PR] [FLINK-37502][docs] Translate documentation for Disaggregated State Management into Chinese [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-37609) Bump parquet libs to 1.15.1 Ferenc Csaky (Jira)
• 2025/04/05 Re: [PR] [FLINK-29770]hbase connector supports out of order data [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37611] Deflake ExactlyOnceKafkaWriterITCase [flink-connector-kafka] via GitHub
• 2025/04/05 Re: [PR] [FLINK-24960][flink-yarn-tests] fix race condition with new stdout line [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-34505) Migrate WindowGroupReorderRule Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [hotfix] Fix typo in CopyOnWriteStateMap [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context [flink] via GitHub
• 2025/04/05 [jira] [Commented] (FLINK-37609) Bump parquet libs to 1.15.1 Ferenc Csaky (Jira)
• 2025/04/05 Re: [PR] [FLINK-26428][docs-zh] Significant differences of Fault Tolerance between English and Chinese version [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception [flink-cdc] via GitHub
• 2025/04/05 Re: [PR] [FLINK-31390][table-planner] use scala view to avoid unnecessary trav… [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-32471][table]Add is_not_null to join push rule [flink] via GitHub
• 2025/04/05 Re: [PR] [FLINK-28829][k8s] Support prepreparing K8S resources before JM creation [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate Weijie Guo (Jira)
• 2025/04/05 Re: [PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink] via GitHub
• 2025/04/05 [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Weijie Guo (Jira)
• 2025/04/05 [jira] [Updated] (FLINK-37002) Migrate DecomposeGroupingSetsRule Weijie Guo (Jira)

• Earlier messages
• Later messages