issues  

Messages by Date

• 2025/05/28 [jira] [Updated] (FLINK-31942) Support Conditional Writes in DynamoDB connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Closed] (FLINK-36907) Bump flink-connector-aws to 1.20 Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Closed] (FLINK-37858) Migrate state processor API from source v1 to source v2 API Gabor Somogyi (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Commented] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-35541) Introduce retry limiting for AWS connector sinks Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36328) Making the log for child not found as debug Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36239) DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34407) Flaky tests causing workflow timeout Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34892) Nightly AWS connectors build fails on running python tests Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36138) KinesisStreamsSource.build() should have helpful null errors Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Reopened] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Closed] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-35660) Implement parent-child ordering for DDB Streams source Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36359) IT case for DDB Streams connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-32394) Init.pos is partially stored in connector state Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-19460) AWS Kinesis Producer EXACTLY_ONCE semantic Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-31854) FLIP-307:[Phase 1] [Sink Support] Flink Connector Redshift Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-31988) Implement Python wrapper for new KDS source Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37772) Release flink-connector-aws v5.1.0 Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Resolved] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Reopened] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Commented] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37416) DDB Streams connector flink state inconsistency issue Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Closed] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36215) Child shards are getting started with LATEST shard iterator even when parents are not expired Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Commented] (FLINK-37416) DDB Streams connector flink state inconsistency issue Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34340) Implement DDB Streams Table API support Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-21228) Deadlock in KinesisProducer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-26008) Update Kinesalite docker container reference Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-31946) DynamoDB Sink Allow Multiple Item Writes Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36947) Rate limiting the GetRecord call frequency Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-25733) Create A migration guide for Kinesis Table API connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-10536) Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-16839) Connectors Kinesis metrics can be disabled Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-32097) Implement support for Kinesis deaggregation Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34023) Expose Kinesis client retry config in sink Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-22473) Kinesis connector options are not listed by its factory Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-13291) Cannot provide AWS Direct Connect ENDPOINT Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-20350) Incompatible Connectors due to Guava conflict Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-29549) Add Aws Glue Catalog support in Flink Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-32696) Promote Kinesis connector support to PublicEvolving Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-16505) Document how to use the FlinkKinesisConsumer to read a CDC stream from DynamoDB Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36057) Allow specifying ARN for AWS connector resources Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-20294) Expose value format metadata in Kinesis table source Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-26933) FlinkKinesisConsumer incorrectly determines shards as newly discovered when tested against Kinesalite when consuming DynamoDB streams Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-31872) Add Support for Configuring AIMD Ratelimiting strategy parameters by Sink users for KinesisStreamsSink Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected in Kinesis Connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-34520) Confusing MIT language in the NOTICE file Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-30092) Improve Table API experience for Flink DOUBLE type Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-35989) Document and log error on partially failed requests for AWS sinks Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36666) CI/CD should check NOTICE files for discrepancies. Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36432) FLIP-438: Amazon SQS Source Connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36296) Add incremental shard discovery for DDB Streams source Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata. Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Closed] (FLINK-36770) Support Request Timeout for AWS sinks Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36907) Bump flink-connector-aws to 1.20 Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Commented] (FLINK-36770) Support Request Timeout for AWS sinks Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36971) Add Sqs Sink SQL connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37273) Dynamodb Streams getRecords call adaptive delay Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37563) Add additional metrics for DDB connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37004) Implement Multithreaded SourceReader Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37343) Support for Dynamic Table Selection in DynamoDB Sink Connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Commented] (FLINK-37687) Bump flink-connector-aws to 2.0 Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37687) Bump flink-connector-aws to 2.0 Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37841) Having adaptive retry strategy causing issues in DDB Connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-37688) FLIP-524: Amazon CloudWatch Metric Sink Connector Hong Liang Teoh (Jira)
• 2025/05/28 [jira] [Updated] (FLINK-25779) Define ConfigOption for aws, scan and sink map in Kinesis Hong Liang Teoh (Jira)
• 2025/05/28 Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 [jira] [Updated] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37481) FLIP-516: Multi way join operator dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator dalongliu (Jira)
• 2025/05/27 [jira] [Created] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• 2025/05/27 [jira] [Commented] (FLINK-37481) FLIP-516: Multi way join operator dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator dalongliu (Jira)
• 2025/05/27 [jira] [Updated] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator dalongliu (Jira)
• 2025/05/27 [jira] [Commented] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator dalongliu (Jira)
• 2025/05/27 Re: [PR] [hotfix]Adds Override annotation [flink] via GitHub
• 2025/05/27 [PR] [hotfix]Adds Override annotation [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] via GitHub
• 2025/05/27 Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] via GitHub
• 2025/05/27 Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37791][6/N] model sql to rel converter [flink] via GitHub
• 2025/05/27 [jira] [Updated] (FLINK-37791) Integrate with sql to rel converter ASF GitHub Bot (Jira)
• 2025/05/27 [PR] [FLINK-37791][6/N] model sql to rel converter [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37780][5/N] predict sql function type inference and validation [flink] via GitHub
• 2025/05/27 [jira] [Created] (FLINK-37858) Migrate state processor API from source v1 to source v2 API Gabor Somogyi (Jira)
• 2025/05/27 Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37857][tests] Add a DSV2 sink implementation to tests which can collect data [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37857][tests] Add a DSV2 sink implementation to tests which can collect data [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 [jira] [Updated] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data ASF GitHub Bot (Jira)
• 2025/05/27 [PR] [FLINK-37857][tests] Add a DSV2 sink implementation to tests which can collect data [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp [flink] via GitHub
• 2025/05/27 Re: [PR] [hotfix] Fix invalid comments in Committer [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink] via GitHub
• 2025/05/27 [jira] [Created] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data Gabor Somogyi (Jira)
• 2025/05/27 Re: [PR] [FLINK-37763][table] Support multiple table arguments in PTFs [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37841][Connectors/DynamoDB] Using standard retry strategy instead of adaptive retry strategy to build ddb streams client [flink-connector-aws] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37841][Connectors/DynamoDB] Using standard retry strategy instead of adaptive retry strategy to build ddb streams client [flink-connector-aws] via GitHub
• 2025/05/27 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 [jira] [Commented] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException Ferenc Csaky (Jira)
• 2025/05/27 [PR] [release] Main branch updates after release cut [flink-kubernetes-operator] via GitHub
• 2025/05/27 [jira] [Comment Edited] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink Poorvank Bhatia (Jira)
• 2025/05/27 Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37763][table] Support multiple table arguments in PTFs [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37125] [conf] fixed env.log.max java.lang.NumberFormatException [flink] via GitHub
• 2025/05/27 Re: [PR] [release] Main branch updates after release cut [flink-kubernetes-operator] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] via GitHub
• 2025/05/27 [jira] [Commented] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException sehaj pal singh sandhu (Jira)
• 2025/05/27 Re: [PR] [FLINK-37763][table] Support multiple table arguments in PTFs [flink] via GitHub
• 2025/05/27 [jira] [Assigned] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException Ferenc Csaky (Jira)
• 2025/05/27 [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37763][table] Support multiple table arguments in PTFs [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37763][table] Support multiple table arguments in PTFs [flink] via GitHub
• 2025/05/27 Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] via GitHub
• 2025/05/27 [jira] [Commented] (FLINK-37850) Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException Sergey Nuyanzin (Jira)

• Earlier messages
• Later messages