[PR] update flink architecture url for text [Flinks's Architecture] [flink-web]

2024-03-11 Thread via GitHub
shashikumarec088 opened a new pull request, #724: URL: https://github.com/apache/flink-web/pull/724 updated the url which was not found before, i feel even this fix is not permanent as version 1.18 might change in the future -- This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825176#comment-17825176 ] Sergey Nuyanzin commented on FLINK-31663: - {quote} Since the behavior of array_u

[jira] [Comment Edited] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825176#comment-17825176 ] Sergey Nuyanzin edited comment on FLINK-31663 at 3/11/24 7:25 AM:

[jira] [Updated] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32483: -- Affects Version/s: 1.20.0 > RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedSta

Re: [PR] [FLINK-34571][test] Fix flaky test `SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError` [flink]

2024-03-11 Thread via GitHub
reswqa merged PR #24469: URL: https://github.com/apache/flink/pull/24469 -- 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-unsubscr...@flink.apache

Re: [PR] [FLINK-34571][test] Fix flaky test `SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError` [flink]

2024-03-11 Thread via GitHub
reswqa commented on PR #24469: URL: https://github.com/apache/flink/pull/24469#issuecomment-1987838887 Thanks for the quick review! -- 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 co

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825197#comment-17825197 ] Matthias Pohl commented on FLINK-34227: --- Same issue was observed for {{GroupWindow

[jira] [Commented] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825198#comment-17825198 ] Weijie Guo commented on FLINK-34571: master(1.20) via fcf61b9108942a892aa93765178a81

[PR] [BP-1.19][FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError [flink]

2024-03-11 Thread via GitHub
reswqa opened a new pull request, #24479: URL: https://github.com/apache/flink/pull/24479 Backport FLINK-34571 to release-1.19 branch. -- 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-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34571: --- Fix Version/s: 1.20.0 > SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError faile

[jira] [Comment Edited] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825198#comment-17825198 ] Weijie Guo edited comment on FLINK-34571 at 3/11/24 8:21 AM: -

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-03-11 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825202#comment-17825202 ] Ahmed Hamdy commented on FLINK-31472: - [~mapohl] Sorry I was out of office, Since I

Re: [PR] [BP-1.19][FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24479: URL: https://github.com/apache/flink/pull/24479#issuecomment-1987859634 ## CI report: * 7207cdb3f47f5470ce49c343b4b7c302a75ef1e7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Reopened] (FLINK-34629) Pulsar source lost topic subscribe

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-34629: --- Assignee: WangMinChao I re-opened that one in favor of FLINK-34627 because it appears to b

[jira] [Closed] (FLINK-34627) Pulsar source lost topic subscribe

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34627. - Resolution: Duplicate I'm closing this one as well in favor of the reopened duplicate FLINK-3462

Re: [PR] [FLINK-31472] Disable Intermittently failing throttling test [flink]

2024-03-11 Thread via GitHub
XComp closed pull request #24175: [FLINK-31472] Disable Intermittently failing throttling test URL: https://github.com/apache/flink/pull/24175 -- 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 spe

Re: [PR] [FLINK-31472] Disable Intermittently failing throttling test [flink]

2024-03-11 Thread via GitHub
XComp commented on PR #24175: URL: https://github.com/apache/flink/pull/24175#issuecomment-1987866921 According to [this comment in FLINK-31472](https://issues.apache.org/jira/browse/FLINK-31472?focusedCommentId=17825202&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#c

Re: [PR] [FLINK-34152][autoscaler] Refactor the MemoryTuning to avoid the huge method [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
1996fanrui commented on code in PR #795: URL: https://github.com/apache/flink-kubernetes-operator/pull/795#discussion_r1519353312 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/TuningSimpleMemorySpec.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-34152) Tune TaskManager memory

2024-03-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825218#comment-17825218 ] Rui Fan commented on FLINK-34152: - Merged to main(1.8.0) via: * 48692b7243086a2ccf2cb4c6

[jira] [Created] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

2024-03-11 Thread He Wang (Jira)
He Wang created FLINK-34639: --- Summary: Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector Key: FLINK-34639 URL: https://issues.apache.org/jira/browse/FLINK-34639 Project: Flink

Re: [PR] [FLINK-34632][runtime/checkpointing] Log checkpoint Id when logging delay [flink]

2024-03-11 Thread via GitHub
masteryhx closed pull request #24474: [FLINK-34632][runtime/checkpointing] Log checkpoint Id when logging delay URL: https://github.com/apache/flink/pull/24474 -- 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

[jira] [Closed] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

2024-03-11 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-34632. Fix Version/s: 1.20.0 Assignee: Mingliang Liu Resolution: Fixed merged 22309fdc in

Re: [PR] [hotfix] A couple of hotfixes related to e2e tests [flink]

2024-03-11 Thread via GitHub
pnowojski merged PR #24472: URL: https://github.com/apache/flink/pull/24472 -- 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-unsubscr...@flink.apa

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
xintongsong commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519286951 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "202

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
MartijnVisser commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519461611 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- Review Comment: @lincoln-lil I think we're missing something on the changes to t

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
Sxnan commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519464357 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-03-x

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825244#comment-17825244 ] Jacky Lau commented on FLINK-31663: --- [~Sergey Nuyanzin] in Flink, array_contains retur

Re: [PR] [FLINK-34543][datastream]Support Full Partition Processing On Non-keyed DataStream [flink]

2024-03-11 Thread via GitHub
reswqa commented on code in PR #24398: URL: https://github.com/apache/flink/pull/24398#discussion_r1519327670 ## flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/KeyedPartitionWindowedStreamITCase.java: ## @@ -0,0 +1,521 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825251#comment-17825251 ] Sergey Nuyanzin commented on FLINK-31663: - let's no mix everything in one place

[jira] [Comment Edited] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825251#comment-17825251 ] Sergey Nuyanzin edited comment on FLINK-31663 at 3/11/24 10:36 AM: ---

[jira] [Comment Edited] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825251#comment-17825251 ] Sergey Nuyanzin edited comment on FLINK-31663 at 3/11/24 10:41 AM: ---

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
JunRuiLee commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519522297 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
JunRuiLee commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519522297 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "2024-

[jira] [Created] (FLINK-34640) Replace DummyMetricGroup usage with UnregisteredMetricsGroup

2024-03-11 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34640: Summary: Replace DummyMetricGroup usage with UnregisteredMetricsGroup Key: FLINK-34640 URL: https://issues.apache.org/jira/browse/FLINK-34640 Project: Flink

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-11 Thread via GitHub
XComp commented on code in PR #24390: URL: https://github.com/apache/flink/pull/24390#discussion_r1519417563 ## flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/FileSystemOutputFormatTest.java: ## @@ -83,153 +103,175 @@ void after() {

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-11 Thread via GitHub
Zakelly commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1519549762 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java: ## @@ -31,55 +31,92 @@ */ @Internal

[jira] [Commented] (FLINK-31663) Add ARRAY_EXCEPT supported in SQL & Table API

2024-03-11 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825260#comment-17825260 ] Jacky Lau commented on FLINK-31663: --- [~Sergey Nuyanzin] ok. if the array_except and ar

[jira] [Commented] (FLINK-34588) FineGrainedSlotManager checks whether resources need to reconcile but doesn't act on the result

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825261#comment-17825261 ] Matthias Pohl commented on FLINK-34588: --- Ok, thanks for clarification. I might add

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
masteryhx commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519492535 ## docs/data/release_archive.yml: ## @@ -1,6 +1,10 @@ release_archive: flink: -- version_short: "1.18" +- version_short: "1.19" + version_long: 1.18.

[jira] [Created] (FLINK-34641) Possibility to add Python Files from http/https sources in PythonDriver

2024-03-11 Thread Aleksei Perminov (Jira)
Aleksei Perminov created FLINK-34641: Summary: Possibility to add Python Files from http/https sources in PythonDriver Key: FLINK-34641 URL: https://issues.apache.org/jira/browse/FLINK-34641 Proje

Re: [PR] [hotfix] Minor autoscaler event and metric improvements [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
gyfora merged PR #794: URL: https://github.com/apache/flink-kubernetes-operator/pull/794 -- 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-unsubscr

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-11 Thread via GitHub
masteryhx commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1519609456 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBProperty.java: ## @@ -31,55 +31,92 @@ */ @Internal

[jira] [Updated] (FLINK-27593) Parquet/Orc format reader optimization

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27593: Fix Version/s: 1.20.0 > Parquet/Orc format reader optimization > -

[jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29941: Fix Version/s: 1.20.0 > Support SQL Client connects to SQL Gateway > -

[jira] [Updated] (FLINK-29355) Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29355: Fix Version/s: 1.20.0 > Sql parse failed because of Desc catalog.database.table is incorrectly par

[jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22418: Fix Version/s: 1.20.0 > The currently activated tab in the same page isn't consistent > --

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

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19034: Fix Version/s: 1.20.0 > Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetri

[jira] [Updated] (FLINK-30959) Improve the documentation of UNIX_TIMESTAMP for different argument format

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30959: Fix Version/s: 1.20.0 > Improve the documentation of UNIX_TIMESTAMP for different argument format

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

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30292: Fix Version/s: 1.20.0 > Better support for conversion between DataType and TypeInformation > -

[jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19432: Fix Version/s: 1.20.0 > Whether to capture the updates which don't change any monitored columns >

[jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30970: Fix Version/s: 1.20.0 > Fix SQL Client doc still uses old style output > -

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17784: Fix Version/s: 1.20.0 > Better detection for parquet and orc in hive > ---

[jira] [Updated] (FLINK-26129) Using fail method instead of kill method when yarn application deployment error occures

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26129: Fix Version/s: 1.20.0 > Using fail method instead of kill method when yarn application deployment

[jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20853: Fix Version/s: 1.20.0 > Add reader schema null check for AvroDeserializationSchema when recordClaz

[jira] [Updated] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23860: Fix Version/s: 1.20.0 > Conversion to relational algebra failed to preserve datatypes > --

[jira] [Updated] (FLINK-25345) FLIP-196: Source API stability guarantees

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25345: Fix Version/s: 1.20.0 > FLIP-196: Source API stability guarantees > --

[jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17535: Fix Version/s: 1.20.0 > Treat min/max as part of the hierarchy of config option >

[jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24226: Fix Version/s: 1.20.0 > Improve error message when trying Presto S3 FS with recoverable writer > -

[jira] [Updated] (FLINK-31682) map_from_arrays should take whether allow duplicate keys and null key into consideration

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31682: Fix Version/s: 1.20.0 > map_from_arrays should take whether allow duplicate keys and null key into

[jira] [Updated] (FLINK-29646) SQL Gateway should return a simpler error message

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29646: Fix Version/s: 1.20.0 > SQL Gateway should return a simpler error message > --

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12692: Fix Version/s: 1.20.0 > Support disk spilling in HeapKeyedStateBackend > -

[jira] [Updated] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28901: Fix Version/s: 1.20.0 > CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with > TestTime

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15532: Fix Version/s: 1.20.0 > Enable strict capacity limit for memory usage for RocksDB > --

[jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32535: Fix Version/s: 1.20.0 > CheckpointingStatisticsHandler periodically returns NullArgumentException

[jira] [Updated] (FLINK-28097) Remove bundling of formats-common in json/csv format

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28097: Fix Version/s: 1.20.0 > Remove bundling of formats-common in json/csv format > ---

[jira] [Updated] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28398: Fix Version/s: 1.20.0 > CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExec

[jira] [Updated] (FLINK-22371) Chinese grammatical error

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22371: Fix Version/s: 1.20.0 > Chinese grammatical error > - > >

[jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25350: Fix Version/s: 1.20.0 > Verify stability guarantees of annotated classes > ---

[jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31267: Fix Version/s: 1.20.0 > Fine-Grained Resource Management supports table and sql levels > -

[jira] [Updated] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28104: Fix Version/s: 1.20.0 > Drop the unused order parameter in FirstValueFunction/LastValueFunction >

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20091: Fix Version/s: 1.20.0 > Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema >

[jira] [Updated] (FLINK-34315) Temporarily force disabling window join, window rank and window deduplicate optimization when using session window tvf

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34315: Fix Version/s: 1.20.0 > Temporarily force disabling window join, window rank and window deduplicat

[jira] [Updated] (FLINK-18981) Support column comment for Hive tables

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18981: Fix Version/s: 1.20.0 > Support column comment for Hive tables > -

[jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24094: Fix Version/s: 1.20.0 > Support DROP PARTITION by partial partition specification > --

[jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24376: Fix Version/s: 1.20.0 > Operator name in OperatorCoordinator should not use chained name > ---

[jira] [Updated] (FLINK-32607) Kafka table source and json format support projection pushdown

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32607: Fix Version/s: 1.20.0 > Kafka table source and json format support projection pushdown > -

[jira] [Updated] (FLINK-34264) Prometheuspushgateway's hosturl can use basicAuth certification login

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34264: Fix Version/s: 1.20.0 > Prometheuspushgateway's hosturl can use basicAuth certification login > --

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31249: Fix Version/s: 1.20.0 > Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck >

[jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20952: Fix Version/s: 1.20.0 > Changelog json formats should support inherit options from JSON format > -

[jira] [Updated] (FLINK-29656) Modify all join-related sql tests to make having statistics as the default choice

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29656: Fix Version/s: 1.20.0 > Modify all join-related sql tests to make having statistics as the default

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

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20190: Fix Version/s: 1.20.0 > A New Window Trigger that can trigger window operation both by event time

[jira] [Updated] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29459: Fix Version/s: 1.20.0 > Sink v2 has bugs in supporting legacy v1 implementations with global commi

[jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21613: Fix Version/s: 1.20.0 > Parse Compute Column with `IN` expression throws NPE > ---

[jira] [Updated] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28764: Fix Version/s: 1.20.0 > Support more than 64 distinct aggregate function calls in one aggregate SQ

[jira] [Updated] (FLINK-26951) Add HASH supported in SQL & Table API

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26951: Fix Version/s: 1.20.0 > Add HASH supported in SQL & Table API > --

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

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29863: Fix Version/s: 1.20.0 > Properly handle NaN/Infinity in OpenAPI spec > ---

[jira] [Updated] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28838: Fix Version/s: 1.20.0 > Avoid to notify the elementQueue consumer when the fetch result is empty >

[jira] [Updated] (FLINK-29723) Supports hive first_value function by native implementation

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29723: Fix Version/s: 1.20.0 > Supports hive first_value function by native implementation >

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27954: Fix Version/s: 1.20.0 > JobVertexFlameGraphHandler does not work on standby Dispatcher > -

[jira] [Updated] (FLINK-31691) Add MAP_FROM_ENTRIES supported in SQL & Table API

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31691: Fix Version/s: 1.20.0 > Add MAP_FROM_ENTRIES supported in SQL & Table API > --

[jira] [Updated] (FLINK-28830) new stack udtf doesn't support atomic type

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28830: Fix Version/s: 1.20.0 > new stack udtf doesn't support atomic type >

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-11937: Fix Version/s: 1.20.0 > Resolve small file problem in RocksDB incremental checkpoint > ---

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

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27268: Fix Version/s: 1.20.0 > build sql query error in JdbcDynamicTableSource >

[jira] [Updated] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29967: Fix Version/s: 1.20.0 > Optimize determinism requirements from sink node with considering that >

[jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27492: Fix Version/s: 1.20.0 > Flink table scala example does not including the scala-api jars >

[jira] [Updated] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20865: Fix Version/s: 1.20.0 > Prevent potential resource deadlock in fine-grained resource management >

[jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20154: Fix Version/s: 1.20.0 > Improve error messages when using CLI with wrong target >

[jira] [Updated] (FLINK-26831) Move JarHandlers to flink-runtime

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26831: Fix Version/s: 1.20.0 > Move JarHandlers to flink-runtime > - > >

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

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14148: Fix Version/s: 1.20.0 > Investigate pushing predicate/projection to underlying Hive input format >

[jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18567: Fix Version/s: 1.20.0 > Add Support for Azure Cognitive Search Table & SQL Connector > ---

  1   2   3   4   5   6   7   8   9   10   >