Messages by Thread
-
-
[jira] [Created] (FLINK-39584) Expand filter-merging for source-reuse
Daniel Rossos (Jira)
-
Re: [PR] [FLINK-39283][Formats/avro] Upgrade `org.apache.avro:avro` to 1.12.1 [flink]
via GitHub
-
[jira] [Updated] (FLINK-39583) Normalize Calcite correl variables to make subplan reuse by digest more effective
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-39583) Normalize Calcite correl variables to make subplan reuse by digest more effective
Ferenc Csaky (Jira)
-
[jira] [Commented] (FLINK-38902) Add user instructions and usage documentation for FLIP-487
Yuepeng Pan (Jira)
-
[jira] [Comment Edited] (FLINK-38902) Add user instructions and usage documentation for FLIP-487
Yuepeng Pan (Jira)
-
[PR] [BP-2.3][FLINK-38902][docs] Add user instructions and usage documentation for FLIP-487 [flink]
via GitHub
-
[jira] [Commented] (FLINK-38545) Update Pulsar connector to Flink 1.20
Fabrizzio Chavez (Jira)
-
[jira] [Updated] (FLINK-39113) Add Encryption context support
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-37240) Changing column nullability throws StateMigrationException in a SQL pipeline with a JOIN
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37240][table] RowDataSerializer relaxes NOT NULL to NULL as a state compatibility change. [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-39526) Support CROSS JOIN with inline VALUE clause with static state size
Fabian Hueske (Jira)
-
[jira] [Commented] (FLINK-39525) Release Testing: Verify FLIP-560: Application Capability Enhancement
Mukul Gupta (Jira)
-
[jira] [Closed] (FLINK-39459) Release Testing Instructions: FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs
Sergey Nuyanzin (Jira)
-
[jira] [Closed] (FLINK-39460) Release Testing Instructions: FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution
Sergey Nuyanzin (Jira)
-
[jira] [Comment Edited] (FLINK-39461) Release Testing Instructions: FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-39465) Release Testing Instructions: FLIP-555: Flink Native S3 FileSystem
Yuepeng Pan (Jira)
-
[jira] [Closed] (FLINK-39471) Release Testing Instructions: FLIP-553: Robust OTel gRPC metric exporter
Yuepeng Pan (Jira)
-
Re: [PR] [FLINK-39438][MaxCompute] Add support for sink operation types in MaxCompute options [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-39435) [flink-connector-kafka] Switching Kafka topics via Savepoint restore causes dual-topic consumption AND new topic consumed from earliest instead of configured offset
Hongshun Wang (Jira)
-
[jira] [Updated] (FLINK-39435) [flink-connector-kafka] Switching Kafka topics via Savepoint restore causes dual-topic consumption AND new topic consumed from earliest instead of configured offset
Hongshun Wang (Jira)
-
Re: [PR] [FLINK-39417] Fix GenericRecordData could not be [de]serialized in pipeline [flink-cdc]
via GitHub
-
[PR] [WIP] [flink]
via GitHub
-
[jira] [Updated] (FLINK-39582) [cdc-connector][postgres] Support emitting pg_logical_emit_message records to deserialization
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-39582) [cdc-connector][postgres] Support emitting pg_logical_emit_message records to deserialization
Jira
-
[jira] [Comment Edited] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition
Hao Li (Jira)
-
[jira] [Updated] (FLINK-37094) Adapt the external Hive connector to the removal of deprecated APIs in table module in 2.0
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-37094]refactor: adapt Hive connector to Flink 2.0 API changes [flink-connector-hive]
via GitHub
-
[PR] [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed [flink-connector-aws]
via GitHub
-
[jira] [Created] (FLINK-39581) Document the available config params in a single place for s3 native connector
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-39580) Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty)
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39580][build] Bump Java dependencies to resolve CVEs [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Java dependencies to resolve CVEs [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
Re: [PR] [FLINK-39580][build] Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) [flink]
via GitHub
-
[jira] [Closed] (FLINK-39575) Fix output rowtype in StreamPhysicalProcessTableFunction.toUdfCall when table arg is not first
Timo Walther (Jira)
-
[jira] [Created] (FLINK-39580) Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty)
Purushottam Sinha (Jira)
-
[jira] [Closed] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-39113) Add Encryption context support
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-39036) RowDataToAvroConverter ignores logical type when converting timestamps
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink]
via GitHub
-
[jira] [Resolved] (FLINK-39468) Release Testing Instructions: FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[jira] [Commented] (FLINK-39468) Release Testing Instructions: FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[jira] [Commented] (FLINK-39494) Release Testing: Verify FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[PR] [FLINK-39579][s3] Fix s3.sse.kms.encryption-context config in native s3 connector [flink]
via GitHub
-
[jira] [Updated] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector
ASF GitHub Bot (Jira)
-
[jira] [Assigned] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector
Gabor Somogyi (Jira)
-
[PR] [FLINK-30514] Fix HybridSourceReader's method calling order for underlying subsources during source switch [flink]
via GitHub
-
[jira] [Updated] (FLINK-39494) Release Testing: Verify FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[PR] [FLINK-39578][python] Include py.typed in PyFlink distribution [flink]
via GitHub
-
[jira] [Resolved] (FLINK-39470) Release Testing Instructions: FLIP-549: Support Application Management
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-39473) Release Testing Instructions: FLIP-560: Application Capability Enhancement
Yuepeng Pan (Jira)
-
[PR] [hotfix][docs] Fix typo in Working with State V2 - Execution Order [flink]
via GitHub
-
[jira] [Updated] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy
Florian Vazelle (Jira)
-
[jira] [Created] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy
Florian Vazelle (Jira)
-
[jira] [Updated] (FLINK-39577) Reuse Calcite's COALESCE to apply simplifications from RexSimplify
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39577][table] Reuse Calcite's `COALESCE` to apply simplifications from `RexSimplify` [flink]
via GitHub
-
[jira] [Created] (FLINK-39577) Reuse Calcite's COALESCE to apply simplifications from RexSimplify
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37731][pipeline-paimon]Support Postpone Bucket [flink-cdc]
via GitHub
-
[jira] [Assigned] (FLINK-39571) Improve Flink Kubernetes Operator documentation coverage
Gyula Fora (Jira)
-
[PR] [FLINK-39576][table] Expose NO_PASS_THROUGH as a PTF trait [flink]
via GitHub
-
[jira] [Updated] (FLINK-39576) Add new PTF StaticArgumentTrait#NO_PASS_THROUGH
ASF GitHub Bot (Jira)
-
[PR] [hotfix][docs] Fix typo in Using Keyed State V2 [flink]
via GitHub
-
[jira] [Updated] (FLINK-39575) Fix output rowtype in StreamPhysicalProcessTableFunction.toUdfCall when table arg is not first
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39575][table] Fix per-arg static-arg lookup in StreamPhysicalProcessTableFunction.toUdfCall [flink]
via GitHub
-
[jira] [Created] (FLINK-39576) Add new PTF StaticArgumentTrait#NO_PASS_THROUGH
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39575) Fix output rowtype in StreamPhysicalProcessTableFunction.toUdfCall when table arg is not first
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-39526) Support CROSS JOIN with inline VALUE clause with static state size
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-39526) Ever-growing checkpoint size in CROSS JOIN with inline VALUE clause causes checkpointing failure
Fabian Hueske (Jira)
-
[jira] [Commented] (FLINK-39526) Ever-growing checkpoint size in CROSS JOIN with inline VALUE clause causes checkpointing failure
Fabian Hueske (Jira)
-
[jira] [Commented] (FLINK-39397) postgres pk table encounted an error when delete a record
Taranpreet Kaur (Jira)
-
[jira] [Commented] (FLINK-30514) HybridSource savepoint recovery sequence
Chen Zhang (Jira)
-
Re: [PR] [hotfix][autoscaler] Cover ScalingRealizer overrides with tests [flink-kubernetes-operator]
via GitHub
-
[PR] [hotfix][e2e] Mitigate flaky minikube ingress addon enable in CI [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39573][cdc][docs] Fix Build documentation CI startup_failure by replacing third-party rsync action [flink-cdc]
via GitHub