Re: [PR] [FLINK-33171][table planner] Table SQL support Not Equal for TimePoint type and TimeString [flink]

fengjiajie commented on code in PR #23478: URL: https://github.com/apache/flink/pull/23478#discussion_r1359102193 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -488,6 +488,18 @@ object ScalarOperato

[jira] [Updated] (FLINK-31981) Enabling waiting on the Flink Application to complete before returning to Flink client for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31981: Fix Version/s: (was: 1.16.3) > Enabling waiting on the Flink Application to complete before returning

Re: [PR] [FLINK-33171][table planner] Table SQL support Not Equal for TimePoint type and TimeString [flink]

fengjiajie commented on code in PR #23478: URL: https://github.com/apache/flink/pull/23478#discussion_r1359102193 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -488,6 +488,18 @@ object ScalarOperato

Re: [PR] [FLINK-33255] [table] Validate argument count during type inference [flink]

bvarghese1 commented on code in PR #23520: URL: https://github.com/apache/flink/pull/23520#discussion_r1358960432 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandInference.java: ## @@ -62,11 +62,31 @@ public

Re: [PR] [FLINK-33255] [table] Validate argument count during type inference [flink]

bvarghese1 commented on code in PR #23520: URL: https://github.com/apache/flink/pull/23520#discussion_r1358960352 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeInferenceUtil.java: ## @@ -385,7 +385,7 @@ private static String formatArg

Re: [PR] [hotfix] Exclude http-only available Maven dependencies and include 1.18-SNAPSHOT in PR tests [flink-connector-hbase]

MartijnVisser merged PR #28: URL: https://github.com/apache/flink-connector-hbase/pull/28 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Created] (FLINK-33276) Reorganize CI stages

Matthias Pohl created FLINK-33276: - Summary: Reorganize CI stages Key: FLINK-33276 URL: https://issues.apache.org/jira/browse/FLINK-33276 Project: Flink Issue Type: Technical Debt C

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on PR #22985: URL: https://github.com/apache/flink/pull/22985#issuecomment-1761625553 @1996fanrui thanks for your review, I'm done addressing all your comments. I hope it's the last round of review. -- This is an automated message from the Apache Git Service. To respon

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1358346133 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -252,28 +257,96 @@ public void testTransitionToFinishedOnSuspend(

Re: [PR] [hotfix] Rely on org.apache.flink's surefire configuration [flink-connector-hbase]

MartijnVisser merged PR #29: URL: https://github.com/apache/flink-connector-hbase/pull/29 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1358336728 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -570,8 +659,9 @@ public void setHowToHandleFailure(Function funct

[jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED

[ https://issues.apache.org/jira/browse/FLINK-28074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-28074: Fix Version/s: 1.19.0 (was: 1.18.0) > show statistics details for DESCRIBE EXTENDED

[jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard

[ https://issues.apache.org/jira/browse/FLINK-23855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-23855: Fix Version/s: 1.19.0 (was: 1.18.0) > Table API & SQL Configuration Not displayed o

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29863: Fix Version/s: 1.19.0 (was: 1.18.0) > Properly handle NaN/Infinity in OpenAPI spec

[jira] [Created] (FLINK-33275) CLONE - Vote on the release candidate

Jing Ge created FLINK-33275: --- Summary: CLONE - Vote on the release candidate Key: FLINK-33275 URL: https://issues.apache.org/jira/browse/FLINK-33275 Project: Flink Issue Type: Sub-task Affects

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19659: Fix Version/s: 1.19.0 (was: 1.18.0) > Array type supports equals and not_equals ope

[jira] [Updated] (FLINK-32641) json format supports pojo type

[ https://issues.apache.org/jira/browse/FLINK-32641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32641: Fix Version/s: 1.19.0 (was: 1.18.0) > json format supports pojo type >

[jira] [Created] (FLINK-33273) CLONE - Stage source and binary releases on dist.apache.org

Jing Ge created FLINK-33273: --- Summary: CLONE - Stage source and binary releases on dist.apache.org Key: FLINK-33273 URL: https://issues.apache.org/jira/browse/FLINK-33273 Project: Flink Issue Type

[jira] [Updated] (FLINK-28650) Flink SQL Parsing bug for METADATA

[ https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-28650: Fix Version/s: 1.19.0 (was: 1.18.0) > Flink SQL Parsing bug for METADATA >

[jira] [Updated] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29330: Fix Version/s: 1.19.0 (was: 1.18.0) > Provide better logs of MiniCluster shutdown p

[jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24636: Fix Version/s: 1.19.0 (was: 1.18.0) > Move cluster deletion operation cache into Re

[jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-12273: Fix Version/s: 1.19.0 (was: 1.18.0) > The default value of CheckpointRetentionPolic

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1358281363 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,23 +157,74 @@ private void handleDeploymentFailure(ExecutionVert

[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries

[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19034: Fix Version/s: 1.19.0 (was: 1.18.0) > Remove deprecated StreamExecutionEnvironment#

[jira] [Updated] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32523: Fix Version/s: 1.19.0 (was: 1.18.0) (was: 1.17.2) > NotifyCh

[jira] [Updated] (FLINK-30292) Better support for conversion between DataType and TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30292: Fix Version/s: 1.19.0 (was: 1.18.0) > Better support for conversion between DataTyp

[jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing

[ https://issues.apache.org/jira/browse/FLINK-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19613: Fix Version/s: 1.19.0 (was: 1.18.0) > Create flink-connector-files-test-utils for f

[jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong

[ https://issues.apache.org/jira/browse/FLINK-21940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-21940: Fix Version/s: 1.19.0 (was: 1.18.0) > Rowtime/proctime should be obtained from getT

[jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-26664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26664: Fix Version/s: 1.19.0 (was: 1.18.0) > Improve Python exception messages to be more

[jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-20190: Fix Version/s: 1.19.0 (was: 1.18.0) > A New Window Trigger that can trigger window

[jira] [Updated] (FLINK-29368) Modify DESCRIBE statement docs for new syntax

[ https://issues.apache.org/jira/browse/FLINK-29368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29368: Fix Version/s: 1.19.0 (was: 1.18.0) > Modify DESCRIBE statement docs for new syntax

[jira] [Updated] (FLINK-29001) Migrate datadog reporter to v2 metric submission API

[ https://issues.apache.org/jira/browse/FLINK-29001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29001: Fix Version/s: 1.19.0 (was: 1.18.0) > Migrate datadog reporter to v2 metric submiss

[jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-22334: Fix Version/s: 1.19.0 (was: 1.18.0) > Fail to translate the hive-sql in STREAMING m

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1358306727 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,23 +157,74 @@ private void handleDeploymentFailure(ExecutionVert

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-21022: Fix Version/s: 1.19.0 (was: 1.11.7) (was: 1.18.0) > flink-co

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-14148: Fix Version/s: 1.19.0 (was: 1.18.0) > Investigate pushing predicate/projection to u

[jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs

[ https://issues.apache.org/jira/browse/FLINK-23942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-23942: Fix Version/s: 1.19.0 (was: 1.18.0) > Python documentation redirects to shared page

[jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names

[ https://issues.apache.org/jira/browse/FLINK-20518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-20518: Fix Version/s: 1.19.0 (was: 1.18.0) > WebUI should escape characters in metric name

[jira] [Updated] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29370: Fix Version/s: 1.19.0 (was: 1.18.0) (was: 1.16.3) > Protobuf

[jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down

[ https://issues.apache.org/jira/browse/FLINK-19819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19819: Fix Version/s: 1.19.0 (was: 1.18.0) > SourceReaderBase supports limit push down > -

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-14122: Fix Version/s: 1.19.0 (was: 1.18.0) > Extend State Processor API to read ListCheckp

[jira] [Updated] (FLINK-25244) Deprecate Java 8 support

[ https://issues.apache.org/jira/browse/FLINK-25244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25244: Fix Version/s: 1.19.0 (was: 1.18.0) > Deprecate Java 8 support > --

[jira] [Updated] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink

[ https://issues.apache.org/jira/browse/FLINK-30166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30166: Fix Version/s: 1.19.0 (was: 1.18.0) > Refactor tests that use the deprecated Stream

[jira] [Updated] (FLINK-30379) Decouple connector docs integration from connector releases

[ https://issues.apache.org/jira/browse/FLINK-30379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30379: Fix Version/s: 1.19.0 (was: 1.18.0) > Decouple connector docs integration from conn

[jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-27809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-27809: Fix Version/s: 1.19.0 (was: 1.18.0) > Clarify that cluster-id is mandatory for Kube

[jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24757: Fix Version/s: 1.19.0 (was: 1.18.0) > Yarn application is not terminated after the

[jira] [Updated] (FLINK-33271) CLONE - Build Release Candidate: 1.18.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-33271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33271: Description: The core of the release process is the build-vote-fix cycle. Each cycle produces one release

[jira] [Updated] (FLINK-12590) Replace http links in documentation

[ https://issues.apache.org/jira/browse/FLINK-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-12590: Fix Version/s: 1.19.0 (was: 1.18.0) > Replace http links in documentation > ---

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1358317366 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -67,13 +77,36 @@ class Executing extends StateWithExecutionGraph impl

[jira] [Updated] (FLINK-28929) Add built-in datediff function.

[ https://issues.apache.org/jira/browse/FLINK-28929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-28929: Fix Version/s: 1.19.0 (was: 1.18.0) > Add built-in datediff function. > ---

[jira] [Resolved] (FLINK-32921) Prepare Flink 1.18 Release

[ https://issues.apache.org/jira/browse/FLINK-32921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-32921. - Resolution: Fixed > Prepare Flink 1.18 Release > -- > > Key: FLI

[jira] [Updated] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite

[ https://issues.apache.org/jira/browse/FLINK-24192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24192: Fix Version/s: 1.19.0 (was: 1.18.0) > Sql get plan failed. All the inputs have rele

[jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-15860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-15860: Fix Version/s: 1.19.0 (was: 1.18.0) > Store temporary functions as CatalogFunctions

[jira] [Updated] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure

[ https://issues.apache.org/jira/browse/FLINK-24343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24343: Fix Version/s: 1.19.0 (was: 1.18.0) > Revisit Scheduler and Coordinator Startup Pro

Re: [PR] [FLINK-33171][table planner] Table SQL support Not Equal for TimePoint type and TimeString [flink]

lincoln-lil commented on code in PR #23478: URL: https://github.com/apache/flink/pull/23478#discussion_r1358298316 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -488,6 +488,18 @@ object ScalarOperat

[jira] [Created] (FLINK-33271) CLONE - Build Release Candidate: 1.18.0-rc2

Jing Ge created FLINK-33271: --- Summary: CLONE - Build Release Candidate: 1.18.0-rc2 Key: FLINK-33271 URL: https://issues.apache.org/jira/browse/FLINK-33271 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-27268) build sql query error in JdbcDynamicTableSource

[ https://issues.apache.org/jira/browse/FLINK-27268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-27268: Fix Version/s: 1.19.0 (was: 1.18.0) > build sql query error in JdbcDynamicTableSour

[jira] [Updated] (FLINK-30289) RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting

[ https://issues.apache.org/jira/browse/FLINK-30289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30289: Fix Version/s: 1.19.0 (was: 1.18.0) > RateLimitedSourceReader uses wrong signal for

[jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24951: Fix Version/s: 1.19.0 (was: 1.18.0) > Allow watch bookmarks to mitigate frequent wa

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-31116: Fix Version/s: 1.19.0 (was: 1.18.0) > Support taskmanager related parameters in ses

[jira] [Updated] (FLINK-32753) Print JVM flags on AZP

[ https://issues.apache.org/jira/browse/FLINK-32753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32753: Fix Version/s: 1.19.0 (was: 1.18.0) > Print JVM flags on AZP >

[jira] [Updated] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

[ https://issues.apache.org/jira/browse/FLINK-30613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30613: Fix Version/s: 1.19.0 (was: 1.18.0) > Improve resolving schema compatibility -- Mil

[jira] [Updated] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32488: Fix Version/s: 1.19.0 (was: 1.18.0) > Introduce configuration to control ExecutionG

[jira] [Updated] (FLINK-25419) Support the metadata column to generate dynamic index

[ https://issues.apache.org/jira/browse/FLINK-25419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25419: Fix Version/s: 1.19.0 (was: 1.18.0) > Support the metadata column to generate dynam

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1358300145 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,23 +157,74 @@ private void handleDeploymentFailure(ExecutionVert

[jira] [Updated] (FLINK-24901) Some further improvements of the pluggable shuffle framework

[ https://issues.apache.org/jira/browse/FLINK-24901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24901: Fix Version/s: 1.19.0 (was: 1.18.0) > Some further improvements of the pluggable sh

[jira] [Updated] (FLINK-31245) Adaptive scheduler does not reset the state of GlobalAggregateManager when rescaling

[ https://issues.apache.org/jira/browse/FLINK-31245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-31245: Fix Version/s: 1.19.0 (was: 1.18.0) > Adaptive scheduler does not reset the state o

[jira] [Resolved] (FLINK-33273) CLONE - Stage source and binary releases on dist.apache.org

[ https://issues.apache.org/jira/browse/FLINK-33273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33273. - Fix Version/s: 1.18.0 Resolution: Fixed > CLONE - Stage source and binary releases on dist.apache

[jira] [Assigned] (FLINK-33273) CLONE - Stage source and binary releases on dist.apache.org

[ https://issues.apache.org/jira/browse/FLINK-33273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33273: --- Assignee: Jing Ge > CLONE - Stage source and binary releases on dist.apache.org > -

[jira] [Resolved] (FLINK-33272) CLONE - Build and stage Java and Python artifacts

[ https://issues.apache.org/jira/browse/FLINK-33272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33272. - Fix Version/s: 1.18.0 Resolution: Fixed > CLONE - Build and stage Java and Python artifacts > ---

[jira] [Assigned] (FLINK-33272) CLONE - Build and stage Java and Python artifacts

[ https://issues.apache.org/jira/browse/FLINK-33272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33272: --- Assignee: Jing Ge > CLONE - Build and stage Java and Python artifacts > ---

[jira] [Assigned] (FLINK-32921) Prepare Flink 1.18 Release

[ https://issues.apache.org/jira/browse/FLINK-32921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-32921: --- Assignee: Jing Ge > Prepare Flink 1.18 Release > -- > > Key

[jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks

[ https://issues.apache.org/jira/browse/FLINK-24680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24680: Fix Version/s: 1.19.0 (was: 1.18.0) > Expose UserCodeClassLoader in OperatorCoordin

[jira] [Updated] (FLINK-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code

[ https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-29040: Fix Version/s: 1.19.0 (was: 1.18.0) > When using the JDBC Catalog, the custom canno

[jira] [Updated] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32444: Fix Version/s: 1.19.0 (was: 1.18.0) > Enable object reuse for Flink SQL jobs by def

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24122: Fix Version/s: 1.19.0 (was: 1.18.0) > Add support to do clean in history server > -

[jira] [Created] (FLINK-33272) CLONE - Build and stage Java and Python artifacts

Jing Ge created FLINK-33272: --- Summary: CLONE - Build and stage Java and Python artifacts Key: FLINK-33272 URL: https://issues.apache.org/jira/browse/FLINK-33272 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26761: Fix Version/s: 1.19.0 (was: 1.18.0) > Fix the cast exception thrown by PreValidateR

[jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-22826: Fix Version/s: 1.19.0 (was: 1.18.0) > flink sql1.13.1 causes data loss based on cha

[jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs

[ https://issues.apache.org/jira/browse/FLINK-20818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-20818: Fix Version/s: 1.19.0 (was: 1.18.0) > End to end test produce excessive amount of l

[jira] [Updated] (FLINK-26692) migrate TpcdsTestProgram.java to new source

[ https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26692: Fix Version/s: 1.19.0 (was: 1.18.0) > migrate TpcdsTestProgram.java to new source >

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-22607: Fix Version/s: 1.19.0 (was: 1.18.0) > Examples use deprecated AscendingTimestampExt

[jira] [Created] (FLINK-33274) CLONE - Propose a pull request for website updates

Jing Ge created FLINK-33274: --- Summary: CLONE - Propose a pull request for website updates Key: FLINK-33274 URL: https://issues.apache.org/jira/browse/FLINK-33274 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-14500: Fix Version/s: 1.19.0 (was: 1.18.0) > Support Flink Python User-Defined Stateless F

[jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-16531: Fix Version/s: 1.19.0 (was: 1.18.0) > Add full integration tests for "GROUPING SETS

[jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19038: Fix Version/s: 1.19.0 (was: 1.18.0) > It doesn't support to call Table.limit() cont

[jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners

[ https://issues.apache.org/jira/browse/FLINK-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19499: Fix Version/s: 1.19.0 (was: 1.18.0) > Expose Metric Groups to Split Assigners > ---

[jira] [Updated] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25205: Fix Version/s: 1.19.0 (was: 1.18.0) > Optimize SinkUpsertMaterializer > ---

Re: [PR] [DEBUG] Test misc things for HBase [flink-connector-hbase]

MartijnVisser closed pull request #28: [DEBUG] Test misc things for HBase URL: https://github.com/apache/flink-connector-hbase/pull/28 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific com

[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-17362: Fix Version/s: 1.19.0 (was: 1.18.0) > Improve table examples to reflect latest stat

[jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase

[ https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24048: Fix Version/s: 1.19.0 (was: 1.18.0) > Move changeLog inference out of optimizing ph

[jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-19362: Fix Version/s: 1.19.0 (was: 1.18.0) > Remove confusing comment for `DOT` operator c

[jira] [Updated] (FLINK-22484) Built-in functions for collections

[ https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-22484: Fix Version/s: 1.19.0 (was: 1.18.0) > Built-in functions for collections >

[jira] [Updated] (FLINK-24517) Streamline Flink releases

[ https://issues.apache.org/jira/browse/FLINK-24517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24517: Fix Version/s: 1.19.0 (was: 1.18.0) > Streamline Flink releases > -

[jira] [Updated] (FLINK-27432) Replace Time with Duration in TaskSlotTable

[ https://issues.apache.org/jira/browse/FLINK-27432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-27432: Fix Version/s: 1.19.0 (was: 1.18.0) > Replace Time with Duration in TaskSlotTable >

[jira] [Updated] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister

[ https://issues.apache.org/jira/browse/FLINK-25862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25862: Fix Version/s: 1.19.0 (was: 1.18.0) > Refactor SharedStateRegistry to not limit Str

[jira] [Updated] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-24179: Fix Version/s: 1.19.0 (was: 1.18.0) > KafkaSinkITCase.testRecoveryWithExactlyOnceGu

[jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft()

[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-15740: Fix Version/s: 1.19.0 (was: 1.18.0) > Remove Deadline#timeLeft() >

[jira] [Updated] (FLINK-32074) Support file merging across checkpoints

[ https://issues.apache.org/jira/browse/FLINK-32074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-32074: Fix Version/s: 1.19.0 (was: 1.18.0) > Support file merging across checkpoints > ---

[jira] [Updated] (FLINK-25900) Create view example does not assign alias to functions resulting in generated names like EXPR$5

[ https://issues.apache.org/jira/browse/FLINK-25900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25900: Fix Version/s: 1.19.0 (was: 1.18.0) > Create view example does not assign alias to

  1   2   3   4   5   6   >