[jira] [Closed] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

2021-05-17 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-22637. Resolution: Duplicate No, you are right. I don't know what I mixed up when double-checking the inclusion

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input nod

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

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345919#comment-17345919 ] Piotr Nowojski commented on FLINK-22284: I meant {{request}} from a couple of li

[GitHub] [flink] flinkbot edited a comment on pull request #15897: [FLINK-22638] Keep channels blocked on alignment timeout

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15897: URL: https://github.com/apache/flink/pull/15897#issuecomment-838767418 ## CI report: * 659023b1937b4e105dde32fb772c6b771b597ee6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * 9fcb8001b9956441051aa1800cdc2df052f7a2c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * 98e2ad667f5990ce96f7421ca6077ead095354d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15928: [FLINK-22651][python][table-planner-blink] Support StreamExecPythonGroupAggregate json serialization/deserialization

2021-05-17 Thread GitBox
flinkbot commented on pull request #15928: URL: https://github.com/apache/flink/pull/15928#issuecomment-842073143 ## CI report: * dbf4810554bf5641ad6a2b36d55c079fb97455e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] wangwei1025 opened a new pull request #15929: [FLINK-15390][Connectors/ORC]List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread GitBox
wangwei1025 opened a new pull request #15929: URL: https://github.com/apache/flink/pull/15929 ## What is the purpose of the change *This pull request support vectorized orc reader with nested types (List/Map/Struct).* ## Brief change log - *Add OrcArrayColu

[jira] [Updated] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22088: --- Fix Version/s: 1.14.0 > CheckpointCoordinator might not be able to abort triggering checkpoi

[jira] [Updated] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22088: --- Priority: Major (was: Minor) > CheckpointCoordinator might not be able to abort triggering

[jira] [Commented] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345926#comment-17345926 ] Piotr Nowojski commented on FLINK-22088: Thanks for the explanation [~gaoyunhaii

[jira] [Updated] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15390: --- Labels: pull-request-available (was: ) > List/Map/Struct types support for vectorized orc r

[GitHub] [flink] flinkbot commented on pull request #15929: [FLINK-15390][Connectors/ORC]List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread GitBox
flinkbot commented on pull request #15929: URL: https://github.com/apache/flink/pull/15929#issuecomment-842078203 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-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Description: To enable/config Changelog Statebackend, we need to set 1. "state.backend.changelog.enable

[jira] [Commented] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345930#comment-17345930 ] Piotr Nowojski commented on FLINK-21952: What about just using {code:java} if (

[jira] [Comment Edited] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345930#comment-17345930 ] Piotr Nowojski edited comment on FLINK-21952 at 5/17/21, 7:26 AM:

[GitHub] [flink] rkhachatryan commented on pull request #15846: [FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
rkhachatryan commented on pull request #15846: URL: https://github.com/apache/flink/pull/15846#issuecomment-842081874 Thanks, I'll merge the PR then. -- 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] rkhachatryan merged pull request #15846: [FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
rkhachatryan merged pull request #15846: URL: https://github.com/apache/flink/pull/15846 -- 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. For queries about this service, p

[jira] [Created] (FLINK-22679) code optimization:Transformation.equals

2021-05-17 Thread huzeming (Jira)
huzeming created FLINK-22679: Summary: code optimization:Transformation.equals Key: FLINK-22679 URL: https://issues.apache.org/jira/browse/FLINK-22679 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-22679) code optimization:Transformation.equals

2021-05-17 Thread huzeming (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huzeming updated FLINK-22679: - Description: code optimization:Transformation.equals , line : 550 {code:java} // old return outputType !

[GitHub] [flink] loniecc opened a new pull request #15930: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
loniecc opened a new pull request #15930: URL: https://github.com/apache/flink/pull/15930 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Commented] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure

2021-05-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345934#comment-17345934 ] Dawid Wysakowicz commented on FLINK-22595: -- https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-22679) code optimization:Transformation.equals

2021-05-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22679: --- Labels: pull-request-available (was: ) > code optimization:Transformation.equals > ---

[jira] [Updated] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure

2021-05-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22595: - Priority: Blocker (was: Major) > RocksDBStateBackendWindowITCase fails on Azure > -

[GitHub] [flink] rkhachatryan opened a new pull request #15932: [BP-1.13][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
rkhachatryan opened a new pull request #15932: URL: https://github.com/apache/flink/pull/15932 Backport of #15846 to 1.13. -- 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.

[GitHub] [flink] rkhachatryan opened a new pull request #15931: [BP-1.12][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
rkhachatryan opened a new pull request #15931: URL: https://github.com/apache/flink/pull/15931 Backport of #15846 to 1.12. -- 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.

[GitHub] [flink] loniecc closed pull request #15930: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
loniecc closed pull request #15930: URL: https://github.com/apache/flink/pull/15930 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot commented on pull request #15930: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
flinkbot commented on pull request #15930: URL: https://github.com/apache/flink/pull/15930#issuecomment-842087282 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

[GitHub] [flink] flinkbot commented on pull request #15932: [BP-1.13][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
flinkbot commented on pull request #15932: URL: https://github.com/apache/flink/pull/15932#issuecomment-842088799 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

[GitHub] [flink] flinkbot commented on pull request #15931: [BP-1.12][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
flinkbot commented on pull request #15931: URL: https://github.com/apache/flink/pull/15931#issuecomment-842088830 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

[GitHub] [flink] flinkbot edited a comment on pull request #15897: [FLINK-22638] Keep channels blocked on alignment timeout

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15897: URL: https://github.com/apache/flink/pull/15897#issuecomment-838767418 ## CI report: * 659023b1937b4e105dde32fb772c6b771b597ee6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15922: URL: https://github.com/apache/flink/pull/15922#issuecomment-841617014 ## CI report: * 9fcb8001b9956441051aa1800cdc2df052f7a2c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 9f545673d53bf59cccdab10021641ece2cf21650 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #15928: [FLINK-22651][python][table-planner-blink] Support StreamExecPythonGroupAggregate json serialization/deserialization

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

[GitHub] [flink] flinkbot commented on pull request #15929: [FLINK-15390][Connectors/ORC]List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread GitBox
flinkbot commented on pull request #15929: URL: https://github.com/apache/flink/pull/15929#issuecomment-842090480 ## CI report: * 541d2ce45eb8216c2d440c0f400ce5a1cdd5761c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] loniecc closed pull request #15930: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
loniecc closed pull request #15930: URL: https://github.com/apache/flink/pull/15930 -- 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. For queries about this service, please

[GitHub] [flink] wangwei1025 commented on pull request #15929: [FLINK-15390][Connectors/ORC]List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread GitBox
wangwei1025 commented on pull request #15929: URL: https://github.com/apache/flink/pull/15929#issuecomment-842105126 @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 speci

[jira] [Updated] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

2021-05-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22266: --- Fix Version/s: 1.13.1 > Harden JobMasterStopWithSavepointITCase > --

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input nod

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

[GitHub] [flink] SteNicholas commented on pull request #15729: [FLINK-22234][runtime] Read savepoint before creating ExecutionGraph

2021-05-17 Thread GitBox
SteNicholas commented on pull request #15729: URL: https://github.com/apache/flink/pull/15729#issuecomment-842116214 @tillrohrmann, thanks for the work of reviewing the pull request. And if you are available, please help to review again. Thanks. -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15928: [FLINK-22651][python][table-planner-blink] Support StreamExecPythonGroupAggregate json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15929: [FLINK-15390][Connectors/ORC]List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15929: URL: https://github.com/apache/flink/pull/15929#issuecomment-842090480 ## CI report: * 541d2ce45eb8216c2d440c0f400ce5a1cdd5761c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15931: [BP-1.12][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
flinkbot commented on pull request #15931: URL: https://github.com/apache/flink/pull/15931#issuecomment-842118924 ## CI report: * 49597b911b12065aa87592e1d48762efd63103c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15932: [BP-1.13][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
flinkbot commented on pull request #15932: URL: https://github.com/apache/flink/pull/15932#issuecomment-842119088 ## CI report: * aa3beef8368578aee442932d579dbc582cbc4ff3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-16930) Drop StatefulFunctionsClusterEntryPoint

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345957#comment-17345957 ] Konstantin Knauf commented on FLINK-16930: -- Enabling the reactive scheduler is

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345958#comment-17345958 ] Konstantin Knauf commented on FLINK-22533: -- [~igal] Do you think about this as

[jira] [Commented] (FLINK-22552) Rebase StateFun on Flink 1.13

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345962#comment-17345962 ] Konstantin Knauf commented on FLINK-22552: -- Let's wait for Flink 1.13.1 at leas

[jira] [Commented] (FLINK-22633) Add a Harness example to flink-statefun-playground

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345960#comment-17345960 ] Konstantin Knauf commented on FLINK-22633: -- +1 > Add a Harness example to flin

[jira] [Commented] (FLINK-20182) Add JDK 11 build to StateFun's CI

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345967#comment-17345967 ] Konstantin Knauf commented on FLINK-20182: -- Yes, let's not stop at FLINK-22468.

[GitHub] [flink] flinkbot edited a comment on pull request #15928: [FLINK-22651][python][table-planner-blink] Support StreamExecPythonGroupAggregate json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15931: [BP-1.12][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15931: URL: https://github.com/apache/flink/pull/15931#issuecomment-842118924 ## CI report: * 49597b911b12065aa87592e1d48762efd63103c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15932: [BP-1.13][FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval failures on recovery

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

[jira] [Commented] (FLINK-21280) Investigate a way to disable object reuse in StateFun

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345968#comment-17345968 ] Konstantin Knauf commented on FLINK-21280: -- [~igal] Are there any ideas about t

[jira] [Commented] (FLINK-18894) StateFun job stalls on stop-with-savepoint

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345963#comment-17345963 ] Konstantin Knauf commented on FLINK-18894: -- [~igal] What is the status of this

[GitHub] [flink] flinkbot commented on pull request #15933: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
flinkbot commented on pull request #15933: URL: https://github.com/apache/flink/pull/15933#issuecomment-842137326 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

[GitHub] [flink] HuangXingBo opened a new pull request #15934: [FLINK-22652][python][table-planner-blink] Support StreamExecPythonGroupWindowAggregate json serialization/deserialization

2021-05-17 Thread GitBox
HuangXingBo opened a new pull request #15934: URL: https://github.com/apache/flink/pull/15934 ## What is the purpose of the change *This pull request will support StreamExecPythonGroupWindowAggregate json serialization/deserialization* ## Brief change log - *Support S

[jira] [Updated] (FLINK-22652) Support StreamExecPythonGroupWindowAggregate json serialization/deserialization

2021-05-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22652: --- Labels: pull-request-available (was: ) > Support StreamExecPythonGroupWindowAggregate json

[jira] [Commented] (FLINK-22529) StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants

2021-05-17 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345964#comment-17345964 ] Konstantin Knauf commented on FLINK-22529: -- +1 > StateFun Kinesis ingresses sh

[GitHub] [flink] flinkbot commented on pull request #15934: [FLINK-22652][python][table-planner-blink] Support StreamExecPythonGroupWindowAggregate json serialization/deserialization

2021-05-17 Thread GitBox
flinkbot commented on pull request #15934: URL: https://github.com/apache/flink/pull/15934#issuecomment-842141649 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-22680) An IndexOutOfBoundsException is thrown out after apply WatermarkAssignerChangelogNormalizeTransposeRule

2021-05-17 Thread Andy (Jira)
Andy created FLINK-22680: Summary: An IndexOutOfBoundsException is thrown out after apply WatermarkAssignerChangelogNormalizeTransposeRule Key: FLINK-22680 URL: https://issues.apache.org/jira/browse/FLINK-22680

[jira] [Updated] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

2021-05-17 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22680: - Summary: An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRu

[jira] [Created] (FLINK-22681) how can i get flink job status from prometheus(PrometheusPushGateway)

2021-05-17 Thread yuwei zhan (Jira)
yuwei zhan created FLINK-22681: -- Summary: how can i get flink job status from prometheus(PrometheusPushGateway) Key: FLINK-22681 URL: https://issues.apache.org/jira/browse/FLINK-22681 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

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

[GitHub] [flink] flinkbot commented on pull request #15933: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
flinkbot commented on pull request #15933: URL: https://github.com/apache/flink/pull/15933#issuecomment-842161618 ## CI report: * 071d47faa002887a09d820570ce0eea5a2593ec1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15934: [FLINK-22652][python][table-planner-blink] Support StreamExecPythonGroupWindowAggregate json serialization/deserialization

2021-05-17 Thread GitBox
flinkbot commented on pull request #15934: URL: https://github.com/apache/flink/pull/15934#issuecomment-842161713 ## CI report: * 96c01b17ed4bfbb8d0f7505d74b84fcd653b6df7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

2021-05-17 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345991#comment-17345991 ] Zhilong Hong commented on FLINK-22284: -- Sorry that I missed the {{request}}. I pref

[GitHub] [flink] beyond1920 commented on a change in pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only in

2021-05-17 Thread GitBox
beyond1920 commented on a change in pull request #14830: URL: https://github.com/apache/flink/pull/14830#discussion_r633364916 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/GroupWindowITCase.scala ## @@ -18

[jira] [Comment Edited] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345997#comment-17345997 ] Piotr Nowojski edited comment on FLINK-22284 at 5/17/21, 9:15 AM:

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

2021-05-17 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345997#comment-17345997 ] Piotr Nowojski commented on FLINK-22284: Do you want to open a PR for this impro

[jira] [Created] (FLINK-22682) Checkpoint interval too large for higher DOP

2021-05-17 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-22682: --- Summary: Checkpoint interval too large for higher DOP Key: FLINK-22682 URL: https://issues.apache.org/jira/browse/FLINK-22682 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22681) how can i get flink job status from prometheus(PrometheusPushGateway)

2021-05-17 Thread yuwei zhan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuwei zhan updated FLINK-22681: --- Description: how can i get flink job status from prometheus(PrometheusPushGateway)  或者说flink on k8s

[jira] [Updated] (FLINK-22681) how can i get flink job status from prometheus(PrometheusPushGateway)

2021-05-17 Thread yuwei zhan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuwei zhan updated FLINK-22681: --- Description: How can i get flink job status from prometheus (PrometheusPushGateway)  Or is there a

[jira] [Commented] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

2021-05-17 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346001#comment-17346001 ] Andy commented on FLINK-22680: -- [~godfrey] Could I take this issue?  > An `IndexOutOfBound

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

2021-05-17 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346004#comment-17346004 ] Zhilong Hong commented on FLINK-22284: -- Yes, please assign it to me. Thank you, [~p

[jira] [Updated] (FLINK-22682) Checkpoint interval too large for higher DOP

2021-05-17 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22682: Description: When running a job on EMR with DOP of 160, checkpoints are not triggered at the set

[jira] [Created] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value

2021-05-17 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-22683: -- Summary: The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value Key: FLINK-22683 URL: https://issues.apache.org/jira/browse/FLINK-22683

[jira] [Updated] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value

2021-05-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-22683: --- Affects Version/s: 1.13.0 1.12.3 > The total Flink/process memory of memoryCo

[jira] [Updated] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value

2021-05-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-22683: --- Affects Version/s: (was: 1.12.3) 1.12.4 > The total Flink/process memory

[jira] [Updated] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value

2021-05-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-22683: --- Component/s: Runtime / Metrics > The total Flink/process memory of memoryConfiguration in /taskmanag

[jira] [Commented] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value

2021-05-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346008#comment-17346008 ] Yangze Guo commented on FLINK-22683: [~xintongsong] Could you assign this to me? >

[jira] [Assigned] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value

2021-05-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22683: Assignee: Yangze Guo > The total Flink/process memory of memoryConfiguration in /taskmana

[jira] [Created] (FLINK-22684) Add the ability to ignore in-flight data on recovery

2021-05-17 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-22684: - Summary: Add the ability to ignore in-flight data on recovery Key: FLINK-22684 URL: https://issues.apache.org/jira/browse/FLINK-22684 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input nod

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

[GitHub] [flink] twalthr opened a new pull request #15935: [FLINK-22666][table] Make structured type's fields more lenient for Scala

2021-05-17 Thread GitBox
twalthr opened a new pull request #15935: URL: https://github.com/apache/flink/pull/15935 ## What is the purpose of the change This make the logic for structured type fields more lenient. It fixes issues with Scala case classes. ## Brief change log Compare children indi

[jira] [Updated] (FLINK-22666) Add more test cases for brigding to Scala DataStream API

2021-05-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22666: --- Labels: pull-request-available (was: ) > Add more test cases for brigding to Scala DataStre

[jira] [Commented] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

2021-05-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346015#comment-17346015 ] godfrey he commented on FLINK-22680: Thanks for reporting this issue [~qingru zhang]

[jira] [Assigned] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

2021-05-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22680: -- Assignee: Andy > An `IndexOutOfBoundsException` is thrown out when apply > `WatermarkAssigne

[GitHub] [flink] flinkbot edited a comment on pull request #15922: [FLINK-22650][python][table-planner-blink] Support StreamExecPythonCorrelate json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15926: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

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

[GitHub] [flink] flinkbot edited a comment on pull request #15933: [FLINK-22679] code optimization:Transformation

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15933: URL: https://github.com/apache/flink/pull/15933#issuecomment-842161618 ## CI report: * 071d47faa002887a09d820570ce0eea5a2593ec1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15934: [FLINK-22652][python][table-planner-blink] Support StreamExecPythonGroupWindowAggregate json serialization/deserialization

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15934: URL: https://github.com/apache/flink/pull/15934#issuecomment-842161713 ## CI report: * 96c01b17ed4bfbb8d0f7505d74b84fcd653b6df7 UNKNOWN * 23eca32fecff7a4dacf5275a0af384761f9a56f5 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot commented on pull request #15935: [FLINK-22666][table] Make structured type's fields more lenient for Scala

2021-05-17 Thread GitBox
flinkbot commented on pull request #15935: URL: https://github.com/apache/flink/pull/15935#issuecomment-842176895 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-22684) Add the ability to ignore in-flight data on recovery

2021-05-17 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-22684: -- Description: The main case: * We want to restore the last unaligned checkpoint. * In

[jira] [Commented] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

2021-05-17 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346026#comment-17346026 ] Andy commented on FLINK-21301: -- Hi [~jark] Thanks for your reply. I agree that things will

[jira] [Commented] (FLINK-22684) Add the ability to ignore in-flight data on recovery

2021-05-17 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346027#comment-17346027 ] Anton Kalashnikov commented on FLINK-22684: --- [~pnowojski] , [~roman_khachatrya

[jira] [Updated] (FLINK-22666) Add more test cases for bridging to Scala DataStream API

2021-05-17 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-22666: Summary: Add more test cases for bridging to Scala DataStream API (was: Add more test cases for b

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input nod

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

[jira] [Comment Edited] (FLINK-22684) Add the ability to ignore in-flight data on recovery

2021-05-17 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346027#comment-17346027 ] Anton Kalashnikov edited comment on FLINK-22684 at 5/17/21, 9:54 AM: -

  1   2   3   4   5   >