[jira] [Updated] (FLINK-23170) Write metadata after materialization

2021-07-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23170: -- Description: Currently, changelog state backend writes state metadata on first state a

[GitHub] [flink] flinkbot edited a comment on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16434: URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346 ## CI report: * e1f1b3df1ae855ffd1be6dded31e24bdb0b1f9db Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * 2261906218ec3345b677703e3f79511436e5eac9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16349: URL: https://github.com/apache/flink/pull/16349#issuecomment-872790415 ## CI report: * 0d0cd1ddbc25b0f960ed0864c02a0bf21c0867c1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16063: URL: https://github.com/apache/flink/pull/16063#issuecomment-853640847 ## CI report: * a5833f1f9f82960dcc3d860ed324e4f1fe53a3e9 UNKNOWN * d46546abefb77e5f19dc7e16d5183741e30d35ed Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] zentol commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

2021-07-08 Thread GitBox
zentol commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r666709684 ## File path: flink-core/src/main/java/org/apache/flink/core/classloading/ComponentClassLoader.java ## @@ -0,0 +1,246 @@ +/* + * Licensed to the Apache So

[jira] [Comment Edited] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.

2021-07-08 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376949#comment-17376949 ] Roc Marshal edited comment on FLINK-22860 at 7/9/21, 6:37 AM:

[GitHub] [flink] rkhachatryan commented on pull request #16404: [FLINK-23277][state/changelog] Store and recover TTL metadata using changelog

2021-07-08 Thread GitBox
rkhachatryan commented on pull request #16404: URL: https://github.com/apache/flink/pull/16404#issuecomment-876951474 Thanks for looking into the failure. I think it's an already resolved in FLINK-23283. Let me rebase (and squash) and let's see whether the build passes. -- This is an

[GitHub] [flink] Myasuka commented on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

2021-07-08 Thread GitBox
Myasuka commented on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-876949258 @paul8263 Could you share what the UI would be if user clicked but flamegraph not enabled? -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] tsreaper commented on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

2021-07-08 Thread GitBox
tsreaper commented on pull request #16349: URL: https://github.com/apache/flink/pull/16349#issuecomment-876948373 @flinkbot run azure -- 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] [Commented] (FLINK-23262) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377844#comment-17377844 ] Xintong Song commented on FLINK-23262: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] AHeise commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

2021-07-08 Thread GitBox
AHeise commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r666701426 ## File path: flink-core/src/main/java/org/apache/flink/core/classloading/ComponentClassLoader.java ## @@ -0,0 +1,246 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] Myasuka commented on pull request #16404: [FLINK-23277][state/changelog] Store and recover TTL metadata using changelog

2021-07-08 Thread GitBox
Myasuka commented on pull request #16404: URL: https://github.com/apache/flink/pull/16404#issuecomment-876947076 I noticed that the CI failed due to `GroupWindowITCase.testWindowAggregateOnUpsertSource`, since currently PR is not allowed to be merged without success CI, could you check tha

[GitHub] [flink] flinkbot edited a comment on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * 2261906218ec3345b677703e3f79511436e5eac9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-07-08 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23074: --- Fix Version/s: 1.13.2 1.12.5 > There is a class conflict between flink-connector-hive and

[jira] [Assigned] (FLINK-23322) RMQSourceITCase.testStopWithSavepoint fails on azure due to timeout

2021-07-08 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-23322: --- Assignee: Fabian Paul > RMQSourceITCase.testStopWithSavepoint fails on azure due to timeout

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-08 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377835#comment-17377835 ] Ada Wong commented on FLINK-23324: -- [~Leonard Xu][~jark] > Postgres of JDBC Connector

[GitHub] [flink] paul8263 commented on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

2021-07-08 Thread GitBox
paul8263 commented on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-876936422 In the commit fd2bdde, if user accessed the flame graph tab with flame graph setting disabled, it would result in an exception which tells the user that flame graph is disabled

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-08 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377832#comment-17377832 ] Ada Wong commented on FLINK-23324: -- Please assign to me, thanks. > Postgres of JDBC Co

[jira] [Created] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-08 Thread Ada Wong (Jira)
Ada Wong created FLINK-23324: Summary: Postgres of JDBC Connector enable case-sensitive. Key: FLINK-23324 URL: https://issues.apache.org/jira/browse/FLINK-23324 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-872812232 ## CI report: * 6a7d378800616b57c9551b849a550ebb1716315f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23289) BinarySection should add null check in constructor method

2021-07-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377823#comment-17377823 ] Caizhi Weng commented on FLINK-23289: - I've added some description after discussing

[jira] [Updated] (FLINK-23289) BinarySection should add null check in constructor method

2021-07-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23289: Description: {{BinarySection}} currently does not check if {{MemorySegment[]}} is null in its con

[jira] [Comment Edited] (FLINK-23219) temproary join ttl configruation does not take effect

2021-07-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377821#comment-17377821 ] Caizhi Weng edited comment on FLINK-23219 at 7/9/21, 5:40 AM:

[jira] [Commented] (FLINK-23219) temproary join ttl configruation does not take effect

2021-07-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377821#comment-17377821 ] Caizhi Weng commented on FLINK-23219: - [~waywtdcc] If I'm not mistaken, it is possib

[jira] [Commented] (FLINK-23262) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377819#comment-17377819 ] Xintong Song commented on FLINK-23262: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23218) Distribute the ShuffleDescriptors via blob server

2021-07-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377811#comment-17377811 ] Zhu Zhu commented on FLINK-23218: - 1. To not affect existing users, I prefer limit to no

[GitHub] [flink] pnowojski commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-07-08 Thread GitBox
pnowojski commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r77997 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -312,6 +323,16 @@ BufferAndBac

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 4812b42d100c84091daf0841abff818eef20ada9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-872812232 ## CI report: * 6a7d378800616b57c9551b849a550ebb1716315f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-876475935 ## CI report: * 473db5d7954ebc197a64bb49d3b91d5c09d2c595 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16435: [FLINK-23184][table-runtime-blink] Fix compile error in code generation of unary plus and minus

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16435: URL: https://github.com/apache/flink/pull/16435#issuecomment-876899708 ## CI report: * 3032756fb594f7e8ca62c59c896b933542453659 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 4812b42d100c84091daf0841abff818eef20ada9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan edited a comment on pull request #16415: [FLINK-23262][tests] Check watermark frequency instead of count

2021-07-08 Thread GitBox
rkhachatryan edited a comment on pull request #16415: URL: https://github.com/apache/flink/pull/16415#issuecomment-876898158 Sorry, my bad, I should have apply the same change to record the start time. Now (with 499dfac) the test passed (also checked locally with 10k runs, with smaller `

[GitHub] [flink] rkhachatryan commented on pull request #16404: [FLINK-23277][state/changelog] Store and recover TTL metadata using changelog

2021-07-08 Thread GitBox
rkhachatryan commented on pull request #16404: URL: https://github.com/apache/flink/pull/16404#issuecomment-876908810 Thanks for the review @Myasuka, I've replied to your comments and updated the PR, please take a look. -- This is an automated message from the Apache Git Service. To re

[jira] [Assigned] (FLINK-23144) Add percentiles to checkpoint stats

2021-07-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-23144: - Assignee: Roman Khachatryan > Add percentiles to checkpoint stats > ---

[jira] [Commented] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

2021-07-08 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377791#comment-17377791 ] Guowei Ma commented on FLINK-23235: --- I thought about it again. In fact, we only need t

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 01b2bc58b30a2a3730895f7c50ff59099bd273d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-07-08 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377786#comment-17377786 ] Rui Li commented on FLINK-23074: Fixed in release-1.13: 8359fa8a9149392d964f52e7492b4dc2

[GitHub] [flink] lirui-apache closed pull request #16424: [FLINK-23074][connector-hive] Shade parquet class in hive-exec to prevent conflict.

2021-07-08 Thread GitBox
lirui-apache closed pull request #16424: URL: https://github.com/apache/flink/pull/16424 -- 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-un

[GitHub] [flink] lirui-apache closed pull request #16423: [FLINK-23074][connector-hive] Shade parquet class in hive-exec to prevent conflict.

2021-07-08 Thread GitBox
lirui-apache closed pull request #16423: URL: https://github.com/apache/flink/pull/16423 -- 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-un

[GitHub] [flink] flinkbot commented on pull request #16435: [FLINK-23184][table-runtime-blink] Fix compile error in code generation of unary plus and minus

2021-07-08 Thread GitBox
flinkbot commented on pull request #16435: URL: https://github.com/apache/flink/pull/16435#issuecomment-876899708 ## CI report: * 3032756fb594f7e8ca62c59c896b933542453659 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16434: URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346 ## CI report: * e1f1b3df1ae855ffd1be6dded31e24bdb0b1f9db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16420: [FLINK-23290][table-runtime] Fix NullPointerException when filter contains casting to boolean

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16420: URL: https://github.com/apache/flink/pull/16420#issuecomment-876213306 ## CI report: * cc63e6c45a73722102e26cf51e1b9c4b11554336 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16349: URL: https://github.com/apache/flink/pull/16349#issuecomment-872790415 ## CI report: * 0d0cd1ddbc25b0f960ed0864c02a0bf21c0867c1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan edited a comment on pull request #16415: [FLINK-23262][tests] Check watermark frequency instead of count

2021-07-08 Thread GitBox
rkhachatryan edited a comment on pull request #16415: URL: https://github.com/apache/flink/pull/16415#issuecomment-876898158 Sorry, my bad, I should have apply the same change to record the start time. Now (with 499dfac) the test passed (also checked locally with 10k runs). -- This is

[GitHub] [flink] rkhachatryan commented on pull request #16415: [FLINK-23262][tests] Check watermark frequency instead of count

2021-07-08 Thread GitBox
rkhachatryan commented on pull request #16415: URL: https://github.com/apache/flink/pull/16415#issuecomment-876898158 Sorry, my bad, I should have apply the same change to record the start time. Now the test passed (also checked locally with 10k runs). -- This is an automated message f

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 01b2bc58b30a2a3730895f7c50ff59099bd273d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wsry commented on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-07-08 Thread GitBox
wsry commented on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-876895192 @pnowojski I have rebased the latest master branch and appended a fixup commit which fixes the comments and enables 0 exclusive credit for unaligned checkpoint itcase. -- This i

[jira] [Updated] (FLINK-22672) Some enhancements for pluggable shuffle service framework

2021-07-08 Thread Jin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22672: - Description: "Pluggable shuffle service" in Flink provides an architecture which are unified for both s

[jira] [Updated] (FLINK-22672) Some enhancements for pluggable shuffle service framework

2021-07-08 Thread Jin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-22672: - Description: "Pluggable shuffle service" in Flink provides an architecture which are unified for both s

[GitHub] [flink] flinkbot edited a comment on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16434: URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346 ## CI report: * e1f1b3df1ae855ffd1be6dded31e24bdb0b1f9db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-876475935 ## CI report: * 473db5d7954ebc197a64bb49d3b91d5c09d2c595 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16420: [FLINK-23290][table-runtime] Fix NullPointerException when filter contains casting to boolean

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16420: URL: https://github.com/apache/flink/pull/16420#issuecomment-876213306 ## CI report: * cc63e6c45a73722102e26cf51e1b9c4b11554336 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16349: URL: https://github.com/apache/flink/pull/16349#issuecomment-872790415 ## CI report: * 0d0cd1ddbc25b0f960ed0864c02a0bf21c0867c1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16435: [FLINK-23184][table-runtime-blink] Fix compile error in code generation of unary plus and minus

2021-07-08 Thread GitBox
flinkbot commented on pull request #16435: URL: https://github.com/apache/flink/pull/16435#issuecomment-876890574 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Created] (FLINK-23323) HAQueryableStateRocksDBBackendITCase failed due to heap OOM

2021-07-08 Thread Xintong Song (Jira)
Xintong Song created FLINK-23323: Summary: HAQueryableStateRocksDBBackendITCase failed due to heap OOM Key: FLINK-23323 URL: https://issues.apache.org/jira/browse/FLINK-23323 Project: Flink

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377764#comment-17377764 ] Xintong Song commented on FLINK-23318: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23233) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377763#comment-17377763 ] Xintong Song commented on FLINK-23233: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] tsreaper opened a new pull request #16435: [FLINK-23184][table-runtime-blink] Fix compile error in code generation of unary plus and minus

2021-07-08 Thread GitBox
tsreaper opened a new pull request #16435: URL: https://github.com/apache/flink/pull/16435 (This commit is cherry-picked from #16406) ## What is the purpose of the change Currently code generation of unary plus and minus will not cast the result term to its desired type. This

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377760#comment-17377760 ] Xintong Song commented on FLINK-23318: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377762#comment-17377762 ] Xintong Song commented on FLINK-23318: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377761#comment-17377761 ] Xintong Song commented on FLINK-23318: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377758#comment-17377758 ] Xintong Song commented on FLINK-22085: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377755#comment-17377755 ] Xintong Song commented on FLINK-23318: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377756#comment-17377756 ] Xintong Song commented on FLINK-23318: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] gaoyunhaii commented on pull request #16385: [FLINK-23080][datastream] Introduce SinkFunction#finish() method.

2021-07-08 Thread GitBox
gaoyunhaii commented on pull request #16385: URL: https://github.com/apache/flink/pull/16385#issuecomment-876885109 No problem, I'll have 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 to

[jira] [Commented] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377753#comment-17377753 ] Xintong Song commented on FLINK-20431: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20431: - Labels: auto-unassigned pull-request-available test-stability (was: auto-deprioritized-critical

[GitHub] [flink] gaoyunhaii commented on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-876884430 Hi Till, very thanks for the review! I addressed the inline comments, and for another possible option I think it seems to might cause deadlock. -- This is an automated mes

[GitHub] [flink] cshuo commented on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
cshuo commented on pull request #16434: URL: https://github.com/apache/flink/pull/16434#issuecomment-876884044 cc @JingsongLi plz have 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 to the

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377750#comment-17377750 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r44562 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolderTest.java ## @@ -446,6 +525,27 @@ p

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377749#comment-17377749 ] Xintong Song commented on FLINK-22387: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r44248 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolderTest.java ## @@ -446,6 +525,27 @@ p

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377747#comment-17377747 ] Xintong Song commented on FLINK-22457: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot commented on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
flinkbot commented on pull request #16434: URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346 ## CI report: * e1f1b3df1ae855ffd1be6dded31e24bdb0b1f9db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-876475935 ## CI report: * fa6a87a6d47d79d400ef4964b168e8a767c8bad0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] cshuo commented on a change in pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
cshuo commented on a change in pull request #16434: URL: https://github.com/apache/flink/pull/16434#discussion_r40410 ## File path: flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/rank/FastTop1FunctionTest.java ## @@ -0,0 +1,181 @@ +/

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r40109 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolderTest.java ## @@ -370,6 +373,82 @@ p

[GitHub] [flink] flinkbot commented on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
flinkbot commented on pull request #16434: URL: https://github.com/apache/flink/pull/16434#issuecomment-876877559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-23107) Separate deduplicate rank from rank functions

2021-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23107: --- Labels: pull-request-available (was: ) > Separate deduplicate rank from rank functions > --

[GitHub] [flink] cshuo opened a new pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-08 Thread GitBox
cshuo opened a new pull request #16434: URL: https://github.com/apache/flink/pull/16434 …ank from other rank functions ## What is the purpose of the change Consider the following sql: ``` SELECT * FROM ( SELECT *, ROW_NUMBER() OVER (PARTITION BY d ORD

[jira] [Commented] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377734#comment-17377734 ] Caizhi Weng commented on FLINK-23318: - After binary searching through the commits I

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r38491 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolderTest.java ## @@ -370,6 +373,82 @@ p

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r37899 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/util/IncompleteFuturesTracker.java ## @@ -108,4 +94,22 @@ vo

[jira] [Commented] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

2021-07-08 Thread frank wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377733#comment-17377733 ] frank wang commented on FLINK-13400: hi [~lirui] maybe you can assign this to me >

[GitHub] [flink] tsreaper commented on a change in pull request #16420: [FLINK-23290][table-runtime] Fix NullPointerException when filter is a function call which returns null values

2021-07-08 Thread GitBox
tsreaper commented on a change in pull request #16420: URL: https://github.com/apache/flink/pull/16420#discussion_r36299 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala ## @@ -176,7 +184,15 @@ object G

[GitHub] [flink] flinkbot edited a comment on pull request #16415: [FLINK-23262][tests] Check watermark frequency instead of count

2021-07-08 Thread GitBox
flinkbot edited a comment on pull request #16415: URL: https://github.com/apache/flink/pull/16415#issuecomment-875773502 ## CI report: * 499dfac89e8c2411c75e14c407e46a1195a4ac60 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

2021-07-08 Thread Aiden Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377724#comment-17377724 ] Aiden Gong commented on FLINK-23237: [~hehuiyuan] ,You catch 'IOException' in your a

[GitHub] [flink] JingsongLi commented on a change in pull request #16420: [FLINK-23290][table-runtime] Fix NullPointerException when filter is a function call which returns null values

2021-07-08 Thread GitBox
JingsongLi commented on a change in pull request #16420: URL: https://github.com/apache/flink/pull/16420#discussion_r32299 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala ## @@ -176,7 +184,15 @@ object

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-08 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r32156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/util/NonSuccessFuturesTrack.java ## @@ -0,0 +1,86 @@ +/* + *

[jira] [Closed] (FLINK-22994) Improve the performance of nesting udf invoking

2021-07-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22994. Fix Version/s: 1.14.0 Resolution: Fixed Implements via: master: 31fcb6c22baaac1308a72559e3

[GitHub] [flink] JingsongLi merged pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-07-08 Thread GitBox
JingsongLi merged pull request #16163: URL: https://github.com/apache/flink/pull/16163 -- 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-unsu

[GitHub] [flink] JingsongLi commented on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-07-08 Thread GitBox
JingsongLi commented on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-876864094 I think this PR is ready to merge. Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

2021-07-08 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377712#comment-17377712 ] hehuiyuan commented on FLINK-23237: --- Hi [~Aiden Gong], it will failed  when set `ignor

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-07-08 Thread GitBox
wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r26886 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -312,6 +323,16 @@ BufferAndBacklog

[GitHub] [flink] hehuiyuan edited a comment on pull request #16394: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input in 1.12 version

2021-07-08 Thread GitBox
hehuiyuan edited a comment on pull request #16394: URL: https://github.com/apache/flink/pull/16394#issuecomment-875305823 Hi @wuchong , could you please 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

[GitHub] [flink] LongWangXX commented on pull request #16417: FLINK-22969

2021-07-08 Thread GitBox
LongWangXX commented on pull request #16417: URL: https://github.com/apache/flink/pull/16417#issuecomment-876861105 @luoyuxia Hello, can you help me merge the code into the master branch? Thank you -- This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Commented] (FLINK-23322) RMQSourceITCase.testStopWithSavepoint fails on azure due to timeout

2021-07-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377701#comment-17377701 ] Xintong Song commented on FLINK-23322: -- cc [~arvid] [~cmick] > RMQSourceITCase.tes

  1   2   3   4   5   >