[jira] [Commented] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346625#comment-17346625 ] Till Rohrmann commented on FLINK-22686: --- Thanks a lot for sharing the topology wit

[jira] [Closed] (FLINK-12295) avoid to call retractExpressions method of max/min function in retractable aggregate code-gen

2021-05-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-12295. Resolution: Fixed master: 057f86bd83c8e47081809b7f43c89c80f6dc5d94 > avoid to call retractExpress

[GitHub] [flink] JingsongLi merged pull request #15940: [FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction

2021-05-17 Thread GitBox
JingsongLi merged pull request #15940: URL: https://github.com/apache/flink/pull/15940 -- 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, ple

[jira] [Commented] (FLINK-3204) TaskManagers are not shutting down properly on YARN

2021-05-17 Thread Jinhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346620#comment-17346620 ] Jinhong Liu commented on FLINK-3204: [~nvasilishin] I stop a NodeManger while the job

[GitHub] [flink] twalthr commented on a change in pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-17 Thread GitBox
twalthr commented on a change in pull request #15905: URL: https://github.com/apache/flink/pull/15905#discussion_r634092309 ## File path: flink-python/pyflink/table/descriptors.py ## @@ -33,7 +33,6 @@ 'FileSystem', 'Kafka', 'Elasticsearch', -'HBase', Review

[jira] [Commented] (FLINK-3204) TaskManagers are not shutting down properly on YARN

2021-05-17 Thread Jinhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346616#comment-17346616 ] Jinhong Liu commented on FLINK-3204: I also meet the issue https://issues.apache.org/

[GitHub] [flink] twalthr commented on a change in pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-17 Thread GitBox
twalthr commented on a change in pull request #15905: URL: https://github.com/apache/flink/pull/15905#discussion_r634090628 ## File path: flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/util/HBaseTestBase.java ## @@ -131,7 +120,7 @@ p

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15780: [FLINK-22487][python] Support `print` to print logs in PyFlink

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

[jira] [Comment Edited] (FLINK-18096) Generated avro formats should support user specified name and namespace

2021-05-17 Thread YoungWoo Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346612#comment-17346612 ] YoungWoo Kim edited comment on FLINK-18096 at 5/18/21, 6:30 AM: --

[jira] [Commented] (FLINK-18096) Generated avro formats should support user specified name and namespace

2021-05-17 Thread YoungWoo Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346612#comment-17346612 ] YoungWoo Kim commented on FLINK-18096: -- [~jark], [~sjwiesman] At least, A generated

[jira] [Resolved] (FLINK-22653) Support StreamExecPythonOverAggregate json serialization/deserialization

2021-05-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22653. -- Fix Version/s: 1.14.0 Resolution: Done Merged into master via 4d33e852358011fa8ef3fb6bb

[GitHub] [flink] HuangXingBo closed pull request #15937: [FLINK-22653][python][table-planner-blink] Support StreamExecPythonOverAggregate json serialization/deserialization

2021-05-17 Thread GitBox
HuangXingBo closed pull request #15937: URL: https://github.com/apache/flink/pull/15937 -- 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, pl

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

2021-05-17 Thread GitBox
wangwei1025 commented on pull request #15939: URL: https://github.com/apache/flink/pull/15939#issuecomment-842881614 Hello @JingsongLi , could you please help me review this PR? thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] HuangXingBo commented on pull request #15780: [FLINK-22487][python] Support `print` to print logs in PyFlink

2021-05-17 Thread GitBox
HuangXingBo commented on pull request #15780: URL: https://github.com/apache/flink/pull/15780#issuecomment-842880760 @dianfu Thanks a lot for the review. I have addressed the comments and optimized the logic of `print_to_logging` at the latest commit. -- This is an automated message from

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

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

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

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

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

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

[GitHub] [flink-statefun] tzulitai opened a new pull request #234: [FLINK-22552] Update Flink dependency to 1.13.0

2021-05-17 Thread GitBox
tzulitai opened a new pull request #234: URL: https://github.com/apache/flink-statefun/pull/234 This PR rebases StateFun to be compatible with Flink 1.13.x. While the PR upgrades to 1.13.0, ultimately, we want to at least update to 1.13.1. We may postpone the merge of this PR until 1.13.

[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: * bc2786c856a33b6629ee3d6dc55458c35860dded Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-05-17 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346608#comment-17346608 ] Tzu-Li (Gordon) Tai commented on FLINK-20182: - [~knaufk] We actually do publ

[jira] [Comment Edited] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2021-05-17 Thread Jinhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346599#comment-17346599 ] Jinhong Liu edited comment on FLINK-22663 at 5/18/21, 5:53 AM: ---

[jira] [Commented] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2021-05-17 Thread Jinhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346599#comment-17346599 ] Jinhong Liu commented on FLINK-22663: - [~fly_in_gis]  Firstly, this issue occurs ju

[GitHub] [flink] lirui-apache commented on a change in pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

2021-05-17 Thread GitBox
lirui-apache commented on a change in pull request #15653: URL: https://github.com/apache/flink/pull/15653#discussion_r634060636 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/util/JobConfUtilsTest.java ## @@ -0,0 +1,60 @@ +/

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

2021-05-17 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-22552: --- Assignee: Tzu-Li (Gordon) Tai > Rebase StateFun on Flink 1.13 > ---

[GitHub] [flink] flinkbot edited a comment on pull request #15940: [FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction

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

[GitHub] [flink] tweise commented on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-842849181 @SteNicholas thanks for the feedback! I will update the PR once we gather some more input. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] tweise commented on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-842848588 > @tweise , thanks for creating pull request for `HybridSource` basic implementation. IMO, `SwitchableSource` and `SwitchableSplitEnumerator` mentioned in FLIP-150 could be intro

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r634044007 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,201

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r634043488 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,201

[GitHub] [flink] flinkbot commented on pull request #15940: [FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction

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

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r634042830 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,201

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r634042326 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,213 @@ +/*

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-17 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r634041985 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,213 @@ +/*

[jira] [Closed] (FLINK-15733) Add min number memory pages check for BytesHashMap

2021-05-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15733. Resolution: Invalid > Add min number memory pages check for BytesHashMap > ---

[GitHub] [flink] flinkbot commented on pull request #15940: [FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction

2021-05-17 Thread GitBox
flinkbot commented on pull request #15940: URL: https://github.com/apache/flink/pull/15940#issuecomment-842815707 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-12295) avoid to call retractExpressions method of max/min function in retractable aggregate code-gen

2021-05-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12295: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > avoid to call retra

[GitHub] [flink] JingsongLi opened a new pull request #15940: [FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction

2021-05-17 Thread GitBox
JingsongLi opened a new pull request #15940: URL: https://github.com/apache/flink/pull/15940 ## What is the purpose of the change Fix comments in `MaxAggFunction.retractExpressions`, return `Expression[0]` is right. ``` See optimization in FlinkRelMdModifiedMonotonicity

[jira] [Assigned] (FLINK-12295) avoid to call retractExpressions method of max/min function in retractable aggregate code-gen

2021-05-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-12295: Assignee: Jingsong Lee > avoid to call retractExpressions method of max/min function in r

[jira] [Updated] (FLINK-12295) avoid to call retractExpressions method of max/min function in retractable aggregate code-gen

2021-05-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12295: - Fix Version/s: 1.14.0 > avoid to call retractExpressions method of max/min function in retractab

[GitHub] [flink] JackWangCS commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-05-17 Thread GitBox
JackWangCS commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-842810784 Hi @zuston , `TokenCache.obtainTokensForNamenodes` need to pass in a set of paths. In the context of `HadoopFSDelegationTokenProvider`, it's a bit complex to constrcut the pa

[GitHub] [flink] zuston commented on a change in pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

2021-05-17 Thread GitBox
zuston commented on a change in pull request #15653: URL: https://github.com/apache/flink/pull/15653#discussion_r634020126 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java ## @@ -114,17 +117,19 @@ p

[GitHub] [flink] zuston commented on a change in pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

2021-05-17 Thread GitBox
zuston commented on a change in pull request #15653: URL: https://github.com/apache/flink/pull/15653#discussion_r634020059 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/util/JobConfUtilsTest.java ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink] zuston commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-05-17 Thread GitBox
zuston commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-842804878 @JackWangCS Thanks for your reply promptly. Sorry, i don't know why not reusing the `TokenCache.obtainTokensForNamenodes` to obtain fs delegation tokens. -- This is an auto

[jira] [Commented] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2021-05-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346568#comment-17346568 ] Yang Wang commented on FLINK-22663: --- Thanks for sharing more information. Only when th

[GitHub] [flink] zuston commented on a change in pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-05-17 Thread GitBox
zuston commented on a change in pull request #14841: URL: https://github.com/apache/flink/pull/14841#discussion_r634018947 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/security/HadoopFSDelegationTokenProvider.java ## @@ -0,0 +1,126 @@ +/* + * Licensed to the Ap

[jira] [Created] (FLINK-22691) On Aliyun ECS, docker deployed flink (1.13.0), which was scanned to Mirai DDOS Trojan

2021-05-17 Thread Magina.Shan (Jira)
Magina.Shan created FLINK-22691: --- Summary: On Aliyun ECS, docker deployed flink (1.13.0), which was scanned to Mirai DDOS Trojan Key: FLINK-22691 URL: https://issues.apache.org/jira/browse/FLINK-22691 P

[GitHub] [flink] flinkbot edited a comment on pull request #15703: [FLINK-22275][table] Support random past for timestamp types in datagen connector

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

[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

2021-05-17 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346558#comment-17346558 ] Yun Tang commented on FLINK-21986: -- [~Feifan Wang], could you tell me what the docker i

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15703: [FLINK-22275][table] Support random past for timestamp types in datagen connector

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

[GitHub] [flink-statefun] tzulitai commented on pull request #230: [FLINK-22468] Fix Java 11 build by adding dependency to javax.annotations

2021-05-17 Thread GitBox
tzulitai commented on pull request #230: URL: https://github.com/apache/flink-statefun/pull/230#issuecomment-842790470 @knaufk thanks for the review and trying this out. I'm not merging this just yet because we should make this a profile that is enabled specifically for Java 11 build

[GitHub] [flink] JasonLeeCoding commented 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
JasonLeeCoding commented on pull request #15926: URL: https://github.com/apache/flink/pull/15926#issuecomment-842786948 I got an error java.lang.AssertionError testCancelExecutionInNonInteractiveMode throws an exception at line 303 of the code Can anyone help me take a look ? -- Thi

[jira] [Updated] (FLINK-22689) Table API Documentation Row-Based Operations Example Fails

2021-05-17 Thread Yunfeng Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-22689: - Description: I wrote the following program according to the example code provided in [Documenta

[jira] [Commented] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346548#comment-17346548 ] ChangZhuo Chen (陳昌倬) commented on FLINK-22686: -- [~arvid] * The topology is

[jira] [Created] (FLINK-22690) kerberos integration with flink,kerberos tokens will expire

2021-05-17 Thread kevinsun (Jira)
kevinsun created FLINK-22690: Summary: kerberos integration with flink,kerberos tokens will expire Key: FLINK-22690 URL: https://issues.apache.org/jira/browse/FLINK-22690 Project: Flink Issue T

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-22686: - Attachment: topology_3.png topology_2.png topolog

[jira] [Created] (FLINK-22689) Table API Documentation Row-Based Operations Example Fails

2021-05-17 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-22689: Summary: Table API Documentation Row-Based Operations Example Fails Key: FLINK-22689 URL: https://issues.apache.org/jira/browse/FLINK-22689 Project: Flink Is

[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_r634001661 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.sca

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-22686: - Attachment: (was: 1.png) > Incompatible subtask mappings while resuming from

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-22686: - Attachment: (was: 3.png) > Incompatible subtask mappings while resuming from

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-22686: - Attachment: (was: 2.png) > Incompatible subtask mappings while resuming from

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-17 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-22686: - Attachment: 3.png 2.png 1.png > Incompatible sub

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

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

[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: * bc2786c856a33b6629ee3d6dc55458c35860dded Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

2021-05-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346542#comment-17346542 ] Xintong Song commented on FLINK-19481: -- {quote}The runtime complexity of having the

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

2021-05-17 Thread GitBox
flinkbot commented on pull request #15939: URL: https://github.com/apache/flink/pull/15939#issuecomment-842774944 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] wangwei1025 opened a new pull request #15939: [FLINK-15390][Connectors/ORC][Connectors/Hive]List/Map/Struct types support for vectorized orc reader

2021-05-17 Thread GitBox
wangwei1025 opened a new pull request #15939: URL: https://github.com/apache/flink/pull/15939 ## 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

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

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

[jira] [Commented] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346533#comment-17346533 ] Yangze Guo commented on FLINK-22688: cc [~mapohl] who can shed some light on this is

[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: * bc2786c856a33b6629ee3d6dc55458c35860dded Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2021-05-17 Thread Jinhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346530#comment-17346530 ] Jinhong Liu commented on FLINK-22663: - [~fly_in_gis] # I shut down one NodeMnager w

[GitHub] [flink] yittg commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-05-17 Thread GitBox
yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-842765986 Hi @wangyang0918 , does this change still make sense? -- 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] yittg commented on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-05-17 Thread GitBox
yittg commented on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-842765542 Hi @tillrohrmann , would you merge it ? Just remind you to confirm you didn't miss it, :) thanks again. -- This is an automated message from the Apache Git Service. To respond t

[jira] [Updated] (FLINK-22651) Support StreamExecPythonGroupAggregate json serialization/deserialization

2021-05-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-22651: - Fix Version/s: 1.14.0 > Support StreamExecPythonGroupAggregate json serialization/deserializatio

[jira] [Resolved] (FLINK-22651) Support StreamExecPythonGroupAggregate json serialization/deserialization

2021-05-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22651. -- Resolution: Done Merged into master via 06dec012763c055746b635070d6bed49bb30686c > Support St

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

2021-05-17 Thread GitBox
HuangXingBo closed pull request #15928: URL: https://github.com/apache/flink/pull/15928 -- 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, pl

[GitHub] [flink] godfreyhe commented on pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input node

2021-05-17 Thread GitBox
godfreyhe commented on pull request #14830: URL: https://github.com/apache/flink/pull/14830#issuecomment-842764474 @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 specifi

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

2021-05-17 Thread GitBox
godfreyhe commented on a change in pull request #14830: URL: https://github.com/apache/flink/pull/14830#discussion_r633973171 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scal

[GitHub] [flink] yittg commented on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

2021-05-17 Thread GitBox
yittg commented on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-842762480 @wuchong Hi, how's everything going? -- 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 t

[jira] [Commented] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-17 Thread Gary Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346523#comment-17346523 ] Gary Wu commented on FLINK-22688: - Hi, [~karmagyz] and [~maguowei],  I have created a b

[jira] [Created] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-17 Thread Gary Wu (Jira)
Gary Wu created FLINK-22688: --- Summary: Root Exception can not be shown on Web UI in Flink 1.13.0 Key: FLINK-22688 URL: https://issues.apache.org/jira/browse/FLINK-22688 Project: Flink Issue Type: B

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

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

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 60e427103cca73ac1fc29fb18893e3996edb1c7a UNKNOWN * b88e8b4068b23de76bfcba85fb1373b478a5 UNKNOWN * 5a2467236a4ef8c211a9d4a9d9092d91cff1

[jira] [Commented] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

2021-05-17 Thread Eduardo Winpenny Tejedor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346460#comment-17346460 ] Eduardo Winpenny Tejedor commented on FLINK-22483: -- Thanks [~trohrmann]

[GitHub] [flink] flinkbot edited a comment on pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

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

[GitHub] [flink] flinkbot edited a comment on pull request #15904: [FLINK-22646] Unregister DeclarativeSlotManager metrics, before suspending

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

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [FLINK-22067][tests] Wait for vertices to start using API

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 536a3f0e34b5840b019cf571cf85d4459b52c3a7 UNKNOWN * 15328613e51f7830fc15ff7ba9ebdb3ebe7b12eb Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15937: URL: https://github.com/apache/flink/pull/15937#issuecomment-842291900 ## CI report: * bef596d85790f56b524ac4a8345a0312bbba1659 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: * b1ef7090e913827bbbe1442cc05ade7cec149558 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

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

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

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

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

2021-05-17 Thread GitBox
HuangXingBo closed pull request #15934: URL: https://github.com/apache/flink/pull/15934 -- 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, pl

[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 -- 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

[GitHub] [flink] XComp commented on pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-17 Thread GitBox
XComp commented on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-841813005 The [reported build failure](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17928&view=logs&j=b2f046ab-ae17-5406-acdc-240be7e870e4&t=93e5ae06-d194-513d-ba8d

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

2021-05-17 Thread GitBox
flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 -- 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

[GitHub] [flink] AHeise commented on a change in pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-17 Thread GitBox
AHeise commented on a change in pull request #15905: URL: https://github.com/apache/flink/pull/15905#discussion_r633698769 ## File path: flink-python/pyflink/table/descriptors.py ## @@ -33,7 +33,6 @@ 'FileSystem', 'Kafka', 'Elasticsearch', -'HBase', Review c

  1   2   3   4   5   >