Messages by Thread
-
-
[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)
-
[jira] [Created] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition
Ran Tao (Jira)
-
[jira] [Closed] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket
Yanquan Lv (Jira)
-
[jira] [Updated] (FLINK-34332) Investigate the permissions
ASF GitHub Bot (Jira)
-
[PR] [FLINK-34332][ci] Follow the principle of least privilege for GITHUB_TOKEN [flink]
via GitHub
-
Re: [PR] [FLINK-39577][table] Reuse Calcite's `COALESCE` to apply simplifications from `RexSimplify` [flink]
via GitHub
-
[jira] [Updated] (FLINK-39695) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39695][table] Outer join on nested field fails with conversion to relational algebra failed to preserve datatypes [flink]
via GitHub
-
[jira] [Closed] (FLINK-39694) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-39647] Downgrade presto-hive to 0.294 [flink]
via GitHub
-
[jira] [Created] (FLINK-39695) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39694) Outer join on nested field fails with Conversion to relational algebra failed to preserve datatypes
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-33653][runtime] Introduce a benchmark for balanced tasks scheduling. [flink-benchmarks]
via GitHub
-
Re: [PR] [hotfix] re-enable unit tests test_kafka.py for pyflink [flink]
via GitHub
-
[PR] [hotfix] Call open() in embedding setup tests before embed() [flink-agents]
via GitHub
-
[PR] [api] Specify model in ChatModelSetup (Java + Python) [flink-agents]
via GitHub
-
Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-38934][cdc connector mysql] honour ssl protocol setting configured in debeziumProps [flink-cdc]
via GitHub
-
[PR] [hotfix][docs] Add missing CSV and JSON entries to DataStream formats overview [flink]
via GitHub
-
[PR] [hotfix][docs] Fix typo and heading level in state backends documentation [flink]
via GitHub
-
[PR] [hotfix][table-runtime] Fix typo in RowTimeMiniBatchAssignerOperator class name [flink]
via GitHub