[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 4/17/18 10:45 PM: - error-prone has JDK 8

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 4/17/18 10:53 PM: - In

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441630#comment-16441630 ] Ted Yu commented on FLINK-7525: --- Hopefully FLIP-6 would be released soon. > Add config option to disable

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441481#comment-16441481 ] ASF GitHub Bot commented on FLINK-8985: --- GitHub user walterddr opened a pull request:

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

GitHub user walterddr opened a pull request: https://github.com/apache/flink/pull/5863 [FLINK-8985][e2etest] initial support for End-to-end CLI test, excluding YARN test ## What is the purpose of the change Adding end to end test for CLI APIs. ## Brief change log

[GitHub] flink pull request #5864: [FLINK-8661] Replace Collections.EMPTY_MAP with Co...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5864 [FLINK-8661] Replace Collections.EMPTY_MAP with Collections.emptyMap() ## What is the purpose of the change The use of Collections.EMPTY_SET and Collections.EMPTY_MAP often causes

[jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441736#comment-16441736 ] ASF GitHub Bot commented on FLINK-8661: --- GitHub user zhangminglei opened a pull request:

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441740#comment-16441740 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter

Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/5857 cc @tillrohrmann : If you have time, please review this PR, thanks. ---

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441743#comment-16441743 ] mingleizhang commented on FLINK-9193: - I agree with [~twalthr] at this point. It would be better

[jira] [Comment Edited] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441743#comment-16441743 ] mingleizhang edited comment on FLINK-9193 at 4/18/18 1:40 AM: -- I agree with

[jira] [Comment Edited] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441743#comment-16441743 ] mingleizhang edited comment on FLINK-9193 at 4/18/18 1:41 AM: -- I agree with

[GitHub] flink pull request #5825: [FLINK-9040][local runtime] check maxParallelism i...

Github user sihuazhou closed the pull request at: https://github.com/apache/flink/pull/5825 ---

[jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441800#comment-16441800 ] ASF GitHub Bot commented on FLINK-9040: --- Github user sihuazhou closed the pull request at:

[jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441799#comment-16441799 ] ASF GitHub Bot commented on FLINK-9040: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5825: [FLINK-9040][local runtime] check maxParallelism in JobVe...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5825 closing this cause I think this maybe a no-issue. ---

[jira] [Assigned] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9040: - Assignee: (was: Sihua Zhou) > JobVertex#setMaxParallelism does not validate argument >

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441716#comment-16441716 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441734#comment-16441734 ] mingleizhang commented on FLINK-8661: - Sorry for later since my friend wants to get this ticket. But I

[jira] [Updated] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9048: -- Description: As of commit e0bc37bef69f5376d03214578e9b95816add661b, I got the following : {code}

[GitHub] flink issue #5860: [FLINK-9138][filesystem-connectors] Implement time based ...

Github user glaksh100 commented on the issue: https://github.com/apache/flink/pull/5860 @aljoscha @fhueske Can you please take a look? ---

[GitHub] flink issue #5488: [FLINK-8335] [hbase] Upgrade hbase connector dependency t...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5488 Okay 👍 ---

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441727#comment-16441727 ] ASF GitHub Bot commented on FLINK-8335: --- Github user zhangminglei commented on the issue:

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8335: Description: hbase 1.4.3 has been released. 1.4.0 shows speed improvement over previous 1.x

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8335: Fix Version/s: 1.6.0 > Upgrade hbase connector dependency to 1.4.3 >

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441846#comment-16441846 ] yuqi commented on FLINK-9194: - [~gjy] Could not reproduce this problem with the environment you provide, more

<    1   2