[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * f27bd348bd56998fafe20ce005c8502042f4

[jira] [Updated] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

2021-02-24 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-21444: Fix Version/s: (was: 1.12.3) (was: 1.13.0) > Lookup joins should deal w

[jira] [Created] (FLINK-21477) Lookup joins should deal with intermediate table scans containing just the table source correctly

2021-02-24 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-21477: --- Summary: Lookup joins should deal with intermediate table scans containing just the table source correctly Key: FLINK-21477 URL: https://issues.apache.org/jira/browse/FLINK-21477

[GitHub] [flink] flinkbot edited a comment on pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

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

[jira] [Created] (FLINK-21478) Lookup joins should deal with any intermediate table scans correctly

2021-02-24 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-21478: --- Summary: Lookup joins should deal with any intermediate table scans correctly Key: FLINK-21478 URL: https://issues.apache.org/jira/browse/FLINK-21478 Project: Flink

[jira] [Commented] (FLINK-21476) How to appoint jobname

2021-02-24 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289760#comment-17289760 ] ranqiqiang commented on FLINK-21476: Thanks > How to appoint jobname > ---

[jira] [Closed] (FLINK-21476) How to appoint jobname

2021-02-24 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ranqiqiang closed FLINK-21476. -- Resolution: Duplicate > How to appoint jobname > --- > > Key: FLI

[jira] [Updated] (FLINK-21478) Lookup joins should deal with any intermediate table scans correctly

2021-02-24 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-21478: Description: This subtask is more complex because it has to deal with temporal joins with a view.

[jira] [Updated] (FLINK-21253) Support grouping set syntax for WindowAggregate and GroupWindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21253: - Summary: Support grouping set syntax for WindowAggregate and GroupWindowAggregate (was: Support grouping set sy

[jira] [Updated] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException

2021-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21475: -- Parent: FLINK-21075 Issue Type: Sub-task (was: Bug) > StateWithExecutionGraph.suspend

[jira] [Commented] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException

2021-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289766#comment-17289766 ] Till Rohrmann commented on FLINK-21475: --- I think the problem is that we call suspe

[jira] [Assigned] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException

2021-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21475: - Assignee: Till Rohrmann > StateWithExecutionGraph.suspend fails with IllegalStateExcept

[jira] [Assigned] (FLINK-21400) Attempt numbers are not maintained across restarts

2021-02-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-21400: Assignee: Chesnay Schepler > Attempt numbers are not maintained across restarts >

[GitHub] [flink] flinkbot edited a comment on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 9e445296314a2bfde4c85b61f1a3d9ee892c97ba Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * f27bd348bd56998fafe20ce005c8502042f4

[jira] [Commented] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

2021-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289774#comment-17289774 ] Till Rohrmann commented on FLINK-21236: --- Yes, I think so too. > Don't explicitly

[jira] [Commented] (FLINK-21450) Add local recovery support to adaptive scheduler

2021-02-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289776#comment-17289776 ] Robert Metzger commented on FLINK-21450: Thanks a lot for offering your help. E

[jira] [Updated] (FLINK-21450) Add local recovery support to adaptive scheduler

2021-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21450: -- Parent: FLINK-21075 Issue Type: Sub-task (was: New Feature) > Add local recovery supp

[jira] [Assigned] (FLINK-21450) Add local recovery support to adaptive scheduler

2021-02-24 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21450: -- Assignee: Dominik Wosiński > Add local recovery support to adaptive scheduler > -

[jira] [Commented] (FLINK-21472) FencingTokenException: Fencing token mismatch

2021-02-24 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289790#comment-17289790 ] Matthias commented on FLINK-21472: -- There seem to be some connection issue to retrieve

[GitHub] [flink] sllence commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-02-24 Thread GitBox
sllence commented on pull request #14977: URL: https://github.com/apache/flink/pull/14977#issuecomment-784935998 > > https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java > > ``` > > else i

[jira] [Created] (FLINK-21480) Respect external resources from resource requirements

2021-02-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-21480: Summary: Respect external resources from resource requirements Key: FLINK-21480 URL: https://issues.apache.org/jira/browse/FLINK-21480 Project: Flink Issue T

[jira] [Created] (FLINK-21481) Move git-commit-id-plugin execution to flink-runtime

2021-02-24 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21481: Summary: Move git-commit-id-plugin execution to flink-runtime Key: FLINK-21481 URL: https://issues.apache.org/jira/browse/FLINK-21481 Project: Flink

[jira] [Created] (FLINK-21479) Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

2021-02-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-21479: Summary: Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy Key: FLINK-21479 URL: https://issues.apache.org/jira/browse/FLINK-21479 Proje

[jira] [Commented] (FLINK-20659) YARNSessionCapacitySchedulerITCase.perJobYarnClusterOffHeap test failed with NPE

2021-02-24 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289809#comment-17289809 ] Matthias commented on FLINK-20659: -- I tried to reproduce on AzureCI but didn't succeed

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 4e37e897e9cce7d900d4d22a3e50e1314f5239cb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * f27bd348bd56998fafe20ce005c8502042f4

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 341578b2d03693afbd8179683c6f2696c229 UNKNOWN * c556f5f3258dc845f6315384ac00b4384110edc9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

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

[jira] [Updated] (FLINK-21253) Support grouping set syntax for GroupWindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21253: - Summary: Support grouping set syntax for GroupWindowAggregate (was: Support grouping set syntax for WindowAggre

[jira] [Created] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
Andy created FLINK-21482: Summary: Support grouping set syntax for WindowAggregate Key: FLINK-21482 URL: https://issues.apache.org/jira/browse/FLINK-21482 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 4e37e897e9cce7d900d4d22a3e50e1314f5239cb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 341578b2d03693afbd8179683c6f2696c229 UNKNOWN * c556f5f3258dc845f6315384ac00b4384110edc9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * f27bd348bd56998fafe20ce005c8502042f4

[jira] [Assigned] (FLINK-21442) Jdbc XA sink - restore state serialization error

2021-02-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21442: - Assignee: Maciej Obuchowski > Jdbc XA sink - restore state serialization error

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21482: - Description: Now window tvf could work well like the following sql.  {code:java} SELECT GROUPING_ID(`name`),

[jira] [Commented] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289832#comment-17289832 ] Andy commented on FLINK-21482: -- [~jark] , [~godfreyhe] The root cause of the above exceptio

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21482: - Description: Now window tvf could work well like the following sql.  {code:java} SELECT GROUPING_ID(`name`),

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21482: - Issue Type: Improvement (was: New Feature) Priority: Minor (was: Major) > Support grouping set syntax fo

[GitHub] [flink] aljoscha commented on a change in pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-24 Thread GitBox
aljoscha commented on a change in pull request #14913: URL: https://github.com/apache/flink/pull/14913#discussion_r581825549 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/HeapTimersSnapshottingTest.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 4a0e89bfae261aa2fbbb3aa37bc6980093a16259 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] dawidwys closed pull request #14979: [FLINK-19970] State leak in CEP Operators

2021-02-24 Thread GitBox
dawidwys closed pull request #14979: URL: https://github.com/apache/flink/pull/14979 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] [Closed] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2021-02-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-19970. Fix Version/s: 1.13.0 Resolution: Fixed Fixed in fab2e55bddc5495353a443c808c99e9bda

[GitHub] [flink] dawidwys commented on a change in pull request #14982: [FLINK-XXXXX] Enfore common/unified savepoint format at operator level

2021-02-24 Thread GitBox
dawidwys commented on a change in pull request #14982: URL: https://github.com/apache/flink/pull/14982#discussion_r581849390 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.java ## @@ -245,6 +262,24 @@ void s

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 4a0e89bfae261aa2fbbb3aa37bc6980093a16259 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN * eb6c10b0d339bfc92a540314e7c58cbf11a7

[GitHub] [flink] zhuzhurk commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-24 Thread GitBox
zhuzhurk commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581859557 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/DistributionPattern.java ## @@ -18,29 +18,22 @@ package org.apache.flink.

[GitHub] [flink] zentol commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

2021-02-24 Thread GitBox
zentol commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r581861367 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -1021,203 +220,20 @@ public ArchivedExecutionC

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21482: - Description: Now window tvf could work well like the following sql.  {code:java} SELECT GROUPING_ID(`name`),

[GitHub] [flink] zentol opened a new pull request #15002: [FLINK-21481][build] Move git-commit-id-plugin execution to flink-runtime

2021-02-24 Thread GitBox
zentol opened a new pull request #15002: URL: https://github.com/apache/flink/pull/15002 Optimization of the build process where we only execute the git-commit-id-plugin once within flink-runtime. The properties from the plugin were used in 2 ways: 1) encoded into a properties

[jira] [Updated] (FLINK-21481) Move git-commit-id-plugin execution to flink-runtime

2021-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21481: --- Labels: pull-request-available (was: ) > Move git-commit-id-plugin execution to flink-runti

[GitHub] [flink] zhuzhurk commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-24 Thread GitBox
zhuzhurk commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581864624 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -668,6 +678,29 @@ public int getTotalNumberO

[GitHub] [flink] flinkbot commented on pull request #15002: [FLINK-21481][build] Move git-commit-id-plugin execution to flink-runtime

2021-02-24 Thread GitBox
flinkbot commented on pull request #15002: URL: https://github.com/apache/flink/pull/15002#issuecomment-784996946 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] zentol merged pull request #14992: [FLINK-21451][coordination] Remove JobID from TaskExecutionState

2021-02-24 Thread GitBox
zentol merged pull request #14992: URL: https://github.com/apache/flink/pull/14992 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 t

[jira] [Closed] (FLINK-21451) Remove TaskExecutionState#jobID

2021-02-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21451. Resolution: Fixed master: 7f1853d3258c38b24e4be36adcfe08a59f211f39 > Remove TaskExecution

[GitHub] [flink] zhuzhurk commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-24 Thread GitBox
zhuzhurk commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r581870920 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the

[GitHub] [flink-statefun] tzulitai commented on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-24 Thread GitBox
tzulitai commented on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-785011143 @sjwiesman `Slice` is exposed through the `TypeSerializer` as well, and exposing it would actually allow us to avoid excessive byte array copies end-to-end. @igalshilman w

[GitHub] [flink-statefun] tzulitai commented on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-24 Thread GitBox
tzulitai commented on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-785011320 CI is passing, merging this. I'll return back to fixing the CI for E2E tests right after this. This is

[GitHub] [flink-statefun] tzulitai closed pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-24 Thread GitBox
tzulitai closed pull request #201: URL: https://github.com/apache/flink-statefun/pull/201 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

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 2d9c758d0a30150d11aa9b0cb9bd4f48aba548c8 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14868: URL: https://github.com/apache/flink/pull/14868#issuecomment-773192044 ## CI report: * 62df715ec67bf1785157ca0a056c44e52765e49c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

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

[jira] [Commented] (FLINK-21472) FencingTokenException: Fencing token mismatch

2021-02-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289864#comment-17289864 ] Yang Wang commented on FLINK-21472: --- I think maybe the JobManager has failed over. The

[GitHub] [flink] rmetzger commented on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

2021-02-24 Thread GitBox
rmetzger commented on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-785014582 Are you using Mesos in production? Or are you interested in contributing to Apache Flink in general? This is a

[GitHub] [flink] flinkbot edited a comment on pull request #14993: [FLINK-21399] Fix JobMasterTest#testRequestNextInputSplitWithGlobalFailover for AdaptiveScheduler

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

[GitHub] [flink] flinkbot commented on pull request #15002: [FLINK-21481][build] Move git-commit-id-plugin execution to flink-runtime

2021-02-24 Thread GitBox
flinkbot commented on pull request #15002: URL: https://github.com/apache/flink/pull/15002#issuecomment-785014658 ## CI report: * d5b6021d847822c7bdcfefea7fbdb5df64a22208 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink-statefun] igalshilman commented on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-24 Thread GitBox
igalshilman commented on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-785018866 @sjwiesman thanks for the suggestion! Yes a builder here will read nicer. I'll followup with that. Regarding the `Slice`, the main motivation was to enable efficien

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement ChangelogStateBackend to forward state changes to StateChangelog

2021-02-24 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r581890258 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@ -0,0 +

[GitHub] [flink] rmetzger closed pull request #14934: Upgrade the os-maven-plugin depency, to version 1.7.0

2021-02-24 Thread GitBox
rmetzger closed pull request #14934: URL: https://github.com/apache/flink/pull/14934 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-statefun] igalshilman edited a comment on pull request #201: [FLINK-21459] [sdks] Implement remote Java SDK

2021-02-24 Thread GitBox
igalshilman edited a comment on pull request #201: URL: https://github.com/apache/flink-statefun/pull/201#issuecomment-785018866 @sjwiesman thanks for the suggestion! Yes a builder here will read nicer. I'll followup with that. Regarding the `Slice`, the main motivation was to enable e

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 4a0e89bfae261aa2fbbb3aa37bc6980093a16259 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN * eb6c10b0d339bfc92a540314e7c58cbf11a7

[GitHub] [flink] flinkbot edited a comment on pull request #14993: [FLINK-21399] Fix JobMasterTest#testRequestNextInputSplitWithGlobalFailover for AdaptiveScheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #15002: [FLINK-21481][build] Move git-commit-id-plugin execution to flink-runtime

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

[jira] [Created] (FLINK-21483) Disable the spot bugs plugin.

2021-02-24 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-21483: Summary: Disable the spot bugs plugin. Key: FLINK-21483 URL: https://issues.apache.org/jira/browse/FLINK-21483 Project: Flink Issue Type: Task Comp

[jira] [Created] (FLINK-21484) Internal enum CheckpointType is exposed via REST API, making it part of Public API

2021-02-24 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-21484: -- Summary: Internal enum CheckpointType is exposed via REST API, making it part of Public API Key: FLINK-21484 URL: https://issues.apache.org/jira/browse/FLINK-21484

[GitHub] [flink] rkhachatryan commented on a change in pull request #14943: [FLINK-21354] Implement ChangelogStateBackend to forward state changes to StateChangelog

2021-02-24 Thread GitBox
rkhachatryan commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r581912262 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

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

[GitHub] [flink] beyond1920 opened a new pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

2021-02-24 Thread GitBox
beyond1920 opened a new pull request #15003: URL: https://github.com/apache/flink/pull/15003 ## What is the purpose of the change This pull request aims to fix a minor bug in `FlinkRelMdWindowProperties` when infer WindowProperties of `Expand`. Add more cases to test grouping set s

[GitHub] [flink] rmetzger commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-24 Thread GitBox
rmetzger commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r581918367 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -835,8 +840,21 @@ public void updateAccumulators(f

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

2021-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21482: --- Labels: pull-request-available (was: ) > Support grouping set syntax for WindowAggregate >

[GitHub] [flink] flinkbot commented on pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

2021-02-24 Thread GitBox
flinkbot commented on pull request #15003: URL: https://github.com/apache/flink/pull/15003#issuecomment-785043784 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] beyond1920 opened a new pull request #15004: [FLINK-21253][table-planner-blink] Support grouping set syntax for GroupWindowAggregate

2021-02-24 Thread GitBox
beyond1920 opened a new pull request #15004: URL: https://github.com/apache/flink/pull/15004 ## What is the purpose of the change This pull request aims to support grouping set syntax for WindowAggregate (from window TVF syntax) and GroupWindowAggregate (legacy GROUP WINDOW FUNCTION sy

[jira] [Updated] (FLINK-21253) Support grouping set syntax for GroupWindowAggregate

2021-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21253: --- Labels: pull-request-available (was: ) > Support grouping set syntax for GroupWindowAggrega

[GitHub] [flink] flinkbot commented on pull request #15004: [FLINK-21253][table-planner-blink] Support grouping set syntax for GroupWindowAggregate

2021-02-24 Thread GitBox
flinkbot commented on pull request #15004: URL: https://github.com/apache/flink/pull/15004#issuecomment-785046376 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] rmetzger commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-24 Thread GitBox
rmetzger commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r581927559 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/stopwithsavepoint/StopWithSavepointTerminationHandlerImpl.java ## @@ -0,0 +

[GitHub] [flink] flinkbot edited a comment on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 9e445296314a2bfde4c85b61f1a3d9ee892c97ba Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and Node

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

[GitHub] [flink] dawidwys commented on a change in pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-24 Thread GitBox
dawidwys commented on a change in pull request #14913: URL: https://github.com/apache/flink/pull/14913#discussion_r581929872 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java ## @@ -4

[GitHub] [flink] dawidwys commented on a change in pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-24 Thread GitBox
dawidwys commented on a change in pull request #14913: URL: https://github.com/apache/flink/pull/14913#discussion_r581929983 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/HeapTimersSnapshottingTest.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #14803: [FLINK-21199][python] Introduce InternalTimerService In PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement ChangelogStateBackend to forward state changes to StateChangelog

2021-02-24 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * 0c28132524116f599ecd4c2b23d77675db92

[GitHub] [flink] flinkbot edited a comment on pull request #15001: [FLINK-20332][runtime][k8s] Add recovered workers to pending resources for native k8s deployment

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

[GitHub] [flink] flinkbot commented on pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

2021-02-24 Thread GitBox
flinkbot commented on pull request #15003: URL: https://github.com/apache/flink/pull/15003#issuecomment-785052606 ## CI report: * b677d152aea25a4ba389e7713248a78484d942a6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15004: [FLINK-21253][table-planner-blink] Support grouping set syntax for GroupWindowAggregate

2021-02-24 Thread GitBox
flinkbot commented on pull request #15004: URL: https://github.com/apache/flink/pull/15004#issuecomment-785052726 ## CI report: * fd725646ab4c7d7174203dbf481901093265f3d8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] dawidwys commented on a change in pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-24 Thread GitBox
dawidwys commented on a change in pull request #14913: URL: https://github.com/apache/flink/pull/14913#discussion_r581931797 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ## @@

[GitHub] [flink] LadyForest opened a new pull request #15005: [FLINK-21298][table] Support 'USE MODULES' syntax both in SQL parser, TableEnvironment and SQL CLI

2021-02-24 Thread GitBox
LadyForest opened a new pull request #15005: URL: https://github.com/apache/flink/pull/15005 ## What is the purpose of the change This pull request supports using the module(s) by `USE MODULES x [, y, z, ...]` syntax in both SQL parser, TableEnvironment, and SQL CLI. ## Br

[jira] [Updated] (FLINK-21298) Support 'USE MODULES' syntax

2021-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21298: --- Labels: pull-request-available (was: ) > Support 'USE MODULES' syntax > ---

  1   2   3   4   5   >