[jira] [Updated] (FLINK-21318) ExecutionContextTest.testCatalogs fail

2021-02-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21318: Description:

[jira] [Created] (FLINK-21332) Optimize releasing result partitions in RegionPartitionReleaseStrategy

2021-02-08 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21332: Summary: Optimize releasing result partitions in RegionPartitionReleaseStrategy Key: FLINK-21332 URL: https://issues.apache.org/jira/browse/FLINK-21332 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #14904: [WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-775639746 ## CI report: * 797afe4dcb649ffa6e1e761581389c6055af0c9c Azure:

[jira] [Created] (FLINK-21331) Optimize calculating tasks to restart in RestartPipelinedRegionFailoverStrategy

2021-02-08 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21331: Summary: Optimize calculating tasks to restart in RestartPipelinedRegionFailoverStrategy Key: FLINK-21331 URL: https://issues.apache.org/jira/browse/FLINK-21331

[jira] [Updated] (FLINK-21110) Optimize scheduler performance for large-scale jobs

2021-02-08 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21110: - Summary: Optimize scheduler performance for large-scale jobs (was: Optimize Scheduler

[jira] [Updated] (FLINK-21330) Optimize the initialization of PipelinedRegionSchedulingStrategy

2021-02-08 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21330: - Summary: Optimize the initialization of PipelinedRegionSchedulingStrategy (was: Optimization

[jira] [Updated] (FLINK-21328) Optimize the initialization of DefaultExecutionTopology

2021-02-08 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21328: - Description: Based on FLINK-21326, the {{consumedResults}} in {{DefaultExecutionVertex}} and

[jira] [Updated] (FLINK-21330) Optimization the initialization of PipelinedRegionSchedulingStrategy

2021-02-08 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21330: - Description: PipelinedRegionSchedulingStrategy is used for task scheduling. Its initialization

[GitHub] [flink] flinkbot edited a comment on pull request #14906: [FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFut

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14906: URL: https://github.com/apache/flink/pull/14906#issuecomment-775715265 ## CI report: * 2951f7e582aecc00293b92003de99c6bf84aa470 Azure:

[jira] [Created] (FLINK-21330) Optimization the initialization of PipelinedRegionSchedulingStrategy

2021-02-08 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21330: Summary: Optimization the initialization of PipelinedRegionSchedulingStrategy Key: FLINK-21330 URL: https://issues.apache.org/jira/browse/FLINK-21330 Project: Flink

[GitHub] [flink] becketqin commented on a change in pull request #14789: [FLINK-21159][connector/kafka] Send NoMoreSplitsEvent to all readers even if the reader is not assigned with any splits

2021-02-08 Thread GitBox
becketqin commented on a change in pull request #14789: URL: https://github.com/apache/flink/pull/14789#discussion_r572647867 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java ## @@

[jira] [Closed] (FLINK-21102) Add ScaleUpController

2021-02-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21102. -- Resolution: Fixed Merged to master in

[GitHub] [flink] rmetzger merged pull request #14874: [FLINK-21102] Add ScaleUpController for declarative scheduler

2021-02-08 Thread GitBox
rmetzger merged pull request #14874: URL: https://github.com/apache/flink/pull/14874 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] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-08 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281581#comment-17281581 ] Matthias commented on FLINK-21133: -- Findings mentioned in duplicate FLINK-21323: {quote} When looking

[jira] [Closed] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask

2021-02-08 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-21323. Resolution: Duplicate Thanks for looking into this, [~roman_khachatryan] and [~kezhuw]. I guess, you're

[jira] [Created] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

2021-02-08 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21329: -- Summary: "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds Key: FLINK-21329 URL: https://issues.apache.org/jira/browse/FLINK-21329

[GitHub] [flink] rmetzger commented on pull request #14874: [FLINK-21102] Add ScaleUpController for declarative scheduler

2021-02-08 Thread GitBox
rmetzger commented on pull request #14874: URL: https://github.com/apache/flink/pull/14874#issuecomment-775727039 Created JIRA for the failed e2e: https://issues.apache.org/jira/browse/FLINK-21329 This is an automated

[jira] [Created] (FLINK-21328) Optimize the initialization of DefaultExecutionTopology

2021-02-08 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21328: Summary: Optimize the initialization of DefaultExecutionTopology Key: FLINK-21328 URL: https://issues.apache.org/jira/browse/FLINK-21328 Project: Flink

[jira] [Created] (FLINK-21327) Support window TVF in batch mode

2021-02-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-21327: --- Summary: Support window TVF in batch mode Key: FLINK-21327 URL: https://issues.apache.org/jira/browse/FLINK-21327 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-21327) Support window TVF in batch mode

2021-02-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21327: Description: As a batch and streaming unified engine, we should also support to run window TVF in batch

[GitHub] [flink] flinkbot commented on pull request #14906: [FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFuture().g

2021-02-08 Thread GitBox
flinkbot commented on pull request #14906: URL: https://github.com/apache/flink/pull/14906#issuecomment-775715265 ## CI report: * 2951f7e582aecc00293b92003de99c6bf84aa470 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-21326) Optimize building topology when initializing ExecutionGraph

2021-02-08 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21326: Summary: Optimize building topology when initializing ExecutionGraph Key: FLINK-21326 URL: https://issues.apache.org/jira/browse/FLINK-21326 Project: Flink

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

2021-02-08 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281569#comment-17281569 ] Yun Tang commented on FLINK-21321: -- I think this is an interesting idea. Though I have not tracked the

[GitHub] [flink] flinkbot commented on pull request #14906: [FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFuture().g

2021-02-08 Thread GitBox
flinkbot commented on pull request #14906: URL: https://github.com/apache/flink/pull/14906#issuecomment-775707192 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] flinkbot edited a comment on pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14895: URL: https://github.com/apache/flink/pull/14895#issuecomment-774905526 ## CI report: * Unknown: [CANCELED](TBD) * f85e0cb64c50146c1be7a040c91c48128e140bc5 Azure:

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

2021-02-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21274: --- Labels: pull-request-available (was: ) > At per-job mode, during the exit of the

[jira] [Commented] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask

2021-02-08 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281568#comment-17281568 ] Kezhu Wang commented on FLINK-21323: [~mapohl] [~roman_khachatryan] [~pnowojski] Maybe we can

[GitHub] [flink] wjc920 opened a new pull request #14906: [FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFuture().get

2021-02-08 Thread GitBox
wjc920 opened a new pull request #14906: URL: https://github.com/apache/flink/pull/14906 ## What is the purpose of the change In some cases we don't have non-daemon thread remaining which causes the JVM to terminate before all tasks have been completed. To solve this

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-02-08 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281563#comment-17281563 ] Kezhu Wang commented on FLINK-21132: {quote}I saw a hole in notifyCheckpointAbortAsync where there

[GitHub] [flink] aimiebell commented on a change in pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-02-08 Thread GitBox
aimiebell commented on a change in pull request #14754: URL: https://github.com/apache/flink/pull/14754#discussion_r572622956 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -1095,7 +1084,7 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14895: URL: https://github.com/apache/flink/pull/14895#issuecomment-774905526 ## CI report: * Unknown: [CANCELED](TBD) * f85e0cb64c50146c1be7a040c91c48128e140bc5 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] LadyForest commented on pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-08 Thread GitBox
LadyForest commented on pull request #14895: URL: https://github.com/apache/flink/pull/14895#issuecomment-775689515 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14905: URL: https://github.com/apache/flink/pull/14905#issuecomment-775660513 ## CI report: * 7908eb32eee9fba4b38936424fe8e40a6be209d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14905: URL: https://github.com/apache/flink/pull/14905#issuecomment-775660513 ## CI report: * 7908eb32eee9fba4b38936424fe8e40a6be209d2 Azure:

[jira] [Assigned] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

2021-02-08 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-20950: - Assignee: Guowei Ma > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed

[GitHub] [flink] flinkbot commented on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

2021-02-08 Thread GitBox
flinkbot commented on pull request #14905: URL: https://github.com/apache/flink/pull/14905#issuecomment-775660513 ## CI report: * 7908eb32eee9fba4b38936424fe8e40a6be209d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14904: [WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-775639746 ## CI report: * 797afe4dcb649ffa6e1e761581389c6055af0c9c Azure:

[GitHub] [flink] flinkbot commented on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

2021-02-08 Thread GitBox
flinkbot commented on pull request #14905: URL: https://github.com/apache/flink/pull/14905#issuecomment-775654551 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

[jira] [Updated] (FLINK-19608) Support window TVF based window aggreagte in planner

2021-02-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19608: --- Labels: pull-request-available (was: ) > Support window TVF based window aggreagte in

[GitHub] [flink] wuchong opened a new pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

2021-02-08 Thread GitBox
wuchong opened a new pull request #14905: URL: https://github.com/apache/flink/pull/14905 ## What is the purpose of the change Support window TVF based window aggreagte in planner. We should be able to end-to-end run the new window aggregate syntax after this PR. ##

[GitHub] [flink] flinkbot edited a comment on pull request #14904: [WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-775639746 ## CI report: * 797afe4dcb649ffa6e1e761581389c6055af0c9c Azure:

[GitHub] [flink] wenlong88 commented on a change in pull request #14878: [FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization

2021-02-08 Thread GitBox
wenlong88 commented on a change in pull request #14878: URL: https://github.com/apache/flink/pull/14878#discussion_r570897982 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/FlinkDeserializationContext.java

[GitHub] [flink] flinkbot commented on pull request #14904: [WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

2021-02-08 Thread GitBox
flinkbot commented on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-775639746 ## CI report: * 797afe4dcb649ffa6e1e761581389c6055af0c9c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

2021-02-08 Thread GitBox
PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-775638451 @wangyang0918 err...i have no idea about `StandaloneApplicationClusterEntryPoint` actually. so you mean `StandaloneApplicationClusterEntryPoint` also have the issue? and the fix

[GitHub] [flink] flinkbot commented on pull request #14904: [WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

2021-02-08 Thread GitBox
flinkbot commented on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-775636912 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

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-08 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Description: I have five stream jobs and want to clear all states in jobs, so I canceled all

[jira] [Updated] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20663: --- Labels: pull-request-available (was: ) > Managed memory may not be released in time when

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-08 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-21325: Description: I have five stream jobs and want to clear all states in jobs, so I canceled all

[GitHub] [flink] xintongsong opened a new pull request #14904: [WIP][FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

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

[jira] [Created] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

2021-02-08 Thread hayden zhou (Jira)
hayden zhou created FLINK-21325: --- Summary: NoResourceAvailableException while cancel then resubmit jobs Key: FLINK-21325 URL: https://issues.apache.org/jira/browse/FLINK-21325 Project: Flink

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

2021-02-08 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281492#comment-17281492 ] Kezhu Wang commented on FLINK-17170: {quote} In stop-with-savepoint path,

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

2021-02-08 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281491#comment-17281491 ] Kezhu Wang commented on FLINK-17170: I think it is problem of {{FlinkKinesisConsumer.cancel}}, it

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

2021-02-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281488#comment-17281488 ] Xintong Song commented on FLINK-11838: -- Thanks for the information. FYI, the Chinese New Year

[GitHub] [flink] wangyang0918 commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

2021-02-08 Thread GitBox
wangyang0918 commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-775610643 @PChou What I mean is adding a private method `ClassPathPackagedProgramRetriever#buildUserClassPaths`. It will be used to initialize the `userClassPaths` variable in

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

2021-02-08 Thread GitBox
KarmaGYZ commented on a change in pull request #14897: URL: https://github.com/apache/flink/pull/14897#discussion_r572517152 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ResourceCounter.java ## @@ -35,11 +37,12 @@ * associated counts. The counts

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

2021-02-08 Thread GitBox
KarmaGYZ commented on a change in pull request #14897: URL: https://github.com/apache/flink/pull/14897#discussion_r572517152 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ResourceCounter.java ## @@ -35,11 +37,12 @@ * associated counts. The counts

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

2021-02-08 Thread GitBox
KarmaGYZ commented on a change in pull request #14897: URL: https://github.com/apache/flink/pull/14897#discussion_r572511815 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ResourceCounter.java ## @@ -35,11 +37,12 @@ * associated counts. The counts

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

2021-02-08 Thread GitBox
KarmaGYZ commented on a change in pull request #14897: URL: https://github.com/apache/flink/pull/14897#discussion_r572511815 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ResourceCounter.java ## @@ -35,11 +37,12 @@ * associated counts. The counts

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

2021-02-08 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281481#comment-17281481 ] Galen Warren commented on FLINK-11838: -- Thanks, that all sounds reasonable. I'll take a look at the

[jira] [Commented] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask

2021-02-08 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281480#comment-17281480 ] Kezhu Wang commented on FLINK-21323: [~mapohl]  [~roman_khachatryan] FLIP-27 sources could be

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 82de9d36ff5364984912c935c60c39a623dec537 Azure:

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

2021-02-08 Thread GitBox
PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-775585080 @wangyang0918 `ClassPathPackagedProgramRetriever` is an implementation of `PackagedProgramRetrieve` which only define method `getPackagedProgram`, that means callers should only

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 9406a10fbbc9a2ccf4cc08236184a9f76c076d43 Azure:

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

2021-02-08 Thread GitBox
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 #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 9406a10fbbc9a2ccf4cc08236184a9f76c076d43 Azure:

[GitHub] [flink] Jason-liujc commented on pull request #5415: [FLINK-3655] [core] Support multiple paths in FileInputFormat

2021-02-08 Thread GitBox
Jason-liujc commented on pull request #5415: URL: https://github.com/apache/flink/pull/5415#issuecomment-775567716 Yea I basically cloned the source code for `ContinuousFileMonitoringFunction` and added the reading from multiple directories capability to it. I can't really share

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 47c27930dce7d7ea2dee3d0f434fe2511ab5 Azure:

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

2021-02-08 Thread GitBox
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] [Commented] (FLINK-21196) Sensitive information(password) is in plain text format in flink-conf.yaml configuration file

2021-02-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281462#comment-17281462 ] Chesnay Schepler commented on FLINK-21196: -- Security-wise we usually only focus on external

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 521acd6627e3b85ab8ef7386cae10728fd97db9c Azure:

[GitHub] [flink] sjwiesman edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
sjwiesman edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775546460 I've fixed the whitespace and added an arrow to the rest API docs. I'm still struggling with the side nav, I'll keep working on it tomorrow.

[GitHub] [flink] sjwiesman commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
sjwiesman commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775546460 I've fixed the whitespace and added an arrow to the rest API docs. I'm still struggling with the side bar, I'll keep working on it tomorrow.

[GitHub] [flink] flinkbot edited a comment on pull request #14874: [FLINK-21102] Add ScaleUpController for declarative scheduler

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14874: URL: https://github.com/apache/flink/pull/14874#issuecomment-773408240 ## CI report: * 2f8766121adb3016eddb1e3145bd1cedd0a3da59 Azure:

[jira] [Commented] (FLINK-21211) Looking for reviews on a framework based on flink-statefun

2021-02-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281456#comment-17281456 ] Chesnay Schepler commented on FLINK-21211: -- You may have better chances with getting feedback

[jira] [Commented] (FLINK-21287) Failed to build flink source code

2021-02-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281452#comment-17281452 ] Chesnay Schepler commented on FLINK-21287: -- Can you give us the full maven output? > Failed to

[jira] [Closed] (FLINK-21314) Airflow | Edit DAG code from the UI

2021-02-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21314. Resolution: Invalid Head over to https://github.com/apache/airflow. > Airflow | Edit DAG

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

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 34720c9f7ea37afb5d7f3d2a824b78fee916b755 Azure:

[GitHub] [flink] sjwiesman edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
sjwiesman edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775465028 @zentol I've updated the styling for the rest API and configurations. Additonally, I've externalized the css to `_custom.scss` so if we want to continue to tweak it

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

2021-02-08 Thread GitBox
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] [Commented] (FLINK-21324) statefun-testutil can't assert messages function sends to itself

2021-02-08 Thread Timur (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281421#comment-17281421 ] Timur commented on FLINK-21324: --- Please review pull request that fixes this bug 

[jira] [Updated] (FLINK-21324) statefun-testutil can't assert messages function sends to itself

2021-02-08 Thread Timur (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timur updated FLINK-21324: -- Description: Assertions don't work for messages sent by functions to themselves. The reason is that

[GitHub] [flink-statefun] f1xmAn opened a new pull request #199: fix assertions for messages function sends to itself

2021-02-08 Thread GitBox
f1xmAn opened a new pull request #199: URL: https://github.com/apache/flink-statefun/pull/199 Here is the bug this PR fixes https://issues.apache.org/jira/browse/FLINK-21324 This is an automated message from the Apache Git

[GitHub] [flink] zentol commented on a change in pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
zentol commented on a change in pull request #14903: URL: https://github.com/apache/flink/pull/14903#discussion_r572422797 ## File path: flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java ## @@ -220,32 +220,42 @@ private static String

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

2021-02-08 Thread GitBox
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-21324) statefun-testutil can't assert messages function sends to itself

2021-02-08 Thread Timur (Jira)
Timur created FLINK-21324: - Summary: statefun-testutil can't assert messages function sends to itself Key: FLINK-21324 URL: https://issues.apache.org/jira/browse/FLINK-21324 Project: Flink Issue

[GitHub] [flink] zentol commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
zentol commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775488365 When some item in the sidebar is expanded such that the scrollbar appears everything is getting resized. Ideally it should just appear without things shifting around.

[GitHub] [flink] flinkbot edited a comment on pull request #14902: [FLINK-21138][queryableState] - User ClassLoader in KvStateServerHandler

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14902: URL: https://github.com/apache/flink/pull/14902#issuecomment-775312905 ## CI report: * 7739e63ba32156084a9c9f5dc47d681c62a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 521acd6627e3b85ab8ef7386cae10728fd97db9c Azure:

[GitHub] [flink] zentol commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
zentol commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775486659 The issue with headings having massive whitespace above them is due to `margin-top` and `padding-top` being set. Either would do the trick I think. (throwing both out isn't so

[GitHub] [flink] zentol commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
zentol commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775484371 I think the code tabs have lost a bit of clarity; it's not immediately obvious that you can click them in the first place.

[GitHub] [flink] zentol commented on a change in pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
zentol commented on a change in pull request #14903: URL: https://github.com/apache/flink/pull/14903#discussion_r572395853 ## File path: flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java ## @@ -220,32 +220,42 @@ private static String

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 521acd6627e3b85ab8ef7386cae10728fd97db9c Azure:

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

2021-02-08 Thread GitBox
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] sjwiesman commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
sjwiesman commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775465028 @zentol I've updated the styling for the rest API and configurations. Additonally, I've externalized the css to ` so if we want to continue to tweak it that's where you

[jira] [Commented] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask

2021-02-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281373#comment-17281373 ] Roman Khachatryan commented on FLINK-21323: --- Probably a duplicate of FLINK-21133. >

[GitHub] [flink-training] xhudik opened a new pull request #17: Readme updated

2021-02-08 Thread GitBox
xhudik opened a new pull request #17: URL: https://github.com/apache/flink-training/pull/17 small changes in Readmes This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-training] xhudik closed pull request #16: added link + typo

2021-02-08 Thread GitBox
xhudik closed pull request #16: URL: https://github.com/apache/flink-training/pull/16 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] flinkbot edited a comment on pull request #14900: (1.12) [FLINK-21312][checkpointing] Reset OperatorChain.isStoppingBySyncSavуpoint properly

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14900: URL: https://github.com/apache/flink/pull/14900#issuecomment-775088580 ## CI report: * 18ad713d9f142ea56a521284d26c95746ee862e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 8f7a3dac732790d6b6de91dc2a68cf344ece945b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14892: [FLINK-21312][checkpointing] Reset OperatorChain.isStoppingBySyncSavуpoint properly

2021-02-08 Thread GitBox
flinkbot edited a comment on pull request #14892: URL: https://github.com/apache/flink/pull/14892#issuecomment-774773480 ## CI report: * 8d1c709aa79aed1e18324dbafef7b7bac305c452 Azure:

  1   2   3   4   >