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

[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

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 @@

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

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:

[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

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

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

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:

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

[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

[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

[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

[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

[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

[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

[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

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

[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

[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) >

[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

[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

[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

[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

[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

[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

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

[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) >

[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

[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

[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

[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) >

[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

[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

[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

[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

[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

[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

[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:

[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

[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

[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

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

[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

[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

[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

[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

[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 --

[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

[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

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

[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

[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

[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

[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 > -- > >

[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

[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

[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

[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

[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

[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

[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

[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:

[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

[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

[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()

[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

[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

[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

[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

[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

[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) >

[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   >