[GitHub] [flink] flinkbot edited a comment on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown

flinkbot edited a comment on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown URL: https://github.com/apache/flink/pull/9767#issuecomment-534898951 ## CI report: * d0732c1e898be8e2bf6881687c546a669caf4808 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328958063 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328956925 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328977911 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328978082 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328964109 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329110530 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329106466 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329113614 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328963166 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328974880 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329101717 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328974100 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328970515 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329105818 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329109482 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328978190 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329112919 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328963109 ## File path:

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14254: - Summary: Introduce BatchFileSystemSink (was: Introduce FileSystemOutputFormat) > Introduce

[jira] [Created] (FLINK-14255) Introduce StreamingFileSystemSink

Jingsong Lee created FLINK-14255: Summary: Introduce StreamingFileSystemSink Key: FLINK-14255 URL: https://issues.apache.org/jira/browse/FLINK-14255 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14254: - Description: Introduce BatchFileSystemSink to support all table file system connector with

[jira] [Updated] (FLINK-10745) Serialization and copy improvements for record writer

[ https://issues.apache.org/jira/browse/FLINK-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10745: - Component/s: Runtime / Task > Serialization and copy improvements for record writer >

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[jira] [Created] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

Aljoscha Krettek created FLINK-14250: Summary: Introduce separate "bin/flink runpy" and remove python support from "bin/flink run" Key: FLINK-14250 URL: https://issues.apache.org/jira/browse/FLINK-14250

[jira] [Commented] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939427#comment-16939427 ] Aljoscha Krettek commented on FLINK-14250: -- This would be breaking for existing users that use

[GitHub] [flink] flinkbot edited a comment on issue #9663: [FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED

[GitHub] [flink] GJL opened a new pull request #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

GJL opened a new pull request #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785 ## What is the purpose of the change *Initialize `DefaultScheduler` with the correct

[jira] [Updated] (FLINK-14244) Use correct RestartBackoffTimeStrategy in new DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14244: --- Labels: pull-request-available (was: ) > Use correct RestartBackoffTimeStrategy in new

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329068200 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329055935 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329051847 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329054365 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329055349 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329067007 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329051310 ## File path: flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329063421 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r328688810 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r328682428 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329056494 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329052823 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329070304 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329064182 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329068246 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329071067 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329068779 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329058986 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r328682276 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329066092 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329060662 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329058300 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329058759 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r329051310 ## File path: flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java

[GitHub] [flink] danny0405 commented on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-535940983 Thanks @KurtYoung for the nice review, my personal CI has passed

[GitHub] [flink] GJL edited a comment on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

GJL edited a comment on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535942534 Thanks! Merging as soon as build is green.

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9786: [FLINK-14251] Add FutureUtils#forward utility

flinkbot commented on issue #9786: [FLINK-14251] Add FutureUtils#forward utility URL: https://github.com/apache/flink/pull/9786#issuecomment-535960500 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

[jira] [Updated] (FLINK-14249) Rework table partition support

[ https://issues.apache.org/jira/browse/FLINK-14249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14249: - Description: A partition is a division of a logical database or its constituent elements into

[GitHub] [flink] 1u0 commented on a change in pull request #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown

1u0 commented on a change in pull request #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown URL: https://github.com/apache/flink/pull/9767#discussion_r329113036 ## File path:

[jira] [Created] (FLINK-14257) Integrate csv to FileSystemTableFactory

Jingsong Lee created FLINK-14257: Summary: Integrate csv to FileSystemTableFactory Key: FLINK-14257 URL: https://issues.apache.org/jira/browse/FLINK-14257 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14258) Integrate hive to FileSystemTableFactory

Jingsong Lee created FLINK-14258: Summary: Integrate hive to FileSystemTableFactory Key: FLINK-14258 URL: https://issues.apache.org/jira/browse/FLINK-14258 Project: Flink Issue Type:

[jira] [Created] (FLINK-14256) Introduce FileSystemTableFactory

Jingsong Lee created FLINK-14256: Summary: Introduce FileSystemTableFactory Key: FLINK-14256 URL: https://issues.apache.org/jira/browse/FLINK-14256 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[jira] [Updated] (FLINK-14259) Extract JobManagerRunner interface for improved testability

[ https://issues.apache.org/jira/browse/FLINK-14259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14259: --- Labels: pull-request-available (was: ) > Extract JobManagerRunner interface for improved

[GitHub] [flink] tillrohrmann opened a new pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

tillrohrmann opened a new pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788 ## What is the purpose of the change This PR is based on #9787. This commit extracts the JobManagerRunner interface and renames the

[GitHub] [flink] tillrohrmann opened a new pull request #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

tillrohrmann opened a new pull request #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789 ## What is the purpose of the change This PR is based on #9788. The PR removes the Mockito usage from

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[jira] [Commented] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939438#comment-16939438 ] Kostas Kloudas commented on FLINK-14250: I think that this a pretty important clean-up. The

[GitHub] [flink] flinkbot commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

flinkbot commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535937544 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] GJL commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

GJL commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535942534 Thanks, merging as soon as build is green.

[GitHub] [flink] flinkbot commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

flinkbot commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535942248 ## CI report: * 93b155a5502cbc16ffdd382ac91708698f02f955 : UNKNOWN

[GitHub] [flink] zhuzhurk commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

zhuzhurk commented on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535942350 Thanks for opening this PR @GJL . The change looks good to me. +1 to merge it.

[GitHub] [flink] flinkbot edited a comment on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

flinkbot edited a comment on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535942248 ## CI report: * 93b155a5502cbc16ffdd382ac91708698f02f955 : PENDING

[GitHub] [flink] gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-535954197 I have made some currection of my implement.

[jira] [Created] (FLINK-14251) Add FutureUtils#forward utility

Till Rohrmann created FLINK-14251: - Summary: Add FutureUtils#forward utility Key: FLINK-14251 URL: https://issues.apache.org/jira/browse/FLINK-14251 Project: Flink Issue Type: Improvement

[GitHub] [flink] gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-535957708 @flinkbot run travis This is an

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[jira] [Created] (FLINK-14252) Encapsulate Dispatcher services in DispatcherServices container

Till Rohrmann created FLINK-14252: - Summary: Encapsulate Dispatcher services in DispatcherServices container Key: FLINK-14252 URL: https://issues.apache.org/jira/browse/FLINK-14252 Project: Flink

[GitHub] [flink] tillrohrmann opened a new pull request #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices

tillrohrmann opened a new pull request #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787 ## What is the purpose of the change This PR is based on #9786. The `DispatcherServices` container contains all

[jira] [Created] (FLINK-14253) Add hash distribution and sort grouping only when dynamic partition insert

Jingsong Lee created FLINK-14253: Summary: Add hash distribution and sort grouping only when dynamic partition insert Key: FLINK-14253 URL: https://issues.apache.org/jira/browse/FLINK-14253 Project:

[jira] [Updated] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

[ https://issues.apache.org/jira/browse/FLINK-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhilasha Seth updated FLINK-14175: --- Affects Version/s: 1.7.3 1.6.5 > Upgrade KPL version in

[jira] [Resolved] (FLINK-10745) Serialization and copy improvements for record writer

[ https://issues.apache.org/jira/browse/FLINK-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-10745. -- Resolution: Fixed > Serialization and copy improvements for record writer >

[GitHub] [flink] flinkbot commented on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface

flinkbot commented on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#issuecomment-535990059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility

flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility URL: https://github.com/apache/flink/pull/9786#issuecomment-535968595 ## CI report: * 426cd9dc6c60f5582848fa52f2fa5f76182c8125 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices

flinkbot edited a comment on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : FAILURE

[jira] [Updated] (FLINK-14260) Remove Mockito usage from TestingJobManagerRunnerFactory

[ https://issues.apache.org/jira/browse/FLINK-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14260: --- Labels: pull-request-available (was: ) > Remove Mockito usage from

[GitHub] [flink] flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-524181331 ## CI report: * 512499aae1ab33c5ae96c8a2100016e40d83b654 : CANCELED

[jira] [Comment Edited] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939438#comment-16939438 ] Kostas Kloudas edited comment on FLINK-14250 at 9/27/19 1:30 PM: - I

[GitHub] [flink] flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-524181331 ## CI report: * 512499aae1ab33c5ae96c8a2100016e40d83b654 : CANCELED

[jira] [Closed] (FLINK-14244) Use correct RestartBackoffTimeStrategy in new DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14244. Resolution: Fixed 1.10: 74f4a9f6f0b55b8569363ed95d4fa7dc379e0ce4 > Use correct

[GitHub] [flink] flinkbot commented on issue #9786: [FLINK-14251] Add FutureUtils#forward utility

flinkbot commented on issue #9786: [FLINK-14251] Add FutureUtils#forward utility URL: https://github.com/apache/flink/pull/9786#issuecomment-535968595 ## CI report: * 426cd9dc6c60f5582848fa52f2fa5f76182c8125 : UNKNOWN

[GitHub] [flink] GJL closed pull request #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

GJL closed pull request #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy

flinkbot edited a comment on issue #9785: [FLINK-14244][runtime] Initialize DefaultScheduler with correct RestartBackoffTimeStrategy URL: https://github.com/apache/flink/pull/9785#issuecomment-535942248 ## CI report: * 93b155a5502cbc16ffdd382ac91708698f02f955 : SUCCESS

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328955258 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326547702 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328971581 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328954394 ## File path:

  1   2   3   4   5   >