[jira] [Assigned] (FLINK-31640) Introduce segment index tracker

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31640: - Assignee: Yuxin Tan > Introduce segment index tracker > --- > >

[jira] [Assigned] (FLINK-31646) Introduce remote storage tier

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31646: - Assignee: Yuxin Tan > Introduce remote storage tier > - > >

[jira] [Assigned] (FLINK-31642) Introduce memory tier reader

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31642: - Assignee: Wencong Liu > Introduce memory tier reader > > >

[jira] [Assigned] (FLINK-31647) Introduce remote storage tier reader

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31647: - Assignee: Wencong Liu > Introduce remote storage tier reader >

[jira] [Assigned] (FLINK-31645) Introduce disk tier reader

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31645: - Assignee: Wencong Liu > Introduce disk tier reader > -- > >

[jira] [Assigned] (FLINK-31644) Introduce disk tier

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31644: - Assignee: Yuxin Tan > Introduce disk tier > --- > > Key: FLINK-

[jira] [Assigned] (FLINK-31641) Introduce memory tier

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31641: - Assignee: Yuxin Tan > Introduce memory tier > - > > Key: FL

[jira] [Updated] (FLINK-31637) Introduce buffer accumulator

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-31637: -- Summary: Introduce buffer accumulator (was: Introduce buffer accumulator tier) > Introduce buffer ac

[jira] [Assigned] (FLINK-31637) Introduce buffer accumulator

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31637: - Assignee: Yuxin Tan > Introduce buffer accumulator > > >

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

2023-04-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715604#comment-17715604 ] Jark Wu commented on FLINK-29692: - Hi [~charles-tan], yes, they have some differences. G

[jira] [Commented] (FLINK-31902) cast expr to type with not null should throw exception like calcite

2023-04-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715605#comment-17715605 ] jackylau commented on FLINK-31902: -- hi [~danny0405] [~snuyanzin]  please have a look >

[jira] [Updated] (FLINK-31902) cast expr to type with not null should throw exception like calcite

2023-04-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-31902: - Description: {code:java} // calcite cast type not null, will throw exception expr("cast(x as int ^not^

[jira] [Updated] (FLINK-31901) AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records

2023-04-23 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-31901: -- Description: Currently `BroadcastUtils#withBroadcast` tries to caches the non-broadcast input

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #234: [FLINK-31887] Upgrade Flink version of Flink ML to 1.16.1

2023-04-23 Thread via GitHub
lindong28 commented on code in PR #234: URL: https://github.com/apache/flink-ml/pull/234#discussion_r1174844283 ## flink-ml-iteration/src/test/java/org/apache/flink/iteration/operator/HeadOperatorTest.java: ## @@ -318,6 +322,10 @@ public void testPostponeGloballyAlignedEventsAf

[jira] [Created] (FLINK-31902) cast expr to type with not null should throw exception like calcite

2023-04-23 Thread jackylau (Jira)
jackylau created FLINK-31902: Summary: cast expr to type with not null should throw exception like calcite Key: FLINK-31902 URL: https://issues.apache.org/jira/browse/FLINK-31902 Project: Flink

[GitHub] [flink] TanYuxin-tyx commented on pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
TanYuxin-tyx commented on PR #22471: URL: https://github.com/apache/flink/pull/22471#issuecomment-1519482485 Thanks for helping review, @reswqa I have addressed the comments. Please take a look again, thanks. -- This is an automated message from the Apache Git Service. To respond to th

[jira] [Updated] (FLINK-31901) AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records

2023-04-23 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-31901: -- Description: Currently `BroadcastUtils#withBroadcast` tries to caches the non-broadcast input

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
TanYuxin-tyx commented on code in PR #22471: URL: https://github.com/apache/flink/pull/22471#discussion_r1174851201 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java: ## @@ -248,12 +251,30 @@ void testReq

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
TanYuxin-tyx commented on code in PR #22471: URL: https://github.com/apache/flink/pull/22471#discussion_r1174850914 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java: ## @@ -257,33 +251,56 @@ public void

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
TanYuxin-tyx commented on code in PR #22471: URL: https://github.com/apache/flink/pull/22471#discussion_r1174849327 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java: ## @@ -506,49 +525,49 @@ public void

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
TanYuxin-tyx commented on code in PR #22471: URL: https://github.com/apache/flink/pull/22471#discussion_r1174848926 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java: ## @@ -721,29 +740,34 @@ public void

[GitHub] [flink] xuzhiwen1255 commented on pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-04-23 Thread via GitHub
xuzhiwen1255 commented on PR #21971: URL: https://github.com/apache/flink/pull/21971#issuecomment-1519451823 @XComp If you have time, please come and have a look again, thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Created] (FLINK-31901) AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records

2023-04-23 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31901: - Summary: AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records Key: FLINK-31901 URL: https://issues.apache.org/jira/browse/FLINK-3

[GitHub] [flink-connector-jdbc] xuzhiwen1255 closed pull request #28: [hotfix] [doc] Fix the configuration item error of docs/content.zh/docs/connectors/table/jdbc.md

2023-04-23 Thread via GitHub
xuzhiwen1255 closed pull request #28: [hotfix] [doc] Fix the configuration item error of docs/content.zh/docs/connectors/table/jdbc.md URL: https://github.com/apache/flink-connector-jdbc/pull/28 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] reswqa commented on pull request #22424: [FLINK-31842][runtime] Calculate the utilization of the task executor only when it is using

2023-04-23 Thread via GitHub
reswqa commented on PR #22424: URL: https://github.com/apache/flink/pull/22424#issuecomment-1519447429 Thanks @huwh and @wanglijie95, Merged % CI. -- 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

[GitHub] [flink] reswqa commented on a diff in pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
reswqa commented on code in PR #22471: URL: https://github.com/apache/flink/pull/22471#discussion_r1174804263 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java: ## @@ -721,29 +740,34 @@ public void testCl

[GitHub] [flink] dianfu closed pull request #20821: [BK-1.15][FLINK-28972][python][connector/pulsar] Align source and sink class to java

2023-04-23 Thread via GitHub
dianfu closed pull request #20821: [BK-1.15][FLINK-28972][python][connector/pulsar] Align source and sink class to java URL: https://github.com/apache/flink/pull/20821 -- 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] dianfu commented on pull request #20821: [BK-1.15][FLINK-28972][python][connector/pulsar] Align source and sink class to java

2023-04-23 Thread via GitHub
dianfu commented on PR #20821: URL: https://github.com/apache/flink/pull/20821#issuecomment-1519428889 Closed as it should already been supported. -- 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

[GitHub] [flink] dianfu closed pull request #13164: [FLINK-18946][python] Support Cassandra connector for Python DataStream API.

2023-04-23 Thread via GitHub
dianfu closed pull request #13164: [FLINK-18946][python] Support Cassandra connector for Python DataStream API. URL: https://github.com/apache/flink/pull/13164 -- 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

[GitHub] [flink] dianfu commented on pull request #13164: [FLINK-18946][python] Support Cassandra connector for Python DataStream API.

2023-04-23 Thread via GitHub
dianfu commented on PR #13164: URL: https://github.com/apache/flink/pull/13164#issuecomment-1519424579 Closed as it should have already been supported. -- 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 g

[GitHub] [flink] dianfu closed pull request #15491: [FLINK-21966][python]Support Kinesis connector in Python DataStream API

2023-04-23 Thread via GitHub
dianfu closed pull request #15491: [FLINK-21966][python]Support Kinesis connector in Python DataStream API URL: https://github.com/apache/flink/pull/15491 -- 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 g

[GitHub] [flink] dianfu commented on pull request #15491: [FLINK-21966][python]Support Kinesis connector in Python DataStream API

2023-04-23 Thread via GitHub
dianfu commented on PR #15491: URL: https://github.com/apache/flink/pull/15491#issuecomment-1519423532 Closed as it should already been supported. -- 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] [Updated] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0

2023-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31899: --- Labels: pull-request-available (was: ) > Upgrade Flink version of Flink ML to 1.17.0 >

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #235: [FLINK-31899] Upgrade Flink version of Flink ML to 1.17.0

2023-04-23 Thread via GitHub
jiangxin369 opened a new pull request, #235: URL: https://github.com/apache/flink-ml/pull/235 ## What is the purpose of the change Upgrade Flink version of Flink ML to 1.17.0. ## Brief change log Upgrade Flink version of Flink ML to 1.17.0. The main changes about

[jira] [Commented] (FLINK-31831) TaskManagerDisconnectOnShutdownITCase.testTaskManagerProcessFailure is unstable

2023-04-23 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715582#comment-17715582 ] Lijie Wang commented on FLINK-31831: {code:java} 04:17:08,719 [ForkJoinPool-1-worker

[jira] [Comment Edited] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715575#comment-17715575 ] Kyungmin Kim edited comment on FLINK-31898 at 4/24/23 5:18 AM: ---

[jira] [Commented] (FLINK-31752) SourceOperatorStreamTask increments numRecordsOut twice

2023-04-23 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715581#comment-17715581 ] Dong Lin commented on FLINK-31752: -- Merged to apache/flink release-1.17 branch be13d05

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-23 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715580#comment-17715580 ] RocMarshal commented on FLINK-31757: I am still working on this jira, and due to the

[GitHub] [flink] flinkbot commented on pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
flinkbot commented on PR #22471: URL: https://github.com/apache/flink/pull/22471#issuecomment-1519379390 ## CI report: * 93c5b7bda3f005a13904629ef5747c9a41f74d13 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715575#comment-17715575 ] Kyungmin Kim commented on FLINK-31898: -- [~Zhanghao Chen]  Hi metric data I provide

[jira] [Updated] (FLINK-31897) Failing Unit Test: org.apache.flink.queryablestate.network.ClientTest.testRequestUnavailableHost

2023-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31897: --- Labels: pull-request-available (was: ) > Failing Unit Test: > org.apache.flink.queryablest

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-23 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22471: URL: https://github.com/apache/flink/pull/22471 ## What is the purpose of the change *Fix the unstable test ClientTest#testRequestUnavailableHost.* ## Brief change log - *Migrate ClientTest to JUnit5* - *F

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-44-17-479.png > Flink k8s autoscaler does not work as expected >

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-43-49-431.png > Flink k8s autoscaler does not work as expected >

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-42-40-124.png > Flink k8s autoscaler does not work as expected >

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-41-43-040.png > Flink k8s autoscaler does not work as expected >

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-31-06-420.png > Flink k8s autoscaler does not work as expected >

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-28-15-462.png > Flink k8s autoscaler does not work as expected >

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Attachment: image-2023-04-24-13-27-17-478.png > Flink k8s autoscaler does not work as expected >

[GitHub] [flink] XComp commented on pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-04-23 Thread via GitHub
XComp commented on PR #21736: URL: https://github.com/apache/flink/pull/21736#issuecomment-1519359797 Hi @gaoyunhaii , I'm wondering what the status of the PR is. I merged FLINK-31593 now which is causing the conflicts, I guess. Would it be possible to finalize this PR rather sooner than la

[jira] [Resolved] (FLINK-31593) Update reference data for Migration Tests

2023-04-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-31593. --- Fix Version/s: 1.18.0 1.17.1 Resolution: Fixed I kept the commits

[GitHub] [flink] huwh commented on pull request #22424: [FLINK-31842][runtime] Calculate the utilization of the task executor only when it is using

2023-04-23 Thread via GitHub
huwh commented on PR #22424: URL: https://github.com/apache/flink/pull/22424#issuecomment-1519353759 Thanks @wanglijie95 , This is a good suggestion, I have squash the previous fix-up commits and update this pr according to the suggestions. -- This is an automated mess

[GitHub] [flink] XComp merged pull request #22258: [BP-1.17][FLINK-31593][tests] Upgraded migration test data

2023-04-23 Thread via GitHub
XComp merged PR #22258: URL: https://github.com/apache/flink/pull/22258 -- 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] XComp merged pull request #22257: [FLINK-31593][tests] Upgraded migration test data

2023-04-23 Thread via GitHub
XComp merged PR #22257: URL: https://github.com/apache/flink/pull/22257 -- 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.

[jira] [Commented] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715565#comment-17715565 ] Zhanghao Chen commented on FLINK-31898: --- [~lufovic77] Could you provide more detai

[jira] [Closed] (FLINK-31799) Python connector download link should refer to the url defined in externalized repository

2023-04-23 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31799. -- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fixed mas

[GitHub] [flink] flinkbot commented on pull request #22469: [FLINK-31881][doc] Fix the format error in Flink official CEP chinese documentation

2023-04-23 Thread via GitHub
flinkbot commented on PR #22469: URL: https://github.com/apache/flink/pull/22469#issuecomment-1519326331 ## CI report: * 676c9ec3d784730702114ca158dbe57c070970d6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22470: [FLINK-31900] Fix some typo in java doc, comments and assertion message

2023-04-23 Thread via GitHub
flinkbot commented on PR #22470: URL: https://github.com/apache/flink/pull/22470#issuecomment-1519326421 ## CI report: * f0eae9538c784d4e04671320e38cc3399a1f1e45 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa merged pull request #22395: [FLINK-31799][docs] Python connector download link should refer to the url defined in externalized repository

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

[jira] [Updated] (FLINK-31900) Fix some typo in java doc, comments and assertion message

2023-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31900: --- Labels: pull-request-available (was: ) > Fix some typo in java doc, comments and assertion

[GitHub] [flink] zoltar9264 opened a new pull request, #22470: [FLINK-31900] Fix some typo in java doc, comments and assertion message

2023-04-23 Thread via GitHub
zoltar9264 opened a new pull request, #22470: URL: https://github.com/apache/flink/pull/22470 ## What is the purpose of the change Fix some typo in java doc, comments and assertion message ## Verifying this change This change is a trivial rework / code cleanup without any

[jira] [Updated] (FLINK-31881) The Chinese documentation page of Flink official CEP is experiencing confusion.

2023-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31881: --- Labels: pull-request-available (was: ) > The Chinese documentation page of Flink official C

[GitHub] [flink] WencongLiu opened a new pull request, #22469: [FLINK-31881][doc] Fix the format error in Flink official CEP chinese documentation

2023-04-23 Thread via GitHub
WencongLiu opened a new pull request, #22469: URL: https://github.com/apache/flink/pull/22469 ## What is the purpose of the change *This pull request is proposed to fix the the format error in Flink official CEP chinese documentation.* ## Brief change log - *Fix th

[jira] [Created] (FLINK-31900) Fix some typo in java doc, comments and assertion message

2023-04-23 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-31900: --- Summary: Fix some typo in java doc, comments and assertion message Key: FLINK-31900 URL: https://issues.apache.org/jira/browse/FLINK-31900 Project: Flink Issue

[jira] [Comment Edited] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME()

2023-04-23 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715562#comment-17715562 ] Bo Cui edited comment on FLINK-21714 at 4/24/23 3:03 AM: - [~leon

[jira] [Created] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0

2023-04-23 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-31899: - Summary: Upgrade Flink version of Flink ML to 1.17.0 Key: FLINK-31899 URL: https://issues.apache.org/jira/browse/FLINK-31899 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME()

2023-04-23 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715562#comment-17715562 ] Bo Cui commented on FLINK-21714: [~leonard] hi Have you tested the sql? val table = tEnv

[jira] [Updated] (FLINK-31887) Upgrade Flink version of Flink ML to 1.16.1

2023-04-23 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-31887: -- Fix Version/s: ml-2.3.0 > Upgrade Flink version of Flink ML to 1.16.1 > --

[GitHub] [flink-ml] jiangxin369 commented on pull request #234: [FLINK-31887] Upgrade Flink version of Flink ML to 1.16.1

2023-04-23 Thread via GitHub
jiangxin369 commented on PR #234: URL: https://github.com/apache/flink-ml/pull/234#issuecomment-1519307669 @lindong28 Could you have a look at this PR? -- 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 g

[GitHub] [flink] wanglijie95 commented on a diff in pull request #22424: [FLINK-31842][runtime] Calculate the utilization of the task executor only when it is using

2023-04-23 Thread via GitHub
wanglijie95 commented on code in PR #22424: URL: https://github.com/apache/flink/pull/22424#discussion_r1174715430 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultAllocatedSlotPool.java: ## @@ -218,11 +205,59 @@ public Collection getFreeSlotsInf

[jira] [Assigned] (FLINK-31897) Failing Unit Test: org.apache.flink.queryablestate.network.ClientTest.testRequestUnavailableHost

2023-04-23 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31897: -- Assignee: Yuxin Tan > Failing Unit Test: > org.apache.flink.queryablestate.network.ClientTes

[jira] [Assigned] (FLINK-31508) FLIP-304: Pluggable failure handling for Apache Flink

2023-04-23 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31508: -- Assignee: Panagiotis Garefalakis > FLIP-304: Pluggable failure handling for Apache Flink > --

[GitHub] [flink] reswqa merged pull request #22465: [BP-1.17][FLINK-31799][docs] Introduce py_connector_download_link shortcode for externalized connectors.

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

[jira] [Commented] (FLINK-31897) Failing Unit Test: org.apache.flink.queryablestate.network.ClientTest.testRequestUnavailableHost

2023-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715558#comment-17715558 ] Yuxin Tan commented on FLINK-31897: --- [~kurto] Thanks for reporting this, I'd like to t

[GitHub] [flink] reswqa merged pull request #22464: [BP-1.16][FLINK-31799] [docs] Introduce py_connector_download_link shortcode for externalized connectors.

2023-04-23 Thread via GitHub
reswqa merged PR #22464: URL: https://github.com/apache/flink/pull/22464 -- 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] flinkbot commented on pull request #22468: FLINK-31889: Add documentation for implementing/loading enrichers

2023-04-23 Thread via GitHub
flinkbot commented on PR #22468: URL: https://github.com/apache/flink/pull/22468#issuecomment-1519286076 ## CI report: * a0c85e227d20bcaaa791801f97ee809b44572446 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31889) Add documentation for implementing/loading enrichers

2023-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31889: --- Labels: pull-request-available (was: ) > Add documentation for implementing/loading enriche

[GitHub] [flink] pgaref opened a new pull request, #22468: FLINK-31889: Add documentation for implementing/loading enrichers

2023-04-23 Thread via GitHub
pgaref opened a new pull request, #22468: URL: https://github.com/apache/flink/pull/22468 [https://issues.apache.org/jira/browse/FLINK-31889](https://issues.apache.org/jira/browse/FLINK-31889) FailureEnrichers documentation -- This is an automated message from the Apache Git Servic

[jira] [Closed] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

2023-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31131. --- Fix Version/s: 1.18.0 Resolution: Fixed > The INITIALIZING of ExecutionState is missed in the state_m

[jira] [Comment Edited] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

2023-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715396#comment-17715396 ] Rui Fan edited comment on FLINK-31131 at 4/24/23 2:06 AM: -- Hi [

[GitHub] [flink] 1996fanrui merged pull request #22460: [FLINK-31131][doc]Backport to release-1.16

2023-04-23 Thread via GitHub
1996fanrui merged PR #22460: URL: https://github.com/apache/flink/pull/22460 -- 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

[GitHub] [flink] 1996fanrui merged pull request #22461: [FLINK-31131][doc]Backport to release-1.17

2023-04-23 Thread via GitHub
1996fanrui merged PR #22461: URL: https://github.com/apache/flink/pull/22461 -- 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] [Commented] (FLINK-31848) And Operator has side effect when operands have udf

2023-04-23 Thread zju_zsx (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715554#comment-17715554 ] zju_zsx commented on FLINK-31848: - [~csq] tks, you are right, this breaks three value lo

[GitHub] [flink] flinkbot commented on pull request #22467: FLINK-31888: Introduce interfaces and utils for loading and executing enrichers

2023-04-23 Thread via GitHub
flinkbot commented on PR #22467: URL: https://github.com/apache/flink/pull/22467#issuecomment-1519276709 ## CI report: * 96080a4365bdc1781e436baa59bc01749ff43e78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyungmin Kim updated FLINK-31898: - Description: Hi I'm using Flink k8s autoscaler to automatically deploy jobs in proper paralleli

[jira] [Updated] (FLINK-31888) Introduce interfaces and utils for loading and executing enrichers

2023-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31888: --- Labels: pull-request-available (was: ) > Introduce interfaces and utils for loading and exe

[jira] [Created] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-23 Thread Kyungmin Kim (Jira)
Kyungmin Kim created FLINK-31898: Summary: Flink k8s autoscaler does not work as expected Key: FLINK-31898 URL: https://issues.apache.org/jira/browse/FLINK-31898 Project: Flink Issue Type: Im

[GitHub] [flink] pgaref opened a new pull request, #22467: FLINK-31888: Introduce interfaces and utils for loading and executing enrichers

2023-04-23 Thread via GitHub
pgaref opened a new pull request, #22467: URL: https://github.com/apache/flink/pull/22467 [https://issues.apache.org/jira/browse/FLINK-31888](https://issues.apache.org/jira/browse/FLINK-31888) Introduce new Config and interfaces for FailureEnricher / Context as well as FailureEnr

[jira] [Created] (FLINK-31897) Failing Unit Test: org.apache.flink.queryablestate.network.ClientTest.testRequestUnavailableHost

2023-04-23 Thread Kurt Ostfeld (Jira)
Kurt Ostfeld created FLINK-31897: Summary: Failing Unit Test: org.apache.flink.queryablestate.network.ClientTest.testRequestUnavailableHost Key: FLINK-31897 URL: https://issues.apache.org/jira/browse/FLINK-31897

[GitHub] [flink-connector-pulsar] tisonkun commented on a diff in pull request #43: [FLINK-31748] Dummy implementation to fix compilation failure

2023-04-23 Thread via GitHub
tisonkun commented on code in PR #43: URL: https://github.com/apache/flink-connector-pulsar/pull/43#discussion_r1174672717 ## flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java: ## @@ -86,6 +86,11 @@ public void

[jira] [Created] (FLINK-31896) Extend web interface to support failure labels

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31896: -- Summary: Extend web interface to support failure labels Key: FLINK-31896 URL: https://issues.apache.org/jira/browse/FLINK-31896 Project: Flink

[jira] [Created] (FLINK-31895) End-to-end integration tests for failure labels

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31895: -- Summary: End-to-end integration tests for failure labels Key: FLINK-31895 URL: https://issues.apache.org/jira/browse/FLINK-31895 Project: Flink

[jira] [Created] (FLINK-31893) AdaptiveScheduler global failure handling

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31893: -- Summary: AdaptiveScheduler global failure handling Key: FLINK-31893 URL: https://issues.apache.org/jira/browse/FLINK-31893 Project: Flink

[jira] [Created] (FLINK-31894) ExceptionHistory and REST API failure label integration

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31894: -- Summary: ExceptionHistory and REST API failure label integration Key: FLINK-31894 URL: https://issues.apache.org/jira/browse/FLINK-31894 Project: F

[jira] [Created] (FLINK-31892) DefaultScheduler global failure handling

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31892: -- Summary: DefaultScheduler global failure handling Key: FLINK-31892 URL: https://issues.apache.org/jira/browse/FLINK-31892 Project: Flink

[jira] [Created] (FLINK-31890) JobMaster per-task failure labeling

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31890: -- Summary: JobMaster per-task failure labeling Key: FLINK-31890 URL: https://issues.apache.org/jira/browse/FLINK-31890 Project: Flink Issue

[jira] [Created] (FLINK-31891) JobMaster TM disconnect failure labeling

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31891: -- Summary: JobMaster TM disconnect failure labeling Key: FLINK-31891 URL: https://issues.apache.org/jira/browse/FLINK-31891 Project: Flink

[jira] [Created] (FLINK-31889) Add documentation for implementing/loading enrichers

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31889: -- Summary: Add documentation for implementing/loading enrichers Key: FLINK-31889 URL: https://issues.apache.org/jira/browse/FLINK-31889 Project: Flin

[jira] [Created] (FLINK-31888) Introduce interfaces and utils for loading and executing enrichers

2023-04-23 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-31888: -- Summary: Introduce interfaces and utils for loading and executing enrichers Key: FLINK-31888 URL: https://issues.apache.org/jira/browse/FLINK-31888

[GitHub] [flink] flinkbot commented on pull request #22466: [FLINK-30478] [core] Avoiding dependence on JDK-internal code

2023-04-23 Thread via GitHub
flinkbot commented on PR #22466: URL: https://github.com/apache/flink/pull/22466#issuecomment-1519127254 ## CI report: * 26a4c5fdc832e25c0ac4e808c7bb3399fc3da711 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   >