[jira] [Resolved] (FLINK-10880) Failover strategies should not be applied to Batch Execution

2018-11-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10880. --- Resolution: Fixed Fix Version/s: 1.5.6 Fixed via master: 24d70417411ae7c87bae4b607e0b

[jira] [Commented] (FLINK-10880) Failover strategies should not be applied to Batch Execution

2018-11-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690682#comment-16690682 ] ASF GitHub Bot commented on FLINK-10880: tillrohrmann closed pull request #7129:

[GitHub] tillrohrmann closed pull request #7131: [BP-1.6][FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7131: [BP-1.6][FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation URL: https://github.com/apache/flink/pull/7131 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed b

[GitHub] tillrohrmann closed pull request #7132: [BP-1.5][FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7132: [BP-1.5][FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation URL: https://github.com/apache/flink/pull/7132 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed b

[GitHub] tillrohrmann closed pull request #7130: [BP-1.7][FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7130: [BP-1.7][FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation URL: https://github.com/apache/flink/pull/7130 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed b

[GitHub] tillrohrmann closed pull request #7129: [FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7129: [FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation URL: https://github.com/apache/flink/pull/7129 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Updated] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked.

2018-11-17 Thread fengge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengge updated FLINK-10915: --- Description: {code:java} (deftype Cflatmapfunction [] FlatMapFunction (flatMap [this value collector]

[jira] [Created] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked.

2018-11-17 Thread fengge (JIRA)
fengge created FLINK-10915: -- Summary: clojure context.collectWithTimestamp Will be blocked. Key: FLINK-10915 URL: https://issues.apache.org/jira/browse/FLINK-10915 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked.

2018-11-17 Thread fengge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengge updated FLINK-10915: --- Description: ``` (defn -main [& args] (let [flink-env (StreamExecutionEnvironment/getExecutionEnvironment)

[jira] [Updated] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked.

2018-11-17 Thread fengge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengge updated FLINK-10915: --- Description: {code:java} //代码占位符 {code} (defn -main [& args] (let [flink-env (StreamExecutionEnvironment/ge

[jira] [Updated] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked.

2018-11-17 Thread fengge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengge updated FLINK-10915: --- Description: {code:java} (defn -main [& args] (let [flink-env (StreamExecutionEnvironment/getExecutionEnvi

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

2018-11-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690566#comment-16690566 ] ASF GitHub Bot commented on FLINK-9083: --- BazzalSeed commented on issue #6782: [FLIN

[GitHub] BazzalSeed commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

2018-11-17 Thread GitBox
BazzalSeed commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#issuecomment-439619677 @jparkie thanks. this will be very beneficial for our system. Currently, we are self-rate limit

[jira] [Created] (FLINK-10914) Prefer notifying status changed to waiting and checking in ExecutionGraph tests

2018-11-17 Thread TisonKun (JIRA)
TisonKun created FLINK-10914: Summary: Prefer notifying status changed to waiting and checking in ExecutionGraph tests Key: FLINK-10914 URL: https://issues.apache.org/jira/browse/FLINK-10914 Project: Flin

[jira] [Updated] (FLINK-10914) Prefer notifying status changed to waiting and checking in ExecutionGraph tests

2018-11-17 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10914: - Description: Currently there are several tests of {{ExecutionGraph}} based on {{ExecutionGraphTestUtils

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-17 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690520#comment-16690520 ] Shimin Yang commented on FLINK-6756: Well, I can take this over. > Provide RichAsync

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-17 Thread wgcn (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690502#comment-16690502 ] wgcn commented on FLINK-10884: -- Cool. it's my first experience in the community. I will fix

[jira] [Updated] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10884: -- Affects Version/s: 1.7.0 1.5.5 > Flink on yarn TM container will be ki

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690488#comment-16690488 ] Till Rohrmann commented on FLINK-10884: --- I think you are right [~1026688210]. We s

[jira] [Closed] (FLINK-10913) ExecutionGraphRestartTest.testRestartAutomatically unstable on Travis

2018-11-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10913. - Resolution: Fixed Fix Version/s: 1.5.6 Fixed via master: 1175dbafb0c40808b73016fa554b43bd

[jira] [Created] (FLINK-10913) ExecutionGraphRestartTest.testRestartAutomatically unstable on Travis

2018-11-17 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10913: - Summary: ExecutionGraphRestartTest.testRestartAutomatically unstable on Travis Key: FLINK-10913 URL: https://issues.apache.org/jira/browse/FLINK-10913 Project: Flin

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

2018-11-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690474#comment-16690474 ] ASF GitHub Bot commented on FLINK-10845: xueyumusic commented on a change in pul

[GitHub] xueyumusic commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

2018-11-17 Thread GitBox
xueyumusic commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r234403497 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table

[GitHub] tillrohrmann closed pull request #7128: [BP-1.5][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7128: [BP-1.5][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7128 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sa

[jira] [Resolved] (FLINK-10906) docker-entrypoint.sh logs credentails during startup

2018-11-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10906. --- Resolution: Fixed Fixed via master: https://github.com/apache/flink/commit/3609f36c634027f1

[GitHub] tillrohrmann closed pull request #7127: [BP-1.6][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7127: [BP-1.6][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7127 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sa

[GitHub] tillrohrmann closed pull request #7126: [BP-1.7][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7126: [BP-1.7][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7126 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sa

[jira] [Commented] (FLINK-10906) docker-entrypoint.sh logs credentails during startup

2018-11-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690471#comment-16690471 ] ASF GitHub Bot commented on FLINK-10906: tillrohrmann commented on issue #7125:

[jira] [Commented] (FLINK-10906) docker-entrypoint.sh logs credentails during startup

2018-11-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690472#comment-16690472 ] ASF GitHub Bot commented on FLINK-10906: tillrohrmann closed pull request #7125:

[GitHub] tillrohrmann commented on issue #7125: [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

2018-11-17 Thread GitBox
tillrohrmann commented on issue #7125: [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7125#issuecomment-439605128 Thanks for the review @zentol. Merging this PR. -

[GitHub] tillrohrmann closed pull request #7125: [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

2018-11-17 Thread GitBox
tillrohrmann closed pull request #7125: [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7125 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of pr