[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-13 Thread GitBox
wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r346167378 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#issuecomment-552497066 ## CI report: * 5875fa6d987995f327cffae7912c47f4dc51e944 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : SUCCESS

[jira] [Commented] (FLINK-14767) Remove TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR

2019-11-13 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973997#comment-16973997 ] vinoyang commented on FLINK-14767: -- [~gjy] WDYT? > Remove TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR

[jira] [Commented] (FLINK-14766) Remove volatile variable in ExecutionVertex

2019-11-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973996#comment-16973996 ] Zhu Zhu commented on FLINK-14766: - [~wind_ljy] According to Flink bylaw, please wait until you are

[jira] [Comment Edited] (FLINK-14766) Remove volatile variable in ExecutionVertex

2019-11-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973996#comment-16973996 ] Zhu Zhu edited comment on FLINK-14766 at 11/14/19 7:53 AM: --- [~wind_ljy]

[jira] [Created] (FLINK-14767) Remove TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR

2019-11-13 Thread vinoyang (Jira)
vinoyang created FLINK-14767: Summary: Remove TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR Key: FLINK-14767 URL: https://issues.apache.org/jira/browse/FLINK-14767 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 :

[jira] [Commented] (FLINK-14594) Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

2019-11-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973994#comment-16973994 ] Zhu Zhu commented on FLINK-14594: - Thanks for the proposal [~azagrebin]. With your proposed changes we

[jira] [Updated] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14717: --- Description: *Current* The job's exceptions just show current attempt’s exceptions in web UI. If the job

[jira] [Updated] (FLINK-14766) Remove volatile variable in ExecutionVertex

2019-11-13 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-14766: - Parent: FLINK-12036 Issue Type: Sub-task (was: Improvement) > Remove volatile variable in

[jira] [Commented] (FLINK-14766) Remove volatile variable in ExecutionVertex

2019-11-13 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973991#comment-16973991 ] Jiayi Liao commented on FLINK-14766: [~zhuzh] I'll submit a PR soon :) > Remove volatile variable

[GitHub] [flink] AT-Fieldless commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-13 Thread GitBox
AT-Fieldless commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#discussion_r346161694 ## File path:

[jira] [Updated] (FLINK-14730) Add pending slots for job

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14730: --- Description: *Current* If the resource requested by the job can‘t be satisfied by the cluster, the job

[jira] [Updated] (FLINK-14730) Add pending slots for job

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14730: --- Description: *Current* if the resource requested by the job can‘t be satisfied by the cluster, the job

[jira] [Commented] (FLINK-14766) Remove volatile variable in ExecutionVertex

2019-11-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973986#comment-16973986 ] Zhu Zhu commented on FLINK-14766: - Sounds good to me. cc [~gjy] > Remove volatile variable in

[GitHub] [flink] dmvk commented on a change in pull request #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive…

2019-11-13 Thread GitBox
dmvk commented on a change in pull request #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive… URL: https://github.com/apache/flink/pull/10175#discussion_r346160924 ## File path:

[GitHub] [flink] dmvk commented on a change in pull request #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive…

2019-11-13 Thread GitBox
dmvk commented on a change in pull request #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive… URL: https://github.com/apache/flink/pull/10175#discussion_r346160924 ## File path:

[GitHub] [flink] dmvk commented on a change in pull request #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive…

2019-11-13 Thread GitBox
dmvk commented on a change in pull request #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive… URL: https://github.com/apache/flink/pull/10175#discussion_r346160519 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN URL: https://github.com/apache/flink/pull/10187#issuecomment-553746982 ## CI report: * e1c1980b8e8715f9888d0cacb4eaa8bcd53a4af9 : PENDING

[GitHub] [flink] flinkbot commented on issue #10188: [FLINK-14066][python] Support to install pyflink in windows

2019-11-13 Thread GitBox
flinkbot commented on issue #10188: [FLINK-14066][python] Support to install pyflink in windows URL: https://github.com/apache/flink/pull/10188#issuecomment-553762988 ## CI report: * dc05221d34c50dbb1ec98a473eef66b4181eb8f5 : UNKNOWN Bot commands The @flinkbot

[jira] [Commented] (FLINK-13938) Use yarn public distributed cache to speed up containers launch

2019-11-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973983#comment-16973983 ] Zili Chen commented on FLINK-13938: --- I send a pull request towards this issue #10187. You can take a

[jira] [Updated] (FLINK-14730) Add pending slots for job

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14730: --- Description: *Current* if the resource requested by the job can‘t be satisfied by the cluster, the job

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346158809 ## File path:

[jira] [Updated] (FLINK-14738) Job which status is finished, get operator metric

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14738: --- Description: When the job is running, we can get the operator's metrics, such as [subtask index].

[GitHub] [flink] flinkbot edited a comment on issue #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#issuecomment-552497066 ## CI report: * 5875fa6d987995f327cffae7912c47f4dc51e944 : FAILURE

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346158429 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346158429 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124#issuecomment-551369957 ## CI report: * 4f26ef56d72e62c90fd32ce1ad30766a138405cd : SUCCESS

[GitHub] [flink] zhijiangW removed a comment on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

2019-11-13 Thread GitBox
zhijiangW removed a comment on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#issuecomment-553760932 Thanks @azagrebin for this fixing. Some background information to share from

[GitHub] [flink] zhijiangW commented on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

2019-11-13 Thread GitBox
zhijiangW commented on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#issuecomment-553760932 Thanks @azagrebin for this fixing. Some background information to share from my

[jira] [Created] (FLINK-14766) Remove volatile variable in ExecutionVertex

2019-11-13 Thread Jiayi Liao (Jira)
Jiayi Liao created FLINK-14766: -- Summary: Remove volatile variable in ExecutionVertex Key: FLINK-14766 URL: https://issues.apache.org/jira/browse/FLINK-14766 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14765) Remove STATE_UPDATER in Execution

2019-11-13 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973977#comment-16973977 ] vinoyang commented on FLINK-14765: -- [~azagrebin] and [~gjy] WDYT about this ticket? Can we remove this

[jira] [Updated] (FLINK-14765) Remove STATE_UPDATER in Execution

2019-11-13 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-14765: - Description: After making access to ExecutionGraph single-threaded in FLINK-11417, we can simplify

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 :

[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs.

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-549714188 ## CI report: * bdb7952a0a48b4e67f51a04db61cd96a1cbecbbc : FAILURE

[jira] [Updated] (FLINK-14738) Job which status is finished, get operator metric

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14738: --- Description: When the job is running, we could get operators' metrics. But when it's finished, only get

[jira] [Created] (FLINK-14765) Remove STATE_UPDATER in Execution

2019-11-13 Thread vinoyang (Jira)
vinoyang created FLINK-14765: Summary: Remove STATE_UPDATER in Execution Key: FLINK-14765 URL: https://issues.apache.org/jira/browse/FLINK-14765 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14740: --- Description: *In current design:* The DataSet job uses VertexID as the OperatorID in the

[jira] [Commented] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973973#comment-16973973 ] lining commented on FLINK-14740: I agree not to expose operator id in web UI. But the problem is

[GitHub] [flink] guoweiM commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-13 Thread GitBox
guoweiM commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#discussion_r345868426 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346153834 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346151056 ## File path:

[jira] [Updated] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job

2019-11-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14740: --- Description: In current design: The DataSet job uses VertexID as the OperatorID in the OperatorMetricGroup

[GitHub] [flink] flinkbot edited a comment on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN URL: https://github.com/apache/flink/pull/10187#issuecomment-553746982 ## CI report: * e1c1980b8e8715f9888d0cacb4eaa8bcd53a4af9 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions URL: https://github.com/apache/flink/pull/10186#issuecomment-553732980 ## CI report: * bc053af0629f4f0b8db14aaaddac474b0a750353 : FAILURE

[GitHub] [flink] guoweiM commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

2019-11-13 Thread GitBox
guoweiM commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10152#discussion_r346151236 ## File path: docs/_includes/generated/writable_configuration.html ##

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346151056 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124#issuecomment-551369957 ## CI report: * 4f26ef56d72e62c90fd32ce1ad30766a138405cd : SUCCESS

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346149933 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346135396 ## File path:

[GitHub] [flink] JingsongLi commented on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

2019-11-13 Thread GitBox
JingsongLi commented on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-553751930 > Add documentation to inform users when to use `FlinkOrcReader` v.s. `HiveRecordReader`? I

[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs.

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-549714188 ## CI report: * bdb7952a0a48b4e67f51a04db61cd96a1cbecbbc : FAILURE

[GitHub] [flink] JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

2019-11-13 Thread GitBox
JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r346149217 ## File path:

[GitHub] [flink] flinkbot commented on issue #10188: [FLINK-14066][python] Support to install pyflink in windows

2019-11-13 Thread GitBox
flinkbot commented on issue #10188: [FLINK-14066][python] Support to install pyflink in windows URL: https://github.com/apache/flink/pull/10188#issuecomment-553751552 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r346148941 ## File path:

[jira] [Updated] (FLINK-14066) Pyflink building failure in master and 1.9.0 version

2019-11-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14066: --- Labels: beginner build pull-request-available (was: beginner build) > Pyflink building

[GitHub] [flink] dianfu opened a new pull request #10188: [FLINK-14066][python] Support to install pyflink in windows

2019-11-13 Thread GitBox
dianfu opened a new pull request #10188: [FLINK-14066][python] Support to install pyflink in windows URL: https://github.com/apache/flink/pull/10188 ## What is the purpose of the change *This pull request adds support to install pyflink in windows.* ## Brief change log

[GitHub] [flink] JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

2019-11-13 Thread GitBox
JingsongLi commented on a change in pull request #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#discussion_r346148106 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r346147881 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r346143069 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r346121333 ## File path:

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

2019-11-13 Thread chen yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973957#comment-16973957 ] chen yong commented on FLINK-14531: --- [~gyfora] Sorry for not replying to you for a long time.I've

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r346144260 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r345662571 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r346141018 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r345665286 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r346140105 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-13 Thread GitBox
wuchong commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r346120431 ## File path: flink-table/flink-table-runtime-blink/pom.xml

[GitHub] [flink] flinkbot commented on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN

2019-11-13 Thread GitBox
flinkbot commented on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN URL: https://github.com/apache/flink/pull/10187#issuecomment-553746982 ## CI report: * e1c1980b8e8715f9888d0cacb4eaa8bcd53a4af9 : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124#issuecomment-551369957 ## CI report: * 4f26ef56d72e62c90fd32ce1ad30766a138405cd : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs.

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-549714188 ## CI report: * bdb7952a0a48b4e67f51a04db61cd96a1cbecbbc : FAILURE

[GitHub] [flink] wsry commented on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs.

2019-11-13 Thread GitBox
wsry commented on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-553741266 Thanks @zhijiangW . I have updated the PR and commit description.

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346139740 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346140200 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346139932 ## File path:

[GitHub] [flink] flinkbot commented on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN

2019-11-13 Thread GitBox
flinkbot commented on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN URL: https://github.com/apache/flink/pull/10187#issuecomment-553740506 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346139740 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
TisonKun commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346139693 ## File path:

[GitHub] [flink] TisonKun opened a new pull request #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN

2019-11-13 Thread GitBox
TisonKun opened a new pull request #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN URL: https://github.com/apache/flink/pull/10187 ## What is the purpose of the change Enable configure shared libraries on YARN. See also

[jira] [Updated] (FLINK-13938) Use yarn public distributed cache to speed up containers launch

2019-11-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13938: --- Labels: pull-request-available (was: ) > Use yarn public distributed cache to speed up

[GitHub] [flink] flinkbot edited a comment on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions URL: https://github.com/apache/flink/pull/10186#issuecomment-553732980 ## CI report: * bc053af0629f4f0b8db14aaaddac474b0a750353 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#issuecomment-549724300 ## CI report: * 0fca3b7914151ce638faa282a6c75096c6f404ed : FAILURE

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346135396 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346135396 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346135013 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346134785 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance

2019-11-13 Thread GitBox
zjffdu commented on a change in pull request #10104: [FLINK-14629][client] Refactor ScalaShellRemote(Stream)Environment to simplify inheritance URL: https://github.com/apache/flink/pull/10104#discussion_r346134481 ## File path:

[GitHub] [flink] flinkbot commented on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions

2019-11-13 Thread GitBox
flinkbot commented on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions URL: https://github.com/apache/flink/pull/10186#issuecomment-553732980 ## CI report: * bc053af0629f4f0b8db14aaaddac474b0a750353 : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10185: [FLINK-14762][client] Implement ClusterClientJobClientAdapter

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10185: [FLINK-14762][client] Implement ClusterClientJobClientAdapter URL: https://github.com/apache/flink/pull/10185#issuecomment-553711316 ## CI report: * 0e693452ffee7136507f8b1e57431dfba28f9647 : FAILURE

[GitHub] [flink] xintongsong commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

2019-11-13 Thread GitBox
xintongsong commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#discussion_r346132449 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

2019-11-13 Thread GitBox
xintongsong commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#discussion_r346129548 ## File path:

[GitHub] [flink] JingsongLi commented on issue #10183: [FLINK-14743][table-blink] Optimize BaseRowSerializer to use Projection instead of switch

2019-11-13 Thread GitBox
JingsongLi commented on issue #10183: [FLINK-14743][table-blink] Optimize BaseRowSerializer to use Projection instead of switch URL: https://github.com/apache/flink/pull/10183#issuecomment-553729738 > What I meant is runtime should only compile generated codes to class, all code

[GitHub] [flink] KurtYoung commented on issue #10183: [FLINK-14743][table-blink] Optimize BaseRowSerializer to use Projection instead of switch

2019-11-13 Thread GitBox
KurtYoung commented on issue #10183: [FLINK-14743][table-blink] Optimize BaseRowSerializer to use Projection instead of switch URL: https://github.com/apache/flink/pull/10183#issuecomment-553729348 What I meant is runtime should only compile generated codes to class, all code generation

[GitHub] [flink] JingsongLi commented on issue #10183: [FLINK-14743][table-blink] Optimize BaseRowSerializer to use Projection instead of switch

2019-11-13 Thread GitBox
JingsongLi commented on issue #10183: [FLINK-14743][table-blink] Optimize BaseRowSerializer to use Projection instead of switch URL: https://github.com/apache/flink/pull/10183#issuecomment-553726864 > -1, I don't think any code generation logic should happen during runtime. How

[GitHub] [flink] flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config

2019-11-13 Thread GitBox
flinkbot edited a comment on issue #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124#issuecomment-551369957 ## CI report: * 4f26ef56d72e62c90fd32ce1ad30766a138405cd : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions

2019-11-13 Thread GitBox
flinkbot commented on issue #10186: [FLINK-14759][flink-runtime]Remove unused class TaskManagerCliOptions URL: https://github.com/apache/flink/pull/10186#issuecomment-553725151 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

  1   2   3   4   5   6   >