[jira] [Updated] (FLINK-21274) At per-job mode，during the exit of the JobManager process, if ioExecutor exits at the end, the System.exit() method will not be executed.

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jichao Wang updated FLINK-21274: Summary: At per-job mode，during the exit of the JobManager process, if ioExecutor exits at the

[jira] [Updated] (FLINK-21274) At per-job mode，when JobManager exits, ioExecutor exits at the end, which will cause the System.exit() method to not be executed

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jichao Wang updated FLINK-21274: Summary: At per-job mode，when JobManager exits, ioExecutor exits at the end, which will cause the

[jira] [Updated] (FLINK-21274) At per-job mode，if the HDFS write is slow(about 5 seconds), the flink job archive file will upload fails

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jichao Wang updated FLINK-21274: Affects Version/s: 1.12.0 > At per-job mode，if the HDFS write is slow(about 5 seconds), the flink

[jira] [Updated] (FLINK-21274) At per-job mode，if the HDFS write is slow(about 5 seconds), the flink job archive file will upload fails

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jichao Wang updated FLINK-21274: Affects Version/s: 1.9.3 1.11.0 > At per-job mode，if the HDFS write is

[jira] [Comment Edited] (FLINK-21274) At per-job mode，if the HDFS write is slow(about 5 seconds), the flink job archive file will upload fails

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279485#comment-17279485 ] Jichao Wang edited comment on FLINK-21274 at 2/6/21, 7:50 AM: --

[jira] [Comment Edited] (FLINK-21274) At per-job mode，if the HDFS write is slow(about 5 seconds), the flink job archive file will upload fails

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279485#comment-17279485 ] Jichao Wang edited comment on FLINK-21274 at 2/6/21, 7:42 AM: --

[jira] [Comment Edited] (FLINK-21274) At per-job mode，if the HDFS write is slow(about 5 seconds), the flink job archive file will upload fails

[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279454#comment-17279454 ] Jichao Wang edited comment on FLINK-21274 at 2/6/21, 7:37 AM: -- I want to

[GitHub] [flink] flinkbot edited a comment on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

flinkbot edited a comment on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772256636 ## CI report: * e3f1c5f58b32c0c0804eedf5616f7dce4d8ccb01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

flinkbot edited a comment on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772256636 ## CI report: * e3f1c5f58b32c0c0804eedf5616f7dce4d8ccb01 Azure:

[jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280055#comment-17280055 ] jiguodai edited comment on FLINK-21309 at 2/6/21, 3:05 AM: --- [~chesnay] my

[jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280055#comment-17280055 ] jiguodai edited comment on FLINK-21309 at 2/6/21, 3:03 AM: --- [~chesnay] my

[jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiguodai updated FLINK-21309: - Description:     When a flink job run on yarn, metrics of jobmanager and taskmanagers will  overwrite

[jira] [Closed] (FLINK-21066) Refactor the CheckpointCoordinator to compute the tasks to trigger/wait/commit dynamically

[ https://issues.apache.org/jira/browse/FLINK-21066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-21066. - Fix Version/s: 1.13.0 Resolution: Fixed > Refactor the CheckpointCoordinator to compute the

[jira] [Commented] (FLINK-21066) Refactor the CheckpointCoordinator to compute the tasks to trigger/wait/commit dynamically

[ https://issues.apache.org/jira/browse/FLINK-21066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280058#comment-17280058 ] Guowei Ma commented on FLINK-21066: --- Merged on master with 2d4038721e1481222f67f8d283e7f8e239475839 >

[jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiguodai updated FLINK-21309: - Description:     When a flink job run on yarn, metrics of jobmanager and taskmanagers will  overwrite

[GitHub] [flink] guoweiM closed pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM closed pull request #14734: URL: https://github.com/apache/flink/pull/14734 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] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280055#comment-17280055 ] jiguodai edited comment on FLINK-21309 at 2/6/21, 2:51 AM: --- [~chesnay] my

[jira] [Commented] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280055#comment-17280055 ] jiguodai commented on FLINK-21309: -- my solution is as below : {code:java} public class

[jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiguodai updated FLINK-21309: - Description:     When a flink job run on yarn, metrics of jobmanager and taskmanagers will  overwrite

[jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiguodai updated FLINK-21309: - Description:     When a flink job run on yarn, metrics of jobmanager and taskmanagers will  overwrite

[jira] [Created] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

jiguodai created FLINK-21309: Summary: Metrics of JobManager and TaskManager overwrite each other in pushgateway Key: FLINK-21309 URL: https://issues.apache.org/jira/browse/FLINK-21309 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14881: [hotfix][state] Improve logging in AbstractKeyedStateBackend

flinkbot edited a comment on pull request #14881: URL: https://github.com/apache/flink/pull/14881#issuecomment-774272115 ## CI report: * 86d913f12aa1f2c57166457922b0e42ccf06c8bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 0d67a18f44b0101a72efca0b305727f8dfba201b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14881: [hotfix][state] Improve logging in AbstractKeyedStateBackend

flinkbot edited a comment on pull request #14881: URL: https://github.com/apache/flink/pull/14881#issuecomment-774272115 ## CI report: * 86d913f12aa1f2c57166457922b0e42ccf06c8bf Azure:

[GitHub] [flink] flinkbot commented on pull request #14881: [hotfix][state] Improve logging in AbstractKeyedStateBackend

flinkbot commented on pull request #14881: URL: https://github.com/apache/flink/pull/14881#issuecomment-774272115 ## CI report: * 86d913f12aa1f2c57166457922b0e42ccf06c8bf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #14881: [hotfix][state] Improve logging in AbstractKeyedStateBackend

flinkbot commented on pull request #14881: URL: https://github.com/apache/flink/pull/14881#issuecomment-774264203 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

[GitHub] [flink] rkhachatryan opened a new pull request #14881: [hotfix][state] Improve logging in AbstractKeyedStateBackend

rkhachatryan opened a new pull request #14881: URL: https://github.com/apache/flink/pull/14881 ## What is the purpose of the change A trivial change that slightly improves logging in `AbstractKeyedStateBackend` (motivated by work on FLIP-151 PoC). ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * 4c8bc864776e0923683d1e60a1da38a12e9a52d0 Azure:

[jira] [Comment Edited] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279900#comment-17279900 ] Eron Wright edited comment on FLINK-21307 at 2/5/21, 7:10 PM: -- Is it a

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279923#comment-17279923 ] Roman Khachatryan commented on FLINK-20376: --- Probably related to FLINK-19741. > Error in

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 0d67a18f44b0101a72efca0b305727f8dfba201b UNKNOWN *

[jira] [Comment Edited] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279900#comment-17279900 ] Eron Wright edited comment on FLINK-21307 at 2/5/21, 6:54 PM: -- Is it a

[jira] [Commented] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279900#comment-17279900 ] Eron Wright commented on FLINK-21307: - Is it a reasonable expectation that enforcing a security

[jira] [Commented] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279875#comment-17279875 ] Stephan Pelikan commented on FLINK-21308: - Sorry, the second link does not point where I wanted

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 0d67a18f44b0101a72efca0b305727f8dfba201b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14379: [FLINK-20563][hive] Support built-in functions for Hive versions prio…

flinkbot edited a comment on pull request #14379: URL: https://github.com/apache/flink/pull/14379#issuecomment-73009 ## CI report: * 6a41d5ec280646f3225637d4aad3b0830debfd95 Azure:

[jira] [Commented] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279870#comment-17279870 ] Stephan Pelikan commented on FLINK-21308: - I've created a draft:

[GitHub] [flink] flinkbot edited a comment on pull request #14880: [FLINK-21302][table-planner-blink] Fix NPE when use row_number() in over agg

flinkbot edited a comment on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-774029330 ## CI report: * 958d56cf87affe70f80257b1464d572bc86fe4b1 Azure:

[jira] [Closed] (FLINK-20978) Implement HeapSavepointRestoreOperation

[ https://issues.apache.org/jira/browse/FLINK-20978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-20978. Resolution: Implemented Implemented in master via:

[GitHub] [flink] dawidwys closed pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

dawidwys closed pull request #14648: URL: https://github.com/apache/flink/pull/14648 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] tillrohrmann commented on a change in pull request #14837: [FLINK-20417][k8s] Create a new watcher when the old one is closed with HTTP_GONE

tillrohrmann commented on a change in pull request #14837: URL: https://github.com/apache/flink/pull/14837#discussion_r571130872 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java ## @@ -360,7 +364,12 @@ public void

[jira] [Comment Edited] (FLINK-21051) SQLClientSchemaRegistryITCase unstable with InternalServerErrorException: Status 500

[ https://issues.apache.org/jira/browse/FLINK-21051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279844#comment-17279844 ] Dawid Wysakowicz edited comment on FLINK-21051 at 2/5/21, 5:36 PM: ---

[jira] [Commented] (FLINK-21051) SQLClientSchemaRegistryITCase unstable with InternalServerErrorException: Status 500

[ https://issues.apache.org/jira/browse/FLINK-21051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279844#comment-17279844 ] Dawid Wysakowicz commented on FLINK-21051: -- The last few instances from [~roman_khachatryan]

[GitHub] [flink] tillrohrmann commented on a change in pull request #14874: [FLINK-21102] Add ScaleUpController for declarative scheduler

tillrohrmann commented on a change in pull request #14874: URL: https://github.com/apache/flink/pull/14874#discussion_r571124837 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/scalingpolicy/ScaleUpControllerTest.java ## @@ -0,0 +1,47

[jira] [Commented] (FLINK-21051) SQLClientSchemaRegistryITCase unstable with InternalServerErrorException: Status 500

[ https://issues.apache.org/jira/browse/FLINK-21051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279831#comment-17279831 ] Till Rohrmann commented on FLINK-21051: --- Another instance:

[GitHub] [flink] flinkbot edited a comment on pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

flinkbot edited a comment on pull request #14734: URL: https://github.com/apache/flink/pull/14734#issuecomment-766092219 ## CI report: * 39b84b60a20f67d813599bcea74ebbc28e9be573 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

gaoyunhaii commented on pull request #14831: URL: https://github.com/apache/flink/pull/14831#issuecomment-774166223 Hi @pnowojski , very thanks for the review and deep thoughts! I first tried to have a consideration for the general concerns. For the first issue, previously Roman and

[jira] [Updated] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11838: -- Issue Type: New Feature (was: Improvement) > Create RecoverableWriter for GCS >

[jira] [Updated] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11838: -- Fix Version/s: 1.13.0 > Create RecoverableWriter for GCS > >

[jira] [Updated] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11838: -- Labels: pull-request-available usability (was: pull-request-available) > Create

[GitHub] [flink] tillrohrmann commented on pull request #14798: [FLINK-21187] Provide exception history for root causes

tillrohrmann commented on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-774160353 Thanks for the update. I'll merge this PR once AZP has completed. This is an automated message from the

[jira] [Closed] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata for c

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-21250. - Resolution: Not A Problem Information provided. > Failure to finalize checkpoint due to >

[jira] [Commented] (FLINK-21248) Checkpoint problem in 1.12.0

[ https://issues.apache.org/jira/browse/FLINK-21248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279800#comment-17279800 ] Till Rohrmann commented on FLINK-21248: --- Thanks for letting us know. JDK bugs are usually very

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14848: [FLINK-21268]Fix scrolling issue in Firefox

flinkbot edited a comment on pull request #14848: URL: https://github.com/apache/flink/pull/14848#issuecomment-772400043 ## CI report: * 598b59820a6278418c9ef7a5c516361e2c89c170 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[jira] [Created] (FLINK-21308) Cancel "sendAfter"

Stephan Pelikan created FLINK-21308: --- Summary: Cancel "sendAfter" Key: FLINK-21308 URL: https://issues.apache.org/jira/browse/FLINK-21308 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on pull request #14851: [FLINK-21098][coordination] Add SlotAllocator

flinkbot edited a comment on pull request #14851: URL: https://github.com/apache/flink/pull/14851#issuecomment-772551657 ## CI report: * c1ab87a91c4bc00156949eebba4ecd5e67740caf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14848: [FLINK-21268]Fix scrolling issue in Firefox

flinkbot edited a comment on pull request #14848: URL: https://github.com/apache/flink/pull/14848#issuecomment-772400043 ## CI report: * 598b59820a6278418c9ef7a5c516361e2c89c170 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[jira] [Updated] (FLINK-21268) Logs view can't scroll in Firefox

[ https://issues.apache.org/jira/browse/FLINK-21268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21268: --- Labels: pull-request-available (was: ) > Logs view can't scroll in Firefox >

[GitHub] [flink] pnowojski commented on pull request #14848: [FLINK-21268]Fix scrolling issue in Firefox

pnowojski commented on pull request #14848: URL: https://github.com/apache/flink/pull/14848#issuecomment-774124578 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Comment Edited] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279761#comment-17279761 ] Piotr Nowojski edited comment on FLINK-21307 at 2/5/21, 3:50 PM: - I have

[jira] [Comment Edited] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279761#comment-17279761 ] Piotr Nowojski edited comment on FLINK-21307 at 2/5/21, 3:40 PM: - I have

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21307: --- Fix Version/s: 1.13.0 > Revisit activation model of FlinkSecurityManager >

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21307: --- Priority: Critical (was: Major) > Revisit activation model of FlinkSecurityManager >

[jira] [Commented] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279761#comment-17279761 ] Piotr Nowojski commented on FLINK-21307: I have two concerns here. 1. I think currently there

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21307: --- Issue Type: Bug (was: Improvement) > Revisit activation model of FlinkSecurityManager >

[jira] [Commented] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

[ https://issues.apache.org/jira/browse/FLINK-21306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279754#comment-17279754 ] Piotr Nowojski commented on FLINK-21306: I would like to clarify here. This ticket is about a

[GitHub] [flink] rmetzger commented on a change in pull request #14790: [FLINK-21134] Introduce 'execution-mode' config option

rmetzger commented on a change in pull request #14790: URL: https://github.com/apache/flink/pull/14790#discussion_r571044740 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -358,6 +359,18 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * 5910b1a876d28886a8b5f87c09e67d75d2a45cd3 Azure:

[jira] [Comment Edited] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279743#comment-17279743 ] Piotr Nowojski edited comment on FLINK-17726 at 2/5/21, 3:13 PM: - We

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279743#comment-17279743 ] Piotr Nowojski commented on FLINK-17726: We have discovered this issue once we introduced a bug,

[GitHub] [flink] rmetzger closed pull request #14870: [FLINK-21254] Add Created state for DeclarativeScheduler

rmetzger closed pull request #14870: URL: https://github.com/apache/flink/pull/14870 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

[jira] [Closed] (FLINK-21254) Add DeclarativeScheduler / Created state

[ https://issues.apache.org/jira/browse/FLINK-21254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21254. -- Resolution: Fixed Merged to master in

[GitHub] [flink] rmetzger commented on pull request #14870: [FLINK-21254] Add Created state for DeclarativeScheduler

rmetzger commented on pull request #14870: URL: https://github.com/apache/flink/pull/14870#issuecomment-774091728 Thanks a lot for your review! Merging ... This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

[ https://issues.apache.org/jira/browse/FLINK-21306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279734#comment-17279734 ] Robert Metzger commented on FLINK-21306: I propose introducing a

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * 5910b1a876d28886a8b5f87c09e67d75d2a45cd3 Azure:

[jira] [Created] (FLINK-21307) Revisit activation model of FlinkSecurityManager

Robert Metzger created FLINK-21307: -- Summary: Revisit activation model of FlinkSecurityManager Key: FLINK-21307 URL: https://issues.apache.org/jira/browse/FLINK-21307 Project: Flink Issue

[GitHub] [flink] XComp commented on pull request #14798: [FLINK-21187] Provide exception history for root causes

XComp commented on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-774075110 @tillrohrmann I addressed all comments, squashed the changes and rebased the branch. This is an automated

[jira] [Created] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

Robert Metzger created FLINK-21306: -- Summary: FlinkSecurityManager might avoid fatal system exits Key: FLINK-21306 URL: https://issues.apache.org/jira/browse/FLINK-21306 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14879: [FLINK-21256][FLINK-21257] Add Restarting and Executing state for declarative scheduler

flinkbot edited a comment on pull request #14879: URL: https://github.com/apache/flink/pull/14879#issuecomment-773936264 ## CI report: * 39d8cae57c588a6552cf246a22b30556022729d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

flinkbot edited a comment on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772256636 ## CI report: * e3f1c5f58b32c0c0804eedf5616f7dce4d8ccb01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

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

flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 04a3a8996bc66bb2d953d5bee380da1a5eff8eac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14379: [FLINK-20563][hive] Support built-in functions for Hive versions prio…

flinkbot edited a comment on pull request #14379: URL: https://github.com/apache/flink/pull/14379#issuecomment-73009 ## CI report: * 64460eaf888b0333b8aed626d48f66fd875997cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14842: [FLINK-21238][python] Support to close PythonFunctionFactory

flinkbot edited a comment on pull request #14842: URL: https://github.com/apache/flink/pull/14842#issuecomment-772256636 ## CI report: * 0083733d9b5cc9e1ce5183e6d889869cf0b6081d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14379: [FLINK-20563][hive] Support built-in functions for Hive versions prio…

flinkbot edited a comment on pull request #14379: URL: https://github.com/apache/flink/pull/14379#issuecomment-73009 ## CI report: * 64460eaf888b0333b8aed626d48f66fd875997cf Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279710#comment-17279710 ] Andy commented on FLINK-21301: -- [~jark] Thanks for your reply. Of course, we could set allow lateness to

[GitHub] [flink] pnowojski commented on a change in pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

pnowojski commented on a change in pull request #14831: URL: https://github.com/apache/flink/pull/14831#discussion_r570945552 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTest.java ## @@ -961,6 +965,52 @@ public

[GitHub] [flink] pnowojski commented on a change in pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

pnowojski commented on a change in pull request #14831: URL: https://github.com/apache/flink/pull/14831#discussion_r570940917 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CheckpointableOneInputStreamTask.java ## @@ -0,0 +1,49 @@

[GitHub] [flink] pnowojski commented on a change in pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

pnowojski commented on a change in pull request #14831: URL: https://github.com/apache/flink/pull/14831#discussion_r570906591 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AbstractNonSourceStreamTask.java ## @@ -0,0 +1,118 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #14880: [FLINK-21302][table-planner-blink] Fix NPE when use row_number() in over agg

flinkbot edited a comment on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-774029330 ## CI report: * 958d56cf87affe70f80257b1464d572bc86fe4b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14844: [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch

flinkbot edited a comment on pull request #14844: URL: https://github.com/apache/flink/pull/14844#issuecomment-772295878 ## CI report: * 2901a50f1cdbdbe923b53b1b9f1a6393b5193016 Azure:

  1   2   3   4   5   >