Messages by Thread
-
[jira] [Updated] (FLINK-39590) Connection catalog manager changes
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39590] connection catalog manager changes [flink]
via GitHub
-
[jira] [Commented] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI
Hao Li (Jira)
-
[jira] [Created] (FLINK-39590) Connection catalog manager changes
Hao Li (Jira)
-
[jira] [Commented] (FLINK-39554) Support multiple custom autoscaler evaluators with deterministic ordering
Pavel Zeger (Jira)
-
[jira] [Commented] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments
Pavel Zeger (Jira)
-
[jira] [Created] (FLINK-39589) Window TVF aggregation emits incorrect results with RocksDB state backend
Kanchi Masalia (Jira)
-
[jira] [Updated] (FLINK-39587) [Web dashboard] CI lint uses --cache and tolerates prettier drift on master
Purushottam Sinha (Jira)
-
[jira] (FLINK-39587) [Web dashboard] CI lint uses --cache and tolerates prettier drift on master
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-39426) Flink 2.0 and Connector version compatibility issue
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39426] Add flink-connector-migration bridge module for Sink V2… [flink]
via GitHub
-
[PR] [FLINK-39588][flink-table][connector/datagen] Migrate the DataGen table connector off deprecated source APIs [flink]
via GitHub
-
Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink]
via GitHub
-
[jira] [Created] (FLINK-39588) Migrate the DataGen table connector off deprecated source APIs
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Commented] (FLINK-39587) [Web dashboard] Prettier rules not enforced in CI - cache hides drift
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-39587) [Web dashboard] Prettier rules not enforced in CI - cache hides drift
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39587) [Web dashboard] Prettier rules not enforced in CI; cache hides drift
Purushottam Sinha (Jira)
-
[PR] [FLINK-39401][formats] Port raw line-delimiter option to release-2.1 [flink]
via GitHub
-
[PR] [hotfix] Add log4j-layout-template-json to NOTICE [flink]
via GitHub
-
[jira] [Closed] (FLINK-39581) Document the available config params in a single place for s3 native connector
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39581) Document the available config params in a single place for s3 native connector
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-39581) Document the available config params in a single place for s3 native connector
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39580) Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty)
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-39580) Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty)
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39580) Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty)
Sergey Nuyanzin (Jira)
-
Re: [PR] [hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety [flink]
via GitHub
-
Re: [PR] [FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules [flink]
via GitHub
-
Re: [PR] [hotfix] Rename prefix to tag for FileChannelManagerImpl [flink]
via GitHub
-
Re: [PR] [FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator [flink]
via GitHub
-
Re: [PR] [FLINK-37549][table][docs]: Fix some scala and markdown syntax errors in tableApi page [flink]
via GitHub
-
Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink]
via GitHub
-
[I] [Tech Debt] [runtime] Add comprehensive tests for ActionExecutionOperator manager classes [flink-agents]
via GitHub
-
[I] [Bug][runtime] Fix memory leak in DurableExecutionManager.checkpointIdToSeqNums [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty
Chen Zhang (Jira)
-
[jira] [Created] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty
Chen Zhang (Jira)
-
[jira] [Comment Edited] (FLINK-39585) Log AdaptiveScheduler ExecutionGraph creation failures at ERROR
Herbert Wang (Jira)
-
[PR] [FLINK-39585][runtime] Log execution graph creation failures at ERROR Level [flink]
via GitHub
-
[jira] [Updated] (FLINK-38333) Umbrella: FLIP-495: Support AdaptiveScheduler record and store the rescale history
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-22258) Umbrella: FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-22258) Umbrella: FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-38902) Add user instructions and usage documentation for FLIP-487
Yuepeng Pan (Jira)
-
[PR] [FLINK-39999][runtime] Log execution graph creation failures at ERROR severity [flink]
via GitHub
-
[jira] [Commented] (FLINK-39585) Log AdaptiveScheduler ExecutionGraph creation failures at ERROR
Herbert Wang (Jira)
-
[jira] [Updated] (FLINK-39585) Log AdaptiveScheduler ExecutionGraph creation failures at ERROR
Herbert Wang (Jira)
-
[jira] [Created] (FLINK-39585) Log AdaptiveScheduler ExecutionGraph creation failures at ERROR
Herbert Wang (Jira)
-
[PR] [hotfix] Replace removed in 2.13 `MutableList` [flink]
via GitHub
-
[PR] Local [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39581) Document the available config params in a single place for s3 native connector
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39226) pemja.core.object.PyIterator ClassCastException
Bowen Li (Jira)
-
[jira] [Updated] (FLINK-39581) Document the available config params in a single place for s3 native connector
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39581] Document the available config params in a single place for s3 native connector [flink]
via GitHub
-
[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)
-
[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)
-
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)