[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[jira] [Closed] (FLINK-14075) Remove unnecessary resource close in JDBCOutputFormatTest.java

[ https://issues.apache.org/jira/browse/FLINK-14075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-14075. Release Note: Method has been removed in master branch. Resolution: Resolved > Remove unnece

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[jira] [Created] (FLINK-14075) Remove unnecessary resource close in JDBCOutputFormatTest.java

Canbin Zheng created FLINK-14075: Summary: Remove unnecessary resource close in JDBCOutputFormatTest.java Key: FLINK-14075 URL: https://issues.apache.org/jira/browse/FLINK-14075 Project: Flink

[jira] [Updated] (FLINK-13238) Reduce blink planner's testing time

[ https://issues.apache.org/jira/browse/FLINK-13238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13238: --- Description: The blink planner has an independent CI profile, but still exceeded 50 min limit from

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[jira] [Closed] (FLINK-13931) Support Hive version 2.0.x

[ https://issues.apache.org/jira/browse/FLINK-13931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13931. Resolution: Fixed master: 353de39cc7630b0843e8b395397d4e359dcb5b81 > Support Hive version 2.0.x > ---

[jira] [Commented] (FLINK-5312) Implement Standalone Setup v2.0

[ https://issues.apache.org/jira/browse/FLINK-5312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929598#comment-16929598 ] Elias Levy commented on FLINK-5312: --- Curious about the reasoning behind the Won't Do re

[GitHub] [flink] flinkbot edited a comment on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

flinkbot edited a comment on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-529525508 ## CI report: * dad3000d92fe91dec8ae8b5738c2d8241da010a5 : SUCCESS [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

flinkbot edited a comment on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-529525508 ## CI report: * dad3000d92fe91dec8ae8b5738c2d8241da010a5 : SUCCESS [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

flinkbot edited a comment on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-529525508 ## CI report: * dad3000d92fe91dec8ae8b5738c2d8241da010a5 : SUCCESS [Build](https://t

[GitHub] [flink] piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-531406061 @tillrohrmann - updated the review. Let me know if this matches what you were thinking regarding t

[jira] [Commented] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929556#comment-16929556 ] Elias Levy commented on FLINK-14002: Came here to open just tis ticket. {{KeyedSeria

[GitHub] [flink] flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531280132 ## CI report: * 1d9a395f8b3074d116697cf10fd0fd36cfeeeacb : SUCCESS [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531280132 ## CI report: * 1d9a395f8b3074d116697cf10fd0fd36cfeeeacb : SUCCESS [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531280132 ## CI report: * 1d9a395f8b3074d116697cf10fd0fd36cfeeeacb : SUCCESS [Build](https://travis-

[GitHub] [flink] tillrohrmann commented on a change in pull request #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

tillrohrmann commented on a change in pull request #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#discussion_r324345844 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSess

[GitHub] [flink] piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-531371824 Ok that sounds good @tillrohrmann. I'll take a stab at updating this with the logging + expire and

[jira] [Commented] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929494#comment-16929494 ] Till Rohrmann commented on FLINK-14074: --- This is strange, because {{UNKNOWN}} shou

[GitHub] [flink] tillrohrmann commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

tillrohrmann commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-531368773 Just out of curiosity what's preventing you from using vanilla Flink? The criteo fork seems to be

[GitHub] [flink] tillrohrmann commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

tillrohrmann commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-531368342 Thanks for getting back so quickly @piyushnarang. I'm a fan of small changes because it makes it e

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929489#comment-16929489 ] Till Rohrmann commented on FLINK-13748: --- Thanks for the analysis [~kkl0u]. I think

[jira] [Commented] (FLINK-14054) Enable checkpointing via job configuration

[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929459#comment-16929459 ] Jun Qin commented on FLINK-14054: - I think It makes sense to have a cluster level defaul

[jira] [Comment Edited] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929410#comment-16929410 ] Kostas Kloudas edited comment on FLINK-13748 at 9/13/19 6:43 PM: -

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929410#comment-16929410 ] Kostas Kloudas commented on FLINK-13748: [~carp84], Chesnay is on holidays curre

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

walterddr 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_r324283758 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/BatchOper

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

walterddr 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_r324285009 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/source/Ta

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

walterddr 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_r324287491 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/pipeline/PipelineStage.

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

walterddr 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_r324284778 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/BatchOper

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

walterddr 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_r324280609 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/AlgoOperator.jav

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

walterddr 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_r324284269 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/BatchOper

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929375#comment-16929375 ] Yu Li commented on FLINK-13748: --- [~Zentol] could you help answer Klou's question about how

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929374#comment-16929374 ] Yu Li commented on FLINK-13748: --- One failure observed in the release-1.9 cron job: https:

[GitHub] [flink] flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531280132 ## CI report: * 1d9a395f8b3074d116697cf10fd0fd36cfeeeacb : SUCCESS [Build](https://travis-

[GitHub] [flink] piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers

piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos scheduling behavior to reject all expired offers URL: https://github.com/apache/flink/pull/9652#issuecomment-531287055 Thanks for getting back @tillrohrmann. I was actually thinking about adding a couple of other knob

[GitHub] [flink] flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot edited a comment on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531280132 ## CI report: * 1d9a395f8b3074d116697cf10fd0fd36cfeeeacb : PENDING [Build](https://travis-

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324247575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324247575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324247575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324247575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324247575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r324247575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] flinkbot commented on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot commented on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531280132 ## CI report: * 1d9a395f8b3074d116697cf10fd0fd36cfeeeacb : UNKNOWN --

[GitHub] [flink] flinkbot commented on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

flinkbot commented on issue #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678#issuecomment-531275389 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929276#comment-16929276 ] Kostas Kloudas commented on FLINK-13748: The problem seems to be the relocation

[jira] [Updated] (FLINK-12362) Remove legacy container number config option for Flink on yarn

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12362: --- Labels: pull-request-available (was: ) > Remove legacy container number config option for F

[GitHub] [flink] yanghua opened a new pull request #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn

yanghua opened a new pull request #9678: [FLINK-12362] Remove legacy container number config option for Flink on yarn URL: https://github.com/apache/flink/pull/9678 ## What is the purpose of the change *This pull request removes legacy container number config option for Flink on

[GitHub] [flink] flinkbot edited a comment on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear…

flinkbot edited a comment on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear… URL: https://github.com/apache/flink/pull/8026#issuecomment-531243526 ## CI report: * f0b1b1472ad30223723cc878e89f378386137574 : SUCCESS [Build](https://travis-ci.com

[jira] [Comment Edited] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin edited comment on FLINK-13985 at 9/13/19 2:53 PM:

[jira] [Comment Edited] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin edited comment on FLINK-13985 at 9/13/19 2:52 PM:

[jira] [Comment Edited] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin edited comment on FLINK-13985 at 9/13/19 2:52 PM:

[jira] [Comment Edited] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin edited comment on FLINK-13985 at 9/13/19 2:51 PM:

[jira] [Comment Edited] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin edited comment on FLINK-13985 at 9/13/19 2:51 PM:

[jira] [Comment Edited] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin edited comment on FLINK-13985 at 9/13/19 2:51 PM:

[jira] [Commented] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929262#comment-16929262 ] Andrey Zagrebin commented on FLINK-13985: - Thanks for sharing the thoughts [~Ste

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929260#comment-16929260 ] vinoyang commented on FLINK-13025: -- thanks [~StephanEwen] [~lilyevsky], now we still ne

[jira] [Comment Edited] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

[ https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929206#comment-16929206 ] Anatolii Siuniaev edited comment on FLINK-8954 at 9/13/19 2:36 PM:

[jira] [Comment Edited] (FLINK-6993) Not reading recursive files in Batch by using readTextFile when file name contains _ in starting.

[ https://issues.apache.org/jira/browse/FLINK-6993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929241#comment-16929241 ] Andrey Zagrebin edited comment on FLINK-6993 at 9/13/19 2:24 PM: --

[jira] [Reopened] (FLINK-6993) Not reading recursive files in Batch by using readTextFile when file name contains _ in starting.

[ https://issues.apache.org/jira/browse/FLINK-6993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reopened FLINK-6993: Assignee: Andrey Zagrebin  I will add to the docs > Not reading recursive files in Batch

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929235#comment-16929235 ] Andrey Zagrebin commented on FLINK-13992: - [~Tison] makes sense to me, just @Non

[jira] [Assigned] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-13992: --- Assignee: TisonKun > Refactor Optional parameter in InputGateWithMetrics#updateMetr

[GitHub] [flink] flinkbot edited a comment on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear…

flinkbot edited a comment on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear… URL: https://github.com/apache/flink/pull/8026#issuecomment-531243526 ## CI report: * f0b1b1472ad30223723cc878e89f378386137574 : PENDING [Build](https://travis-ci.com

[jira] [Comment Edited] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929216#comment-16929216 ] Kostas Kloudas edited comment on FLINK-13748 at 9/13/19 1:54 PM: -

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929216#comment-16929216 ] Kostas Kloudas commented on FLINK-13748: If it does not get solved by the end of

[GitHub] [flink] flinkbot commented on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear…

flinkbot commented on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear… URL: https://github.com/apache/flink/pull/8026#issuecomment-531243526 ## CI report: * f0b1b1472ad30223723cc878e89f378386137574 : UNKNOWN

[jira] [Commented] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

[ https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929206#comment-16929206 ] Anatolii Siuniaev commented on FLINK-8954: -- Is it still an issue? I'd like to he

[jira] [Closed] (FLINK-5770) Flink yarn session stop in non-detached model

[ https://issues.apache.org/jira/browse/FLINK-5770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5770. Resolution: Abandoned > Flink yarn session stop in non-detached model > ---

[jira] [Commented] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929193#comment-16929193 ] Alexander Kasyanenko commented on FLINK-14074: -- Hi [~till.rohrmann], thanks

[jira] [Closed] (FLINK-5686) Print meaningful message when JM is lost

[ https://issues.apache.org/jira/browse/FLINK-5686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5686. Resolution: Not A Problem > Print meaningful message when JM is lost >

[jira] [Closed] (FLINK-5668) passing taskmanager configuration through taskManagerEnv instead of file

[ https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5668. Resolution: Abandoned > passing taskmanager configuration through taskManagerEnv instead of file >

[jira] [Closed] (FLINK-5591) queryable state: request failures failing on the server side do not contain client stack trace

[ https://issues.apache.org/jira/browse/FLINK-5591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5591. Resolution: Abandoned > queryable state: request failures failing on the server side do not contain

[jira] [Updated] (FLINK-5490) ContextEnvironment.getExecutionPlan() clears Sinks

[ https://issues.apache.org/jira/browse/FLINK-5490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5490: - Component/s: (was: Command Line Client) API / DataStream > ContextEnvironmen

[GitHub] [flink] tillrohrmann commented on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear…

tillrohrmann commented on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear… URL: https://github.com/apache/flink/pull/8026#issuecomment-531235817 @aljoscha could you take a look. In particular wrt the ongoing client refactoring? --

[jira] [Commented] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929189#comment-16929189 ] Till Rohrmann commented on FLINK-5449: -- Has this issue been abandoned [~Zentol]? >

[jira] [Closed] (FLINK-5425) JobManager replaced by IP in metrics

[ https://issues.apache.org/jira/browse/FLINK-5425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5425. Resolution: Abandoned > JobManager replaced by IP in metrics > ---

[jira] [Closed] (FLINK-5428) Decrease restart delay in RecoveryITCase

[ https://issues.apache.org/jira/browse/FLINK-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5428. Resolution: Won't Fix Test has been removed. > Decrease restart delay in RecoveryITCase > ---

[jira] [Closed] (FLINK-5312) Implement Standalone Setup v2.0

[ https://issues.apache.org/jira/browse/FLINK-5312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5312. Resolution: Won't Do > Implement Standalone Setup v2.0 > --- > >

[jira] [Updated] (FLINK-5253) Remove special treatment of "dynamic properties"

[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5253: -- Labels: flip-6 pull-request-available (was: flip-6) > Remove special treatment of "dynamic pro

[GitHub] [flink] tillrohrmann closed pull request #3356: [FLINK-5253] Remove special treatment of "dynamic properties"

tillrohrmann closed pull request #3356: [FLINK-5253] Remove special treatment of "dynamic properties" URL: https://github.com/apache/flink/pull/3356 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tillrohrmann commented on issue #3356: [FLINK-5253] Remove special treatment of "dynamic properties"

tillrohrmann commented on issue #3356: [FLINK-5253] Remove special treatment of "dynamic properties" URL: https://github.com/apache/flink/pull/3356#issuecomment-531230714 Closing because the PR has been abandoned. At the moment there are other ideas how to pass in configuration values via

[jira] [Closed] (FLINK-5131) Fine-grained Resource Configuration

[ https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5131. Resolution: Duplicate Superseded by [FLIP-53|https://cwiki.apache.org/confluence/display/FLINK/FLI

[jira] [Closed] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

[ https://issues.apache.org/jira/browse/FLINK-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5140. Resolution: Abandoned > NoResourceAvailableException is thrown while starting a new job > -

[jira] [Closed] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5136. Resolution: Duplicate Superseded by [FLIP-53|https://cwiki.apache.org/confluence/display/FLINK/FLI

[jira] [Comment Edited] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929180#comment-16929180 ] Till Rohrmann edited comment on FLINK-5136 at 9/13/19 1:02 PM:

[jira] [Commented] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929178#comment-16929178 ] Till Rohrmann commented on FLINK-5095: -- Do we still want to do this eventually [~Zen

[jira] [Closed] (FLINK-4980) Include example source code in Flink binary distribution

[ https://issues.apache.org/jira/browse/FLINK-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4980. Resolution: Won't Do > Include example source code in Flink binary distribution > -

[jira] [Closed] (FLINK-4888) instantiated job manager metrics missing important job statistics

[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4888. Resolution: Abandoned Abandoned > instantiated job manager metrics missing important job statistic

[jira] [Updated] (FLINK-4888) instantiated job manager metrics missing important job statistics

[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4888: -- Labels: pull-request-available (was: ) > instantiated job manager metrics missing important jo

[GitHub] [flink] tillrohrmann closed pull request #2683: [FLINK-4888][metrics] instantiated job manager metrics missing important job statistics

tillrohrmann closed pull request #2683: [FLINK-4888][metrics] instantiated job manager metrics missing important job statistics URL: https://github.com/apache/flink/pull/2683 This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-4873) Add config option to specify "home directory" for YARN client resource sharing

[ https://issues.apache.org/jira/browse/FLINK-4873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4873: Assignee: (was: Matyas Orhidi) > Add config option to specify "home directory" for YAR

[jira] [Commented] (FLINK-4873) Add config option to specify "home directory" for YARN client resource sharing

[ https://issues.apache.org/jira/browse/FLINK-4873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16929171#comment-16929171 ] Till Rohrmann commented on FLINK-4873: -- Do you wanna work on this [~ysn2233]? > Add

[GitHub] [flink] tillrohrmann commented on issue #2683: [FLINK-4888][metrics] instantiated job manager metrics missing important job statistics

tillrohrmann commented on issue #2683: [FLINK-4888][metrics] instantiated job manager metrics missing important job statistics URL: https://github.com/apache/flink/pull/2683#issuecomment-531226656 Abandoned This is an automat

[jira] [Closed] (FLINK-13136) Fix documentation error about stop job with restful api

[ https://issues.apache.org/jira/browse/FLINK-13136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-13136. > Fix documentation error about stop job with restful api > --

[jira] [Updated] (FLINK-13136) Fix documentation error about stop job with restful api

[ https://issues.apache.org/jira/browse/FLINK-13136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-13136: - Fix Version/s: 1.10.0 > Fix documentation error about stop job with restful api > --

  1   2   >