issues  

Messages by Thread

• [jira] [Created] (FLINK-40428) Remove Calcite's LogicalSnapshot Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40425) Add OVER window aggregation support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40424) Add windowing TVF support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40423) Add Top-N support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40422) Add slicing APIs to DataFrame API Liu Liu (Jira)
• [jira] [Updated] (FLINK-40421) Add sorting support in DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40420) Add set operations to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40421) Support sorting in DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40419) Add regular join support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40418) Support attribute-based column access on DataFrame Liu Liu (Jira)
• [jira] [Created] (FLINK-40417) Add remaining basic functionality to DataFrame API Liu Liu (Jira)
• [jira] [Updated] (FLINK-40415) PyFlink tests failed on Python 3.9 ASF GitHub Bot (Jira)
• [PR] [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools [flink] via GitHub
  • Re: [PR] [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools [flink] via GitHub
  • Re: [PR] [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools [flink] via GitHub
  • Re: [PR] [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools [flink] via GitHub
• [jira] [Resolved] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40415) PyFlink tests failed on Python 3.9 Dian Fu (Jira)
• [jira] [Closed] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input ASF GitHub Bot (Jira)
• [PR] [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40414] Autoscaler state ConfigMap is treated as trusted input [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site ASF GitHub Bot (Jira)
• [PR] [FLINK-40413] Autoscaling example classes leak into the operator javadoc site [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40413] Autoscaling example classes leak into the operator javadoc site [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site Dennis-Mircea Ciupitu (Jira)
• [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink] via GitHub
  • Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink] via GitHub
  • Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink] via GitHub
  • Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink] via GitHub
  • Re: [PR] [FLINK-40410][table-planner] Exclude VARIANT from constant folding [flink] via GitHub
• [jira] [Resolved] (FLINK-40360) Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits Yanquan Lv (Jira)
• Re: [I] [api][plan][runtime] Support triggering action by Event field values [flink-agents] via GitHub
• [jira] [Closed] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-31161) upgrade MojoHaus Versions Maven Plugin to 2.14.2 Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config Purushottam Sinha (Jira)
• [jira] [Closed] (FLINK-40300) PyFlink Table API lit fails for some literal types Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression Arvid Heise (Jira)
• [jira] [Created] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Mao Jiayi (Jira)
• [jira] [Updated] (FLINK-40400) Harden job artifact fetching in kubernetes operator ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
  • Re: [PR] [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer [flink] via GitHub
• [jira] [Created] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression Moritz Manner (Jira)
• [jira] [Updated] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression Moritz Manner (Jira)
  • [jira] [Updated] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling Kaustubh Butte (Jira)
• [jira] [Updated] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
  • [jira] [Updated] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
• [jira] [Assigned] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator ASF GitHub Bot (Jira)
• [PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40408] Fix NOTICE files to match dependencies [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
• [jira] [Created] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator Mate Czagany (Jira)
• [jira] [Created] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
• Re: [PR] [FLINK-40277][connector-http] Add HTTP sink response classification and retries [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-40277][connector-http] Add HTTP sink response classification and retries [flink-connector-http] via GitHub
• [PR] [oracle] Support specific-offset startup mode with SCN for Oracle pipeline source [flink-cdc] via GitHub
• [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
  • Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
  • Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
  • Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
  • Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
  • Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
• [jira] [Updated] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-40315][connect/mariadb] Add MariaDB CDC DataStream source [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame Dian Fu (Jira)
• [jira] [Commented] (FLINK-40400) Harden job artifact fetching in kubernetes operator Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Purushottam Sinha (Jira)
• Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
• Re: [PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink] via GitHub
• [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents] via GitHub
• [I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents] via GitHub
  • Re: [I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents] via GitHub
  • Re: [I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents] via GitHub
  • Re: [I] [Bug] Durable replay of newObject() memory updates corrupts short-term memory or crash-loops recovery [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Bowen Li (Jira)
  • [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Bowen Li (Jira)
• [jira] [Commented] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Bowen Li (Jira)
• [jira] [Resolved] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Bowen Li (Jira)
• [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Use descriptive thread names for the async executors [flink-agents] via GitHub
• [PR] [plan] Map long/float and other numeric tool parameters to proper JSON Schema types [flink-agents] via GitHub
  • Re: [PR] [plan] Map long/float and other numeric tool parameters to proper JSON Schema types [flink-agents] via GitHub
• [PR] [integration][ollama] Tolerate tool schemas without a 'required' key [flink-agents] via GitHub
  • Re: [PR] [integration][ollama] Tolerate tool schemas without a 'required' key [flink-agents] via GitHub
• [PR] [python] Fix jar URI construction in execution_environment.py [flink-agents] via GitHub
  • Re: [PR] [python] Fix jar URI construction in execution_environment.py [flink-agents] via GitHub
• [jira] [Closed] (FLINK-28260) flink-runtime-web fails to execute "npm ci" on Apple Silicon (arm64) without rosetta Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40401) Protect against large autoscaler config maps ASF GitHub Bot (Jira)
• [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40401] Protect against large autoscaler config maps [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling Kaustubh Butte (Jira)
• [jira] [Created] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling Kaustubh Butte (Jira)
• Re: [PR] [FLINK-40262][format/avro] Support matching Avro record fields by name [flink] via GitHub
• Re: [PR] [FLINK-40264][format/avro] Propagate legacyTimestampMapping into nested row converters [flink] via GitHub
• Re: [PR] [FLINK-40263][format/avro] Validate enum symbols when serializing CHAR/VARCHAR [flink] via GitHub
  • Re: [PR] [FLINK-40263][format/avro] Validate enum symbols when serializing CHAR/VARCHAR [flink] via GitHub
• [PR] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40400] Harden job artifact fetching in kubernetes operator [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40404) Split Python wheel releases for connector (e.g. kafka) Joey Pereira (Jira)
• [jira] [Updated] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs Tim Steinbach (Jira)
  • [jira] [Updated] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs Tim Steinbach (Jira)
• [PR] [FLINK-40403][runtime] Pre-compile subtask-index regexes in MetricStore [flink] via GitHub
  • Re: [PR] [FLINK-40403][runtime] Pre-compile subtask-index regexes in MetricStore [flink] via GitHub
• [jira] [Created] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs Tim Steinbach (Jira)
• [jira] [Updated] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch ASF GitHub Bot (Jira)
• [PR] [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak [flink] via GitHub
• [jira] [Updated] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling ASF GitHub Bot (Jira)
• [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40397][mysql] Add currentBinlogPositionLag metric for MySQL binlog reader [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader [flink-cdc] via GitHub
• [PR] [FLINK-40387][flink-s3-fs-native] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
  • Re: [PR] [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker [flink] via GitHub
• Re: [PR] [FLINK-39997] Upgrade pemja to 0.6.1 [flink] via GitHub
• [jira] [Assigned] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow Dian Fu (Jira)
• [PR] Bump io.opentelemetry:opentelemetry-api from 1.57.0 to 1.62.0 in /flink-python [flink] via GitHub
  • Re: [PR] Bump io.opentelemetry:opentelemetry-api from 1.57.0 to 1.62.0 in /flink-python [flink] via GitHub
  • Re: [PR] Bump io.opentelemetry:opentelemetry-api from 1.57.0 to 1.62.0 in /flink-python [flink] via GitHub
• [jira] [Closed] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow Dian Fu (Jira)
• [jira] [Updated] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow Dian Fu (Jira)
• [jira] [Created] (FLINK-40402) Add connect / read timeout to K8s operator artifact fetcher Robert Metzger (Jira)
• [jira] [Created] (FLINK-40401) Protect against large autoscaler config maps Robert Metzger (Jira)
• [jira] [Created] (FLINK-40400) Harden job artifact fetching in kubernetes operator Robert Metzger (Jira)
• [jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Andreas Bube (Jira)
• [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub

• Earlier messages
• Later messages