[GitHub] flink pull request #4001: [FLINK-5476] Fail fast if trying to submit a job t...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4001#discussion_r129339232 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/StandaloneClusterClient.java --- @@ -70,6 +76,8 @@ public

[jira] [Commented] (FLINK-7124) Allow to rescale JobGraph on JobManager

[ https://issues.apache.org/jira/browse/FLINK-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100231#comment-16100231 ] Till Rohrmann commented on FLINK-7124: -- Hi [~tzulitai], what's the state of this issue? > Allow to

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

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

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

[ https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100423#comment-16100423 ] ASF GitHub Bot commented on FLINK-7265: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink issue #4388: [FLINK-7247] [travis] Replace java 7 build profiles

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4388 +1 test failures are due to network issues and look to have passed in your repo --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-7247) Replace travis java 7 profiles

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

[GitHub] flink pull request #4397: [FLINK-7265] [FLINK-7266] Introduce FileSystemKind...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4397#discussion_r129372059 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/FileSystemKind.java --- @@ -0,0 +1,111 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

[ https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100409#comment-16100409 ] ASF GitHub Bot commented on FLINK-7265: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7221) JDBCOutputFormat swallows errors on last batch

[ https://issues.apache.org/jira/browse/FLINK-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100855#comment-16100855 ] Ken Geis commented on FLINK-7221: - Unfortunately, my employer (UC Berkeley) is reluctant to allow staff to

[GitHub] flink pull request #4149: [FLINK-6923] [Kafka Connector] Expose in-processin...

Github user zhenzhongxu closed the pull request at: https://github.com/apache/flink/pull/4149 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] flink issue #4149: [FLINK-6923] [Kafka Connector] Expose in-processing/in-fl...

Github user zhenzhongxu commented on the issue: https://github.com/apache/flink/pull/4149 thanks @aljoscha for the suggestion. KeyedDeserializationSchema seems like a better approach. I'll close this PR. --- If your project is set up for it, you can reply to this email and have your

[jira] [Created] (FLINK-7259) Match not exhaustive in TaskMonitor

Till Rohrmann created FLINK-7259: Summary: Match not exhaustive in TaskMonitor Key: FLINK-7259 URL: https://issues.apache.org/jira/browse/FLINK-7259 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7181) Activate checkstyle flink-java/operators/*

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

[GitHub] flink issue #4342: [FLINK-7181] Activate checkstyle flink-java/operators/*

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4342 Will rebase it and remove appropriate suppressions first. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129217538 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129233968 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129233893 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129234426 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099668#comment-16099668 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129235807 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099667#comment-16099667 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099664#comment-16099664 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099669#comment-16099669 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099673#comment-16099673 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099666#comment-16099666 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099670#comment-16099670 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129234261 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129234765 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129235825 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099671#comment-16099671 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129234639 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129234789 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129235367 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099672#comment-16099672 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099674#comment-16099674 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099675#comment-16099675 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099665#comment-16099665 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4368#discussion_r129234336 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -0,0 +1,342 @@ +/*

[jira] [Commented] (FLINK-7187) Activate checkstyle flink-java/sca

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

[GitHub] flink issue #4337: [FLINK-7187] Activate checkstyle flink-java/sca

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4337 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #4342: [FLINK-7181] Activate checkstyle flink-java/operators/*

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4342 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-7181) Activate checkstyle flink-java/operators/*

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

[GitHub] flink pull request #4337: [FLINK-7187] Activate checkstyle flink-java/sca

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4337 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4342: [FLINK-7181] Activate checkstyle flink-java/operat...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4342 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-7181) Activate checkstyle flink-java/operators/*

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

[jira] [Commented] (FLINK-7187) Activate checkstyle flink-java/sca

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

[GitHub] flink pull request #4391: [FLINK-7258] [network] Fix watermark configuration...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4391 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #4393: [FLINK-7254] [java8] Properly activate checkstyle for fli...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4393 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-7257) Extend flink-runtime checkstyle coverage to tests

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

[GitHub] flink issue #4394: [FLINK-7257] [runtime] Enable checkstyle for test files i...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4394 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-7254) java8 module pom disables checkstyle

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

[GitHub] flink issue #4369: [Flink-7218] [JobManager] ExecutionVertex.getPreferredLoc...

Github user summerleafs commented on the issue: https://github.com/apache/flink/pull/4369 @StephanEwen You are right, i think we should fix this in `Scheduler.allocateSlot`. If the `ret` from the `scheduleTask` is an SimpleSlot then we record it in `Execution`, how do you think?

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-5789: Summary: Make Bucketing Sink independent of Hadoop's FileSystem (was: Make Bucketing Sink

[jira] [Commented] (FLINK-7124) Allow to rescale JobGraph on JobManager

[ https://issues.apache.org/jira/browse/FLINK-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101083#comment-16101083 ] Tzu-Li (Gordon) Tai commented on FLINK-7124: [~trohrm...@apache.org] I was blocked on fixes

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101108#comment-16101108 ] mingleizhang commented on FLINK-5789: - {{Path}} class in flink does not support {{FileSystem

[GitHub] flink pull request #4397: [FLINK-7265] [FLINK-7266] Introduce FileSystemKind...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4397#discussion_r129375055 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/ConsistencyLevel.java --- @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

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

[jira] [Commented] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

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

[jira] [Assigned] (FLINK-7251) Merge the flink-java8 project into flink-core

[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7251: Assignee: Fang Yong > Merge the flink-java8 project into flink-core >

[jira] [Assigned] (FLINK-6161) Retry connection in case of a ResourceManager heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-6161: --- Assignee: zhijiang > Retry connection in case of a ResourceManager heartbeat timeout >

[GitHub] flink issue #4391: [FLINK-7258] [network] Fix watermark configuration order

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4391 +1. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

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

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

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

[GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4346#discussion_r129230954 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/input/InputBase.java --- @@ -32,6 +35,9 @@ extends

[jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism

[ https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099636#comment-16099636 ] ASF GitHub Bot commented on FLINK-7199: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism

[ https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099638#comment-16099638 ] ASF GitHub Bot commented on FLINK-7199: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism

[ https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099633#comment-16099633 ] ASF GitHub Bot commented on FLINK-7199: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism

[ https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099637#comment-16099637 ] ASF GitHub Bot commented on FLINK-7199: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism

[ https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099635#comment-16099635 ] ASF GitHub Bot commented on FLINK-7199: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7199) Graph simplification does not set parallelism

[ https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099634#comment-16099634 ] ASF GitHub Bot commented on FLINK-7199: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4384 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[GitHub] flink issue #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4368 @EronWright, there shouldn't be any difficulties with that. I think that there is only one functional difference between `TwoPhaseCommitSourceFunction` and `PravegaWriter` - the first one

[jira] [Commented] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

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

[GitHub] flink issue #4391: [FLINK-7258] [network] Fix watermark configuration order

Github user uce commented on the issue: https://github.com/apache/flink/pull/4391 Thanks for the review @zhijiangW and @zentol. Merging this for `1.3` and `master`. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4346#discussion_r129231293 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Simplify.java --- @@ -109,21 +109,23 @@ public Ordering

[GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4346#discussion_r129231234 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Simplify.java --- @@ -109,21 +109,23 @@ public Ordering

[GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4346#discussion_r129231269 --- Diff: flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Simplify.java --- @@ -109,21 +109,23 @@ public Ordering

[GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4346#discussion_r129231080 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/HITS.java --- @@ -168,7 +168,6 @@ protected void

[GitHub] flink pull request #4346: [FLINK-7199] [gelly] Graph simplification does not...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4346#discussion_r129231099 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/HITS.java --- @@ -192,7 +191,6 @@ protected void

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

Github user lincoln-lil commented on the issue: https://github.com/apache/flink/pull/3829 @fhueske Agree with you. I've done most of the work, but after I deprecated `tableEnv.sql` method and modify all the relevant test cases, I found a problem when validate input `sql String`

[jira] [Commented] (FLINK-6378) Implement FLIP-6 Flink-on-Mesos

[ https://issues.apache.org/jira/browse/FLINK-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101025#comment-16101025 ] mingleizhang commented on FLINK-6378: - Thanks, Till. Makes sense better now. > Implement FLIP-6

[jira] [Updated] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer

[ https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6359: -- Description: In this thread on mailing list: http://search-hadoop.com/m/Flink/VkLeQPmRa31hd5cw Gyula Fóra

[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=16091003#comment-16091003 ] Ted Yu edited comment on FLINK-6105 at 7/26/17 1:18 AM: Using

<    1   2   3