Messages by Thread
-
-
[jira] [Commented] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Arvind Kandpal (Jira)
-
[jira] [Updated] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire
Prashant Bhardwaj (Jira)
-
[PR] [FLINK-39698][docs] Fix incorrect content in SQLServer CDC connector documentation [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire
Matthias Pohl (Jira)
-
[jira] [Commented] (FLINK-38192) Improve DynamicSourceUtils exception msg
Arvind Kandpal (Jira)
-
[PR] [FLINK-38192][table] Improve DynamicSourceUtils exception message [flink]
via GitHub
-
[PR] [hotfix] Move chat-model os.environ mutations out of module scope in e2e tests [flink-agents]
via GitHub
-
[PR] [FLINK-39706][ci] Add flink 2.1 testing for v4.0 branch [flink-connector-elasticsearch]
via GitHub
-
[PR] [FLINK-39706][ci] Remove flink 2.1 testing from es connector main branch [flink-connector-elasticsearch]
via GitHub
-
[jira] [Updated] (FLINK-39706) Remove flink 2.1 testing from es connector main branch
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-39706) Remove flink 2.1 testing from es connector main branch
Weijie Guo (Jira)
-
[jira] [Assigned] (FLINK-39705) Remove not needed ZooKeeper references from flink-connector-kafka
Rui Fan (Jira)
-
[jira] [Created] (FLINK-39705) Remove not needed ZooKeeper references from flink-connector-kafka
Aleksandr Savonin (Jira)
-
[jira] [Created] (FLINK-39704) Kubernetes HA can recover a globally terminal FAILED application job after leadership revoke/reacquire
Prashant Bhardwaj (Jira)
-
[jira] [Assigned] (FLINK-22543) layout of exception history tab isn't very usable with Flink SQL
Roman Khachatryan (Jira)
-
[jira] [Updated] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39703][tests] Fix flaky KafkaWriterFaultToleranceITCase [flink-connector-kafka]
via GitHub
-
[jira] [Assigned] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable
Rui Fan (Jira)
-
[jira] [Created] (FLINK-39703) Fix flaky KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable
Aleksandr Savonin (Jira)
-
[jira] [Updated] (FLINK-39700) Fix name-based column matching in materialized table schema diff
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39700][table-planner] Fix column-order sensitivity in validateAndExtractColumnChanges [flink]
via GitHub
-
[jira] [Updated] (FLINK-39702) Exclude netty 3.x from hadoop
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39702] Exclude netty 3.x from hadoop [flink]
via GitHub
-
[jira] [Created] (FLINK-39702) Exclude netty 3.x from hadoop
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-39061][example] Roll back StateMachineExample to v1 State API [flink]
via GitHub
-
[jira] [Updated] (FLINK-37700) SQL parse exception when creating a view with PTF
Sergey Nuyanzin (Jira)
-
[PR] [hotfix] Bump download-artifact action to v8 as GHA requires [flink]
via GitHub
-
[jira] [Updated] (FLINK-39699) Kafka connector CI failed on the main branch
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39699][tests] Wait for completed checkpoint stats in KafkaSinkITCase [flink-connector-kafka]
via GitHub
-
[jira] [Closed] (FLINK-39503) Make Job Overview DAG height viewport-aware and add recenter control
Ferenc Csaky (Jira)
-
[PR] [FLINK-39645][connector-base] Preserve restored HybridSource splits during snapshot [flink]
via GitHub
-
[jira] [Commented] (FLINK-39645) HybridSourceReader.snapshotState() loses recovered splits when currentReader is null
Jira
-
[jira] [Closed] (FLINK-39689) Standardize the place holders characters used in http-generic-json-url query creator to use {{ and }}
Ferenc Csaky (Jira)
-
[jira] [Commented] (FLINK-37198) AvroToRowDataConverters factory omits legacyTimestampMapping option for nested Row.
Jira
-
[jira] [Commented] (FLINK-39685) Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39685) Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements
Gabor Somogyi (Jira)
-
[jira] [Closed] (FLINK-39685) Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException
Jira
-
[jira] [Assigned] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39377) Initial ProcessTableFunctionTestHarness implementation
Fabian Hueske (Jira)
-
[jira] [Commented] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds
Chanhae Oh (Jira)
-
[jira] [Commented] (FLINK-34201) Datadog name resolution fails and do not retry causing metrics to not get exported
Raul Garcia (Jira)
-
[PR] [FLINK-39701][s3]Fix Concurrency Annotation in native-s3-fs [flink]
via GitHub
-
[jira] [Updated] (FLINK-39701) Fix Concurrency Annotation in native-s3-fs
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-39701) Fix Concurrency Annotation in native-s3-fs
Samrat Deb (Jira)
-
[PR] [Feature][Python] Implement EventListener in python sdk [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-39682) Unable to invoke TO_DATE with TIMESTAMP types
Xiqian Yu (Jira)
-
[jira] [Commented] (FLINK-39700) Fix name-based column matching in materialized table schema diff
david radley (Jira)
-
[jira] [Created] (FLINK-39700) Fix name-based column matching in materialized table schema diff
Arvid Heise (Jira)
-
[jira] [Assigned] (FLINK-30514) HybridSource savepoint recovery sequence
Leonard Xu (Jira)
-
[jira] [Resolved] (FLINK-30514) HybridSource savepoint recovery sequence
Leonard Xu (Jira)
-
[jira] [Commented] (FLINK-39699) Kafka connector CI failed on the main branch
Purushottam Sinha (Jira)
-
[PR] [Flink 39689][http-connector] make the template placeholders consistent. [flink-connector-http]
via GitHub
-
[jira] [Updated] (FLINK-39591) Bump actions v4 to v5
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39646) Update flink-python-example to Flink 2.2
Rui Fan (Jira)
-
[jira] [Assigned] (FLINK-39699) Kafka connector CI failed on the main branch
Rui Fan (Jira)
-
[jira] [Closed] (FLINK-39666) Fix TO_TIMESTAMP_LTZ multiple edge-case bugs in precision handling
Timo Walther (Jira)
-
[jira] [Created] (FLINK-39699) Kafka connector CI failed on the main branch
Rui Fan (Jira)
-
[jira] [Commented] (FLINK-39591) Bump actions v4 to v5
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-39650][table] REGEXP_REPLACE plan-time validation and hot-path log cleanup [flink]
via GitHub
-
[jira] [Updated] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Ruan Hang (Jira)
-
[jira] [Created] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation
Ruan Hang (Jira)
-
[PR] [hotfix][ci] Bump artifact-upload version [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39110) Add CRT Support
Gabor Somogyi (Jira)
-
[PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar]
via GitHub
-
[jira] [Updated] (FLINK-39697) Upgrade Pulsar connector to Flink 2.2.1
Fan Deng (Jira)
-
[jira] [Updated] (FLINK-39697) Bump Flink version to 2.2.1
Fan Deng (Jira)
-
[jira] [Assigned] (FLINK-39616) Add instructions on how to fix ordering with ORDER BY when using FROM_CHANGELOG
Fabian Hueske (Jira)
-
[jira] [Resolved] (FLINK-39616) Add instructions on how to fix ordering with ORDER BY when using FROM_CHANGELOG
Fabian Hueske (Jira)
-
Re: [PR] Add release automation scripts (Phase A) [flink]
via GitHub
-
Re: [PR] [FLINK-28440][changelog] Fix premature discard of state handles during checkpoint restore [flink]
via GitHub
-
[jira] [Created] (FLINK-39697) Update Pulsar connector to Flink 2.2.1
Fan Deng (Jira)
-
[PR] [backport-2.1][FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink]
via GitHub
-
[PR] [backport-2.0][FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink]
via GitHub
-
[PR] [backport-1.2][FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink]
via GitHub
-
[jira] [Resolved] (FLINK-39684) YAML PaimonWriter throws NullPointerException when handling REPLACE event
Xiqian Yu (Jira)
-
[PR] [backport-2.2][FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink]
via GitHub
-
[PR] [backport-2.3][FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition
Xiqian Yu (Jira)
-
[jira] [Resolved] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition
Xiqian Yu (Jira)
-
Re: [I] [Tech Debt] Specify model to be used in ChatModelSetup. [flink-agents]
via GitHub
-
[jira] [Comment Edited] (FLINK-39315) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase when the MySql table is being continuously written
Ran Tao (Jira)
-
[jira] [Commented] (FLINK-39315) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase when the MySql table is being continuously written
Ran Tao (Jira)
-
[PR] [BP-4.0] Backport important features to v4.0 branch [flink-connector-elasticsearch]
via GitHub
-
[I] [Feature][Python] Implement EventListener to align with Java SDK [flink-agents]
via GitHub
-
[PR] [FLINK-39696][runtime] Use source partition for distributed flush events [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition
ASF GitHub Bot (Jira)