Messages by Thread
-
-
[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
-
[jira] [Updated] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39693] Bump jackson, log4j, assertj to address CVEs [flink-connector-kafka]
via GitHub
-
[PR] [hotfix] Bump flink.version to 2.1.2 [flink-connector-kafka]
via GitHub
-
[jira] [Created] (FLINK-39693) Bump jackson, log4j, assertj to address CVEs
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-38392) StreamPandasConversionTests failing
Chanhae Oh (Jira)
-
Re: [PR] [FLINK-39490][web] Improve feedback when cluster is unreachable [flink]
via GitHub
-
Re: [PR] [FLINK-39503][runtime-web] Auto-fit Job Overview DAG height and add recenter control [flink]
via GitHub
-
[jira] [Closed] (FLINK-39671) Adopt jackson-bom in flink-model-triton for unified version management
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-39692) Several catch blocks log the message but discard the captured exception
Pavel Zeger (Jira)
-
[jira] [Updated] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules
Pavel Zeger (Jira)
-
[jira] [Created] (FLINK-39691) Fix "mim" typo in AggregatedMetric.toString() in operator and autoscaler-standalone modules
Pavel Zeger (Jira)
-
[PR] [dependency] Update flink version and constraint. [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-39675) http-generic-json-url query param configuration not required.
Ferenc Csaky (Jira)
-
[jira] [Commented] (FLINK-38510) Remove targetColumns from the digest generation of SinkReuser
ChanBin OH (Jira)
-
[jira] [Commented] (FLINK-39166) Add bucket level config parity
Gabor Somogyi (Jira)
-
[jira] [Closed] (FLINK-39166) Add bucket level config parity
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39166) Add bucket level config parity
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-39166) Add bucket level config parity
Gabor Somogyi (Jira)
-
[I] [Feature] Update Flink version and constraint [flink-agents]
via GitHub
-
[PR] [hotfix] Remove unused DurableExecutionManager.maybePruneState helper [flink-agents]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-statefun-docker]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-training]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-jira-bot]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-docker]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-pulsar]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-opensearch]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-prometheus]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-gcp-pubsub]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-web]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-statefun]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-statefun-playground]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-ml]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-shared-utils]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-shaded]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-playgrounds]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-kudu]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-kafka]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-agents-demos]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-http]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-jdbc]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-hbase]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-redis-streams]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-elasticsearch]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-rabbitmq]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-cassandra]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-aws]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-benchmarks]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-cdc]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-mongodb]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-hive]
via GitHub
-
[PR] [INFRA] Set up default rulesets for default and release branches [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36602][table] Upgrade Calcite version to 1.38.0 [flink]
via GitHub
-
[jira] [Created] (FLINK-39690) Use imgae from official hugo images
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39689) Standardize the place holders characters used in http-generic-json-url query creator to use {{ and }}
David Radley (Jira)
-
[PR] [hotfix][build] Use sparse-checkout paths for Flink template in GHA. [flink]
via GitHub
-
[PR] [FLINK-39688] Share a single PluginManager across operator and webhook startup [flink-kubernetes-operator]
via GitHub
-
[jira] [Created] (FLINK-39688) Share a single PluginManager across operator and webhook startup
Dennis-Mircea Ciupitu (Jira)
-
[PR] [hotfix][state/tests] Dispose keyed state backend in testMapStateWithNullValue [flink]
via GitHub
-
[PR] [hotfix] Disable zk ha to fix weekly ci for v3.1 branch [flink-connector-elasticsearch]
via GitHub
-
[jira] [Closed] (FLINK-39686) URI used as URL in SessionContext causes ArrayStoreException
tonyabasy (Jira)
-
[jira] [Created] (FLINK-39686) URI used as URL in SessionContext causes ArrayStoreException
wangzhao (Jira)
-
[jira] [Updated] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException
wangzhao (Jira)
-
[jira] [Created] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException
wangzhao (Jira)
-
[PR] [FLINK-39685][table] Redact sensitive options in SHOW CREATE and DESCRIBE CATALOG statements [flink]
via GitHub