[jira] [Commented] (FLINK-32471) IS_NOT_NULL can add to SUITABLE_FILTER_TO_PUSH

2023-07-10 Thread grandfisher (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741482#comment-17741482 ] grandfisher commented on FLINK-32471: - Thanks, [~337361...@qq.com], We do have a bat

[GitHub] [flink] leonardBang commented on a diff in pull request #22937: [FLINK-32428][table] Introduce base interfaces for CatalogStore

2023-07-10 Thread via GitHub
leonardBang commented on code in PR #22937: URL: https://github.com/apache/flink/pull/22937#discussion_r1257836980 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogStore.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to the Apache Software Founda

[jira] [Closed] (FLINK-30789) Merge MultipleComponentsLeaderElectionDriver methods notifyAllKnownLeaderInformation and notifyLeaderInformationChange into a single method and

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30789. - Resolution: Won't Fix > Merge MultipleComponentsLeaderElectionDriver methods > notifyAllKnownLe

[jira] [Assigned] (FLINK-32405) Initialize catalog listener for CatalogManager

2023-07-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32405: -- Assignee: FangYong > Initialize catalog listener for CatalogManager > ---

[jira] [Assigned] (FLINK-32406) Notify catalog listener for database events

2023-07-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32406: -- Assignee: Fang Yong > Notify catalog listener for database events > -

[jira] [Assigned] (FLINK-32403) Add database related operations in catalog manager

2023-07-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32403: -- Assignee: Fang Yong > Add database related operations in catalog manager > --

[jira] [Assigned] (FLINK-32404) Introduce catalog modification listener and factory interfaces

2023-07-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32404: -- Assignee: FangYong > Introduce catalog modification listener and factory interfaces > ---

[jira] [Assigned] (FLINK-32407) Notify catalog listener for table events

2023-07-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32407: -- Assignee: Fang Yong > Notify catalog listener for table events >

[GitHub] [flink] yuchengxin commented on a diff in pull request #22767: [FLINK-31535][table] Extend watermark-related features for SQL

2023-07-10 Thread via GitHub
yuchengxin commented on code in PR #22767: URL: https://github.com/apache/flink/pull/22767#discussion_r1257910183 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/watermark/WatermarkEmitStrategy.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink] yuchengxin commented on a diff in pull request #22767: [FLINK-31535][table] Extend watermark-related features for SQL

2023-07-10 Thread via GitHub
yuchengxin commented on code in PR #22767: URL: https://github.com/apache/flink/pull/22767#discussion_r1257911008 ## docs/content/docs/dev/table/concepts/time_attributes.md: ## @@ -99,6 +99,105 @@ GROUP BY TUMBLE(time_ltz, INTERVAL '10' MINUTE); ``` + Advanced watermark

[GitHub] [flink] yuchengxin commented on a diff in pull request #22767: [FLINK-31535][table] Extend watermark-related features for SQL

2023-07-10 Thread via GitHub
yuchengxin commented on code in PR #22767: URL: https://github.com/apache/flink/pull/22767#discussion_r1257911307 ## docs/content/docs/dev/table/concepts/time_attributes.md: ## @@ -99,6 +99,105 @@ GROUP BY TUMBLE(time_ltz, INTERVAL '10' MINUTE); ``` + Advanced watermark

[GitHub] [flink] eskabetxe commented on a diff in pull request #22840: [FLINK-32376] Extend Sink#InitContext

2023-07-10 Thread via GitHub
eskabetxe commented on code in PR #22840: URL: https://github.com/apache/flink/pull/22840#discussion_r1257924502 ## flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/TestSinkInitContext.java: ## @@ -142,6 +144,21 @@ public Serializat

[GitHub] [flink] eskabetxe commented on a diff in pull request #22840: [FLINK-32376] Extend Sink#InitContext

2023-07-10 Thread via GitHub
eskabetxe commented on code in PR #22840: URL: https://github.com/apache/flink/pull/22840#discussion_r1257925161 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkTest.java: ## @@ -216,6 +218,21 @@ public OptionalLong getRestoredCheckpointId

[GitHub] [flink] XComp commented on a diff in pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

2023-07-10 Thread via GitHub
XComp commented on code in PR #22010: URL: https://github.com/apache/flink/pull/22010#discussion_r1257913768 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -189,8 +206,28 @@ public static SequenceGenera

[jira] [Created] (FLINK-32568) Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread Rui Fan (Jira)
Rui Fan created FLINK-32568: --- Summary: Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default Key: FLINK-32568 URL: https://issues.apache.org/jira/browse/FLINK-32568 Project: F

[GitHub] [flink] twalthr commented on a diff in pull request #22928: [FLINK-32473] Introduce base interfaces for time travel

2023-07-10 Thread via GitHub
twalthr commented on code in PR #22928: URL: https://github.com/apache/flink/pull/22928#discussion_r1257954899 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogTable.java: ## @@ -40,15 +40,27 @@ public class DefaultCatalogTable impleme

[GitHub] [flink] twalthr commented on a diff in pull request #22928: [FLINK-32473] Introduce base interfaces for time travel

2023-07-10 Thread via GitHub
twalthr commented on code in PR #22928: URL: https://github.com/apache/flink/pull/22928#discussion_r1257956237 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogTable.java: ## @@ -40,15 +40,27 @@ public class DefaultCatalogTable impleme

[GitHub] [flink] 1996fanrui opened a new pull request, #22974: [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread via GitHub
1996fanrui opened a new pull request, #22974: URL: https://github.com/apache/flink/pull/22974 ## What is the purpose of the change Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default ## Brief change log Remove the default `nzSortOrder` f

[jira] [Updated] (FLINK-32568) Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32568: --- Labels: pull-request-available (was: ) > Ensure that all subtasks are sorted by busy ratio

[GitHub] [flink] flinkbot commented on pull request #22974: [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread via GitHub
flinkbot commented on PR #22974: URL: https://github.com/apache/flink/pull/22974#issuecomment-1628565358 ## CI report: * 9f1de8f382cb6e7cc9c2e52b63e8728ebaa50e14 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32552) Mixed up Flink session job deployments

2023-07-10 Thread Fabio Wanner (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabio Wanner updated FLINK-32552: - Description: *Context* In the scope of end-to-end tests we deploy all the Flink session jobs we

[GitHub] [flink] TanYuxin-tyx commented on pull request #22960: [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers

2023-07-10 Thread via GitHub
TanYuxin-tyx commented on PR #22960: URL: https://github.com/apache/flink/pull/22960#issuecomment-1628584789 @xintongsong Thanks for helping review. Based on the offline discussions, I have updated the change. In the new PR, the above issues no longer exist anymore. PTAL, thanks. The

[GitHub] [flink] 1996fanrui commented on pull request #22974: [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread via GitHub
1996fanrui commented on PR #22974: URL: https://github.com/apache/flink/pull/22974#issuecomment-1628596068 Hi @WencongLiu , would you mind help take a look in your free time? thanks~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink] WencongLiu commented on pull request #22974: [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread via GitHub
WencongLiu commented on PR #22974: URL: https://github.com/apache/flink/pull/22974#issuecomment-1628605730 @1996fanrui OK, I'll take a look.😄 -- 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

[GitHub] [flink] 1996fanrui commented on pull request #22974: [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread via GitHub
1996fanrui commented on PR #22974: URL: https://github.com/apache/flink/pull/22974#issuecomment-1628651028 @WencongLiu , thanks for the quick review! I will merge it after the CI passes. -- This is an automated message from the Apache Git Service. To respond to the message, please l

[jira] [Created] (FLINK-32569) Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread Feng Jin (Jira)
Feng Jin created FLINK-32569: Summary: Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface Key: FLINK-32569 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Commented] (FLINK-32569) Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741533#comment-17741533 ] Feng Jin commented on FLINK-32569: -- [~luoyuxia] I would like to fix this issue, please

[jira] [Updated] (FLINK-32569) Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jin updated FLINK-32569: - Description: The newly added member variables in DefaultCatalogTable are not being serialized in Catalo

[GitHub] [flink] luoyuxia commented on a diff in pull request #22928: [FLINK-32473] Introduce base interfaces for time travel

2023-07-10 Thread via GitHub
luoyuxia commented on code in PR #22928: URL: https://github.com/apache/flink/pull/22928#discussion_r1258040684 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogTable.java: ## @@ -40,15 +40,27 @@ public class DefaultCatalogTable implem

[jira] [Assigned] (FLINK-32569) Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32569: Assignee: Feng Jin > Fix the incomplete serialization of ResolvedCatalogTable caused by the newly

[jira] [Resolved] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-4198. -- Resolution: Duplicate I'm gonna close this issue as a duplicate of FLINK-14068 because we go on

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
zentol commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258095765 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] reswqa merged pull request #22963: [hotfix][streaming] Fix typo in DataStream.java and DataStream.scala.

2023-07-10 Thread via GitHub
reswqa merged PR #22963: URL: https://github.com/apache/flink/pull/22963 -- 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

[GitHub] [flink-connector-kafka] chucheng92 commented on pull request #38: [FLINK-32522][connectors/kafka] Kafka connector should depend on commons-collections instead of inherit from flink

2023-07-10 Thread via GitHub
chucheng92 commented on PR #38: URL: https://github.com/apache/flink-connector-kafka/pull/38#issuecomment-1628796627 @MartijnVisser hi, Martijn. Can you help to review it? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink-connector-hbase] ferenc-csaky commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
ferenc-csaky commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258130085 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apac

[GitHub] [flink-connector-hbase] ferenc-csaky commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
ferenc-csaky commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258130085 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apac

[GitHub] [flink] xintongsong commented on a diff in pull request #22960: [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers

2023-07-10 Thread via GitHub
xintongsong commented on code in PR #22960: URL: https://github.com/apache/flink/pull/22960#discussion_r1258144552 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java: ## @@ -276,6 +294,13 @@ priv

[GitHub] [flink] lincoln-lil merged pull request #22972: [FLINK-32457][table-planner] Add test cases of unsupported usage for JSON_OBJECTAGG & JSON_ARRAYAGG and also update docs

2023-07-10 Thread via GitHub
lincoln-lil merged PR #22972: URL: https://github.com/apache/flink/pull/22972 -- 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.a

[jira] [Updated] (FLINK-32457) update current documentation of JSON_OBJECTAGG/JSON_ARRAYAGG to clarify the limitation

2023-07-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32457: Fix Version/s: 1.17.2 > update current documentation of JSON_OBJECTAGG/JSON_ARRAYAGG to clarify th

[jira] [Resolved] (FLINK-32457) update current documentation of JSON_OBJECTAGG/JSON_ARRAYAGG to clarify the limitation

2023-07-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee resolved FLINK-32457. - Resolution: Fixed fixed in master: b4faca57038897230372458d10d14f09c2f33d4d > update current do

[jira] [Commented] (FLINK-24024) Support session Window TVF

2023-07-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741591#comment-17741591 ] Sergey Nuyanzin commented on FLINK-24024: - Thanks for the response [~jingzhang]

[jira] [Assigned] (FLINK-24024) Support session Window TVF

2023-07-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-24024: --- Assignee: Sergey Nuyanzin (was: Jing Zhang) > Support session Window TVF > --

[GitHub] [flink] wanglijie95 closed pull request #22840: [FLINK-32376] Extend Sink#InitContext

2023-07-10 Thread via GitHub
wanglijie95 closed pull request #22840: [FLINK-32376] Extend Sink#InitContext URL: https://github.com/apache/flink/pull/22840 -- 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

[jira] [Commented] (FLINK-32376) [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID

2023-07-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741596#comment-17741596 ] Lijie Wang commented on FLINK-32376: Done via: master(1.18): 4f5b2fb5736f5a1c098a7dc

[jira] [Assigned] (FLINK-32376) [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID

2023-07-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-32376: -- Assignee: João Boto > [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReus

[jira] [Closed] (FLINK-32376) [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID

2023-07-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-32376. -- Resolution: Done > [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and > Job

[jira] [Updated] (FLINK-32376) [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID

2023-07-10 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-32376: --- Fix Version/s: 1.18.0 > [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and

[GitHub] [flink] luoyuxia commented on a diff in pull request #22839: [FLINK-32349][table] Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-07-10 Thread via GitHub
luoyuxia commented on code in PR #22839: URL: https://github.com/apache/flink/pull/22839#discussion_r1258138669 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -849,6 +858,56 @@ private ModifyOperation getOp

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22960: [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers

2023-07-10 Thread via GitHub
TanYuxin-tyx commented on code in PR #22960: URL: https://github.com/apache/flink/pull/22960#discussion_r1258205255 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java: ## @@ -200,6 +202,22 @@ pub

[jira] [Resolved] (FLINK-26522) FLIP-285: Refactoring code for multiple component leader election

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26522. --- Fix Version/s: 1.18.0 Resolution: Fixed > FLIP-285: Refactoring code for multiple com

[jira] [Resolved] (FLINK-32556) Renames contenderID into componentId

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-32556. --- Fix Version/s: 1.18.0 Resolution: Fixed master: 773feebbb2426ab1a8f7684f59b9a73db8f6a

[GitHub] [flink] WencongLiu opened a new pull request, #22975: [FLINK-31643][network] Introduce the configurations for tiered storage

2023-07-10 Thread via GitHub
WencongLiu opened a new pull request, #22975: URL: https://github.com/apache/flink/pull/22975 ## What is the purpose of the change *Introduce the configurations for tiered storage* ## Brief change log - *Introduce the configurations for tiered storage.*

[GitHub] [flink] flinkbot commented on pull request #22975: [FLINK-31643][network] Introduce the configurations for tiered storage

2023-07-10 Thread via GitHub
flinkbot commented on PR #22975: URL: https://github.com/apache/flink/pull/22975#issuecomment-1628902190 ## CI report: * 3c34fdf736b934951415b6282ee7cbb69f205e4f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
zentol commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258227391 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #620: [FLINK-32317] Enrich metadata in CR error field

2023-07-10 Thread via GitHub
gyfora commented on code in PR #620: URL: https://github.com/apache/flink-kubernetes-operator/pull/620#discussion_r1258231715 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java: ## @@ -129,26 +144,56 @@ public

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #625: [FLINK-32529] Add startup probe for JM deployment

2023-07-10 Thread via GitHub
gyfora commented on code in PR #625: URL: https://github.com/apache/flink-kubernetes-operator/pull/625#discussion_r1258236992 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkUtilsTest.java: ## @@ -86,6 +89,43 @@ public void testMergePo

[jira] [Assigned] (FLINK-32527) Build failure on Windows

2023-07-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32527: -- Assignee: Fangbin Sun > Build failure on Windows > > >

[GitHub] [flink-connector-hbase] ferenc-csaky commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
ferenc-csaky commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258295870 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apac

[jira] [Created] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

2023-07-10 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32570: - Summary: Deprecate API that uses Flink's Time implementation (related to FLINK-14638) Key: FLINK-32570 URL: https://issues.apache.org/jira/browse/FLINK-32570 Projec

[jira] [Updated] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32570: -- Fix Version/s: 1.18.0 > Deprecate API that uses Flink's Time implementation (related to FLINK-

[jira] [Updated] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32570: -- Priority: Blocker (was: Major) > Deprecate API that uses Flink's Time implementation (related

[GitHub] [flink] lincoln-lil opened a new pull request, #22976: [FLINK-32457][table-planner] Add test cases of unsupported usage for JSON_OBJECTAGG & JSON_ARRAYAGG and also update docs

2023-07-10 Thread via GitHub
lincoln-lil opened a new pull request, #22976: URL: https://github.com/apache/flink/pull/22976 This is a backport pr of FLINK-32457's subtask-1 -- 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

[GitHub] [flink] flinkbot commented on pull request #22976: [FLINK-32457][table-planner] Add test cases of unsupported usage for JSON_OBJECTAGG & JSON_ARRAYAGG and also update docs

2023-07-10 Thread via GitHub
flinkbot commented on PR #22976: URL: https://github.com/apache/flink/pull/22976#issuecomment-1629072311 ## CI report: * b0f1e65c995771dd3a5b8028b07e6175b9731b7a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2023-07-10 Thread Vladislav Keda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Keda updated FLINK-32513: --- Attachment: image-2023-07-10-17-23-30-472.png > Job in BATCH mode with a significant number

[jira] [Updated] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2023-07-10 Thread Vladislav Keda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Keda updated FLINK-32513: --- Attachment: image-2023-07-10-17-26-46-544.png > Job in BATCH mode with a significant number

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2023-07-10 Thread Vladislav Keda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741639#comment-17741639 ] Vladislav Keda commented on FLINK-32513: Hi [~huwh] , this job is automatically

[jira] [Resolved] (FLINK-29319) Upgrade Calcite version to 1.32

2023-07-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-29319. - Fix Version/s: 1.18.0 Resolution: Fixed > Upgrade Calcite version to 1.32 > -

[jira] [Commented] (FLINK-29319) Upgrade Calcite version to 1.32

2023-07-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741641#comment-17741641 ] Sergey Nuyanzin commented on FLINK-29319: - Merged to master [c942d0f61a044a327f

[jira] [Closed] (FLINK-29319) Upgrade Calcite version to 1.32

2023-07-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-29319. --- > Upgrade Calcite version to 1.32 > --- > > Key: FLI

[jira] [Updated] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2023-07-10 Thread Vladislav Keda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Keda updated FLINK-32513: --- Attachment: (was: image-2023-07-10-17-23-30-472.png) > Job in BATCH mode with a signific

[GitHub] [flink] 1996fanrui merged pull request #22974: [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread via GitHub
1996fanrui merged PR #22974: URL: https://github.com/apache/flink/pull/22974 -- 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.ap

[jira] [Resolved] (FLINK-32568) Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32568. - Fix Version/s: 1.18.0 Resolution: Fixed > Ensure that all subtasks are sorted by busy ratio at th

[jira] [Commented] (FLINK-32568) Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default

2023-07-10 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741645#comment-17741645 ] Rui Fan commented on FLINK-32568: - Merged via 2a6e8ae (master, 1.18) > Ensure that all

[jira] [Commented] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

2023-07-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741648#comment-17741648 ] Matthias Pohl commented on FLINK-32570: --- [~chesnay] any objections against me pick

[GitHub] [flink] hackergin opened a new pull request, #22977: [FLINK-32569][table] Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread via GitHub
hackergin opened a new pull request, #22977: URL: https://github.com/apache/flink/pull/22977 ## What is the purpose of the change Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface In order to implement time

[jira] [Updated] (FLINK-32569) Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32569: --- Labels: pull-request-available (was: ) > Fix the incomplete serialization of ResolvedCatalo

[jira] [Commented] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

2023-07-10 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662 ] Alexis Sarda-Espinosa commented on FLINK-32241: --- [I am seeing this same is

[GitHub] [flink] flinkbot commented on pull request #22977: [FLINK-32569][table] Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface

2023-07-10 Thread via GitHub
flinkbot commented on PR #22977: URL: https://github.com/apache/flink/pull/22977#issuecomment-1629183506 ## CI report: * aef7c958ecd9aae5df4609d71491af2737271422 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

2023-07-10 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662 ] Alexis Sarda-Espinosa edited comment on FLINK-32241 at 7/10/23 3:27 PM: --

[GitHub] [flink] swuferhong opened a new pull request, #22978: [FLINK-32456][table-planner] Support JSON_OBJECTAGG & JSON_ARRAYAGG use with other aggregate functions

2023-07-10 Thread via GitHub
swuferhong opened a new pull request, #22978: URL: https://github.com/apache/flink/pull/22978 ## What is the purpose of the change This pr is aims to support JSON_OBJECTAGG & JSON_ARRAYAGG use with other aggregate functions. ## Brief change log - Modify WrapJsonAggFu

[jira] [Updated] (FLINK-32456) JSON_OBJECTAGG & JSON_ARRAYAGG cannot be used with other aggregate functions

2023-07-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32456: --- Labels: pull-request-available (was: ) > JSON_OBJECTAGG & JSON_ARRAYAGG cannot be used with

[GitHub] [flink] swuferhong commented on pull request #22978: [FLINK-32456][table-planner] Support JSON_OBJECTAGG & JSON_ARRAYAGG use with other aggregate functions

2023-07-10 Thread via GitHub
swuferhong commented on PR #22978: URL: https://github.com/apache/flink/pull/22978#issuecomment-1629205639 Hi, @lincoln-lil. Can you help review this PR? Thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #22978: [FLINK-32456][table-planner] Support JSON_OBJECTAGG & JSON_ARRAYAGG use with other aggregate functions

2023-07-10 Thread via GitHub
flinkbot commented on PR #22978: URL: https://github.com/apache/flink/pull/22978#issuecomment-1629218303 ## CI report: * 111317089a49e9ca34f6540e1e9f586d20caae66 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

2023-07-10 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662 ] Alexis Sarda-Espinosa edited comment on FLINK-32241 at 7/10/23 3:45 PM: --

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
zentol commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258479693 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Sof

[jira] [Closed] (FLINK-30349) Sync missing HBase e2e tests to external repo

2023-07-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30349. Fix Version/s: hbase-3.0.0 Resolution: Fixed main: 8fda39b1e81f63c3db1be2295fb3efee

[jira] [Created] (FLINK-32571) Prebuild HBase testing docker image

2023-07-10 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32571: Summary: Prebuild HBase testing docker image Key: FLINK-32571 URL: https://issues.apache.org/jira/browse/FLINK-32571 Project: Flink Issue Type: Techn

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
zentol commented on code in PR #12: URL: https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258481903 ## flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink-connector-hbase] zentol closed pull request #5: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-07-10 Thread via GitHub
zentol closed pull request #5: [FLINK-30349] Sync missing HBase e2e tests to external repo URL: https://github.com/apache/flink-connector-hbase/pull/5 -- 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

[jira] [Commented] (FLINK-32571) Prebuild HBase testing docker image

2023-07-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741675#comment-17741675 ] Chesnay Schepler commented on FLINK-32571: -- ??the only parameter is the HBase v

[jira] [Commented] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

2023-07-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741693#comment-17741693 ] Chesnay Schepler commented on FLINK-32570: -- Go ahead. > Deprecate API that use

[GitHub] [flink] twalthr closed pull request #22892: [FLINK-32466] Replace STRING with CHARACTER for functions that don't support binary strings

2023-07-10 Thread via GitHub
twalthr closed pull request #22892: [FLINK-32466] Replace STRING with CHARACTER for functions that don't support binary strings URL: https://github.com/apache/flink/pull/22892 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Closed] (FLINK-32466) Invalid input strategy for many functions which allows BINARY strings

2023-07-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-32466. Fix Version/s: 1.18.0 Resolution: Fixed Merged to master: 4cf2124d71a8dd0595e40f07c2dbcc4c8

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #627: [FLINK-32551] Add option to take a savepoint on flinkdeployment/flinksessionjob deletion

2023-07-10 Thread via GitHub
gyfora commented on PR #627: URL: https://github.com/apache/flink-kubernetes-operator/pull/627#issuecomment-1629582915 ``` mvn clean install -DskipTests -Pgenerate-docs ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Closed] (FLINK-32527) Build failure on Windows

2023-07-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32527. -- Resolution: Fixed merged to main f21426201842b5df3c9a4f13ce41973d2ae67430 > Build failure on Windows

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #625: [FLINK-32529] Add startup probe for JM deployment

2023-07-10 Thread via GitHub
gyfora merged PR #625: URL: https://github.com/apache/flink-kubernetes-operator/pull/625 -- 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

[jira] [Closed] (FLINK-32529) Optional startup probe for JM deployment

2023-07-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32529. -- Resolution: Fixed merged to main 5ebfc5e4a6c31ea0c212f187bf7f7de70dfd1c09 > Optional startup probe fo

[jira] [Commented] (FLINK-30349) Sync missing HBase e2e tests to external repo

2023-07-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741748#comment-17741748 ] Martijn Visser commented on FLINK-30349: [~ferenc-csaky] [~chesnay] For my info,

[jira] [Created] (FLINK-32572) Do not collect metrics or scale finished job vertices

2023-07-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-32572: -- Summary: Do not collect metrics or scale finished job vertices Key: FLINK-32572 URL: https://issues.apache.org/jira/browse/FLINK-32572 Project: Flink Issue Type:

[GitHub] [flink] hanyuzheng7 commented on pull request #22842: [FLINK-32261][table] Add built-in MAP_UNION function.

2023-07-10 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1629714547 @snuyanzin support support varargs now -- 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

  1   2   >