Messages by Thread
-
[jira] [Resolved] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event
Sai Sharath Dandi (Jira)
-
[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner
Sai Sharath Dandi (Jira)
-
[PR] [FLINK-37222][Test] Introduce simple test submitting nexmark sql via sql client [flink]
via GitHub
-
[PR] [BP-2.0][FLINK-37206][Runtime] Fix initialization of batching timer service in async state operators [flink]
via GitHub
-
[jira] [Updated] (FLINK-37239) Improve documentation for multiple built-in functions
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile [flink]
via GitHub
-
Re: [PR] [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type [flink]
via GitHub
-
[jira] [Closed] (FLINK-37237) Improve Kudu table creation based on Flink SQL `CREATE TABLE`
Ferenc Csaky (Jira)
-
Re: [PR] [FLINK-37237] Improve Kudu table creation based on Flink SQL `CREATE TABLE` [flink-connector-kudu]
via GitHub
-
[jira] [Commented] (FLINK-37178) Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE
Gustavo de Morais (Jira)
-
[jira] [Closed] (FLINK-37178) Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37239) Improve documentation for multiple built-in functions
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-37236) Make Flink operator compatible with 2.0 preview
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37236] Flink 2.0 preview support [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-37238) Flink Web UI does not take scaled parallelism into account when showing job graph
Sai Sharath Dandi (Jira)
-
[jira] [Created] (FLINK-37238) Flink Web UI does not take scaled parallelism into account when showing job graph
Sai Sharath Dandi (Jira)
-
[PR] Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10 [flink]
via GitHub
-
[jira] [Updated] (FLINK-37237) Improve Kudu table creation based on Flink SQL `CREATE TABLE`
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-37237) Enforce SQL PRIMARY KEY definition for Kudu tables and remove table option
ASF GitHub Bot (Jira)
-
[jira] [Assigned] (FLINK-37212) When hbase region move, throw "Unable to load exception received from server: XXX"
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-37237) Enforce SQL PRIMARY KEY definition for Kudu tables and remove table option
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-37236) Make Flink operator compatible with 2.0 preview
Gyula Fora (Jira)
-
[jira] [Assigned] (FLINK-37221) Apply FLIP-406 to Kubernetes Operator
Gyula Fora (Jira)
-
[PR] [FLINK-31275] extend lineage listener with QueryOperationEvent [flink]
via GitHub
-
[PR] Add Flink 1.20.1 release [flink-web]
via GitHub
-
Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]
via GitHub
-
Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink]
via GitHub
-
[jira] [Assigned] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8
Yanquan Lv (Jira)
-
[jira] [Updated] (FLINK-37234) Add timeout for test case to avoid Infinite waiting
Yanquan Lv (Jira)
-
[jira] [Commented] (FLINK-37234) Add timeout for test case to avoid Infinite waiting
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37234) Add timeout for test case to avoid Infinite waiting
Yanquan Lv (Jira)
-
[jira] [Comment Edited] (FLINK-37233) Flink-CDC Documentation change request
911432 (Jira)
-
[PR] [FLINK-37232][runtime] Fix for broken synchronization assumption on t… [flink]
via GitHub
-
[jira] [Commented] (FLINK-37233) Flink-CDC Documentation change request
qinghuan wang (Jira)
-
[PR] update cdc overview [flink-cdc]
via GitHub
-
[PR] Add Flink 1.19.2 release [flink-web]
via GitHub
-
[jira] [Updated] (FLINK-35775) README.md changes
911432 (Jira)
-
[jira] [Updated] (FLINK-37233) Flink-CDC Documentation change request
911432 (Jira)
-
[jira] [Created] (FLINK-37233) Flink-CDC Documentation change request
911432 (Jira)
-
[jira] [Closed] (FLINK-37229) Add DELETING/DELETED lifecycle states
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side
Matthias Pohl (Jira)
-
[PR] [FLINK-37200]Add e2e test for ElasticSearch Sink. [flink-cdc]
via GitHub
-
[jira] [Closed] (FLINK-37142) Update version of flink-connector-kafka to 4.0-SNAPSHOT
Yanquan Lv (Jira)
-
Re: [PR] Fix docker compose configuration [flink-playgrounds]
via GitHub
-
[jira] [Closed] (FLINK-37230) Consolidate Kudu connector table options
Ferenc Csaky (Jira)
-
[jira] [Commented] (FLINK-37231) Add doc for newly added source metric statistics
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37231) Add doc for newly added source metric statistics
Yanquan Lv (Jira)
-
Re: [PR] [FLINK-23589][flink-avro] Support microsecond precision for timestamp [flink]
via GitHub
-
[jira] [Updated] (FLINK-37230) Consolidate Kudu connector table options
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37230] Consolidate Table options [flink-connector-kudu]
via GitHub
-
[jira] [Created] (FLINK-37230) Consolidate Kudu connector table options
Ferenc Csaky (Jira)
-
Re: [PR] [hotfix] Enable @PublicEvolving japicmp checks [flink]
via GitHub
-
[jira] [Closed] (FLINK-37228) kubernetes HA fails both on flink 1.19.1 and flink 1.20
sigalit (Jira)
-
[jira] [Resolved] (FLINK-36782) Incorrect comment syntax
David Anderson (Jira)
-
[PR] [FLINK-37214][runtime] Refactors test to use proper Executor service for the main thread [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-37098) Can not select time attribute from a view
Alexander Fedulov (Jira)
-
[PR] [hotfix] Mark Column#rename internal [flink]
via GitHub
-
Re: [PR] [FLINK-29571] Support Map<String, T> ConfigOptions [flink]
via GitHub
-
[jira] [Resolved] (FLINK-37170) Disable 1.18 CI
Matthias Pohl (Jira)
-
[jira] [Updated] (FLINK-37229) Add DELETING/DELETED lifecycle states
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37229] Add/record DELETING/DELETED lifecycle states [flink-kubernetes-operator]
via GitHub
-
[jira] [Assigned] (FLINK-31849) Enforce some some simple validation directly through the CRD
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37229) Add DELETING/DELETED lifecycle states
Gyula Fora (Jira)
-
[jira] [Assigned] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers
Gyula Fora (Jira)
-
[jira] [Assigned] (FLINK-31406) Do not delete jobgraph on scale only last-state upgrades
Gyula Fora (Jira)
-
[jira] [Assigned] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing
Gyula Fora (Jira)
-
[jira] [Updated] (FLINK-37227) FLIP-506: Support Reuse Multiple Table Sinks in Planner
xiangyu feng (Jira)
-
Re: [PR] [FLINK-25410] Flink CLI should exit when app is accepted with detach … [flink]
via GitHub
-
Re: [PR] [FLINK-27550] The method of checkYarnQueues is compatible with capacity scheduler [flink]
via GitHub
-
Re: [PR] [FLINK-35512][flink-clients] Don't depend on the flink-clients jar actually existing. [flink]
via GitHub
-
[jira] [Created] (FLINK-37228) kubernetes HA fails both on flink 1.19.1 and flink 1.20
sigalit (Jira)
-
[jira] [Assigned] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads
Matthias Pohl (Jira)
-
[PR] [FLINK-37220][connector-api] Deprecates RateLimiterStrategy#perSecond and introduces PerSecondRateLimiterStrategy to fix thread leakage and intro [flink]
via GitHub
-
[jira] [Updated] (FLINK-37098) Can not select time attribute from a view
Alexander Fedulov (Jira)
-
[jira] [Resolved] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection
Rui Fan (Jira)
-
[jira] [Updated] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner
xiangyu feng (Jira)
-
[jira] [Created] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner
xiangyu feng (Jira)
-
[PR] [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. [flink]
via GitHub
-
[jira] [Commented] (FLINK-37225) Remove remaining test resources of Gelly
Zhanghao Chen (Jira)
-
[jira] [Updated] (FLINK-37134) Cross-team verification for FLIP-492
Feng Jin (Jira)
-
[jira] [Created] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc
Zhanghao Chen (Jira)
-
[jira] [Commented] (FLINK-37118) Enhance flink cdc metrics
ChaomingZhang (Jira)
-
[jira] [Commented] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode"
Feng Jin (Jira)
-
[PR] [FLINK-36352][doc] Remove Scala DataStream API related doc [flink]
via GitHub