Messages by Thread
-
-
[jira] [Comment Edited] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint
Piotr Nowojski (Jira)
-
[jira] [Comment Edited] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode
Kanthi Vaidya (Jira)
-
[jira] [Created] (FLINK-35363) Reorganization of flink-connector-jdbc
Jira
-
[jira] [Created] (FLINK-35362) Reorganization of flink-connector-jdbc
Jira
-
[jira] [Commented] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint
Piotr Nowojski (Jira)
-
[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint
Piotr Nowojski (Jira)
-
[jira] [Assigned] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint
Piotr Nowojski (Jira)
-
[PR] [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese [flink]
via GitHub
-
[jira] [Updated] (FLINK-35353) Translate "Profiler" page into Chinese
ASF GitHub Bot (Jira)
-
[jira] [Comment Edited] (FLINK-35358) Breaking change when loading artifacts
Ferenc Csaky (Jira)
-
[PR] [BP-1.19][FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib" [flink]
via GitHub
-
[PR] [FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib" [flink]
via GitHub
-
[PR] [Module 1] Lab1 and Lab2 done [flink-training]
via GitHub
-
[PR] [FLINK-35361]Delete Flinkhistory files that failed to write to the lo… [flink]
via GitHub
-
[jira] [Updated] (FLINK-35361) Delete Flinkhistory files that failed to write to the local directory
dengxaing (Jira)
-
[jira] [Created] (FLINK-35361) Delete Flinkhistory files that failed to write to the local directory
dengxaing (Jira)
-
[jira] [Comment Edited] (FLINK-20392) Migrating bash e2e tests to Java/Docker
Muhammet Orazov (Jira)
-
[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint
Piotr Nowojski (Jira)
-
Re: [PR] [FLINK-34572] Support OceanBase Jdbc Catalog [flink-connector-jdbc]
via GitHub
-
[jira] [Updated] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode
Jira
-
[jira] [Created] (FLINK-35360) [Feature] Submit Flink CDC pipeline job to yarn Application mode
Jira
-
[jira] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.
Jira
-
[jira] [Created] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xuannan Su (Jira)
-
[jira] [Comment Edited] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.
Jira
-
[jira] [Commented] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.
Jira
-
[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary
Alexey Novakov (Jira)
-
[jira] [Commented] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document
Rui Fan (Jira)
-
[jira] [Assigned] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document
Rui Fan (Jira)
-
[jira] [Resolved] (FLINK-35153) Internal Async State Implementation and StateDescriptor for Map/List State
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-35153) Internal Async State Implementation and StateDescriptor for Map/List State
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink
Lorenzo Affetti (Jira)
-
[jira] [Commented] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27
Lorenzo Affetti (Jira)
-
[jira] [Commented] (FLINK-24299) Make Google PubSub available as Source and Sink for Table API
Lorenzo Affetti (Jira)
-
[jira] [Commented] (FLINK-35358) Breaking change when loading artifacts
Martijn Visser (Jira)
-
Re: [PR] [FLINK-35314][cdc] Add Flink CDC pipeline transform user document [flink-cdc]
via GitHub
-
[PR] [FLINK-32092][tests] Integrate snapshot file-merging with existing ITCases [flink]
via GitHub
-
[jira] [Updated] (FLINK-32092) Integrate snapshot file-merging with existing IT cases
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker
Lorenzo Affetti (Jira)
-
[jira] [Updated] (FLINK-35358) Breaking change when loading artifacts
Rasmus Thygesen (Jira)
-
[jira] [Created] (FLINK-35358) Breaking change when loading artifacts
Rasmus Thygesen (Jira)
-
[jira] [Reopened] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError
Jeyhun Karimov (Jira)
-
[PR] [FLINK-34379][table] Fix adding catalogtable logic [flink]
via GitHub
-
Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]
via GitHub
-
[jira] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join
Roman Boyko (Jira)
-
[jira] [Updated] (FLINK-33925) Extended failure handling for bulk requests (elasticsearch back port)
Sergey Nuyanzin (Jira)
-
[jira] [Closed] (FLINK-30537) Add support for OpenSearch 2.3
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-34942) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-34942) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document
Yang Zhou (Jira)
-
[jira] [Created] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document
Yang Zhou (Jira)
-
[jira] [Updated] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation
Sergey Nuyanzin (Jira)
-
[jira] [Comment Edited] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-34503][table] Migrate JoinDeriveNullFilterRule to java. [flink]
via GitHub
-
Re: [PR] [FLINK-35075][table] Migrate TwoStageOptimizedAggregateRule to java [flink]
via GitHub
-
Re: [PR] [FLINK-34555][table] Migrate JoinConditionTypeCoerceRule to java. [flink]
via GitHub
-
[jira] [Commented] (FLINK-34109) FileSystem sink connector restore job from historical checkpoint failure
Sergey Paryshev (Jira)
-
[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join
xuyang (Jira)
-
[jira] [Commented] (FLINK-33790) Upsert statement filter unique key field colume in mysql dielact
SuDewei (Jira)
-
[jira] [Updated] (FLINK-35346) Introduce pluggable workflow scheduler interface for materialized table
ASF GitHub Bot (Jira)
-
[PR] [FLINK-35318][table] use UTC timezone to handle TIMESTAMP_WITHOUT_TIM… [flink]
via GitHub
-
Re: [PR] [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition in split reader [flink-connector-kafka]
via GitHub
-
[jira] [Assigned] (FLINK-35353) Translate "Profiler" page into Chinese
Jark Wu (Jira)
-
Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
-
[PR] Fsip module 2b [flink-training]
via GitHub
-
[PR] feat(module-1): Implementing ride-cleansing and rides-and-fares [flink-training]
via GitHub
-
[jira] [Commented] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode
Kanthi Vaidya (Jira)
-
[jira] [Resolved] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation
Sergey Nuyanzin (Jira)
-
Re: [PR] [BP-1.19][FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank() [flink]
via GitHub
-
Re: [PR] [FLINK-34896][table] Migrate CorrelateSortToRankRule to java [flink]
via GitHub
-
Re: [PR] [BP-1.18][FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank() [flink]
via GitHub
-
[jira] [Commented] (FLINK-24298) Refactor Google PubSub sink to use Unified Sink API
Ahmed Hamdy (Jira)
-
[PR] [FLINK-35333] Remove weekly check for v3.1 with 1.19 [flink-connector-jdbc]
via GitHub
-
[jira] [Comment Edited] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests
Jira
-
[jira] [Updated] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests
Jira
-
[PR] [FLINK-35333] Fix JdbcXaSinkTestBase fails in weekly workflows [flink-connector-jdbc]
via GitHub
-
Re: [PR] [FLINK-30284][flink-metrics] Modify configuration of DataDog http reporter url. [flink]
via GitHub
-
[jira] [Updated] (FLINK-24298) Refactor Google PubSub sink to use Unified Sink API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
Re: [PR] [FLINK-24298] Add GCP PubSub Sink API Implementation, bump Flink version to 1.19.0 [flink-connector-gcp-pubsub]
via GitHub
-
[jira] [Updated] (FLINK-34931) Update Kudu DataStream connector to use Sink V2
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-34931) Update Kudu connector DataStream Sink implementation
ASF GitHub Bot (Jira)