[GitHub] flink pull request #4621: [FLINK-7495] Call to AbstractUdfStreamOperator#ini...

2018-05-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4621 ---

[jira] [Commented] (FLINK-9321) Rename SubtasksAllAccumulatorsHandlers

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470275#comment-16470275 ] ASF GitHub Bot commented on FLINK-9321: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8134) Add description to MessageHeaders

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470274#comment-16470274 ] ASF GitHub Bot commented on FLINK-8134: --- Github user asfgit closed the pull request at:

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

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470277#comment-16470277 ] ASF GitHub Bot commented on FLINK-9138: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5836: [FLINK-9141][datastream] Fail early when using bot...

2018-05-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5836 ---

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470278#comment-16470278 ] ASF GitHub Bot commented on FLINK-9309: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8912) Web UI does not render error messages correctly in FLIP-6 mode

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470270#comment-16470270 ] ASF GitHub Bot commented on FLINK-8912: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5479: [FLINK-8649] [scala api] Pass on TypeInfo in Strea...

2018-05-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5479 ---

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470297#comment-16470297 ] ASF GitHub Bot commented on FLINK-8135: --- GitHub user andrew-half opened a pull request:

[GitHub] flink issue #5908: [FLINK-9182]async checkpoints for timer service

2018-05-10 Thread makeyang
Github user makeyang commented on the issue: https://github.com/apache/flink/pull/5908 @StefanRRichter sorry for the late answer. just take a surgery few days ago and come back now. I'll take close look at you comments and then answer back. ---

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469988#comment-16469988 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on the issue:

[GitHub] flink issue #5834: [FLINK-9153] TaskManagerRunner should support rpc port ra...

2018-05-10 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5834 @zentol this PR also reviewed by you, and takes a long time, can you review this? thanks~ ---

[GitHub] flink issue #5981: fix syntax error in dataset_transformations.md

2018-05-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5981 merging. ---

[GitHub] flink pull request #5977: [FLINK-9295][kafka] Fix transactional.id collision...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5977#discussion_r187250723 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/MockStreamConfig.java --- @@ -0,0 +1,35 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470004#comment-16470004 ] ASF GitHub Bot commented on FLINK-9070: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #5979: [FLINK-9070][state]improve the performance of Rock...

2018-05-10 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5979#discussion_r187255609 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java --- @@ -356,6

[jira] [Commented] (FLINK-9153) TaskManagerRunner should support rpc port range

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470003#comment-16470003 ] ASF GitHub Bot commented on FLINK-9153: --- Github user yanghua commented on the issue:

[jira] [Commented] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469980#comment-16469980 ] ASF GitHub Bot commented on FLINK-9295: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469996#comment-16469996 ] ASF GitHub Bot commented on FLINK-9309: --- Github user zentol commented on the issue:

[GitHub] flink issue #5976: [FLINK-9309] Recommend HA setup on Production Readiness C...

2018-05-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5976 merging. ---

[GitHub] flink pull request #5987: [FLINK-9043][CLI]Automatically search for the last...

2018-05-10 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5987 [FLINK-9043][CLI]Automatically search for the last successful checkpoint when recover the job from externalized checkpoint ## What is the purpose of the change *Automatically search for

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470565#comment-16470565 ] ASF GitHub Bot commented on FLINK-9043: --- GitHub user sihuazhou opened a pull request:

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470640#comment-16470640 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470641#comment-16470641 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470637#comment-16470637 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187378661 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ProgramArgsQueryParameter.java --- @@ -30,4 +30,8 @@ public

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470636#comment-16470636 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470638#comment-16470638 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470642#comment-16470642 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470639#comment-16470639 ] ASF GitHub Bot commented on FLINK-8135: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187377384 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/MessageParametersTest.java --- @@ -109,8 +114,13 @@ public JobID

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187378407 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtaskIndexPathParameter.java --- @@ -44,4 +44,9 @@ protected String

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187382132 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerIdPathParameter.java --- @@ -41,4 +41,9 @@ protected

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187381371 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/MetricsAggregationParameter.java --- @@ -46,6 +46,13 @@ public

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187378111 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/MetricsAggregationParameter.java --- @@ -46,6 +46,13 @@ public

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187378292 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/TerminationModeQueryParameter.java --- @@ -41,6 +41,11 @@ public String

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470880#comment-16470880 ] ASF GitHub Bot commented on FLINK-9070: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5979: [FLINK-9070][state]improve the performance of RocksDBMapS...

2018-05-10 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5979 LGTM +1 ---

[GitHub] flink issue #5966: [FLINK-9312] [security] Add mutual authentication for RPC...

2018-05-10 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5966 This is relevant http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Discuss-FLIP-26-SSL-Mutual-Authentication-td22188.html ---

[jira] [Commented] (FLINK-9312) Perform mutual authentication during SSL handshakes

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471093#comment-16471093 ] ASF GitHub Bot commented on FLINK-9312: --- Github user GJL commented on the issue:

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187460147 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtaskIndexPathParameter.java --- @@ -44,4 +44,9 @@ protected String

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187458764 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/SavepointPathQueryParameter.java --- @@ -28,4 +28,9 @@

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

2018-05-10 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5985#discussion_r187459062 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/AccumulatorsIncludeSerializedValueQueryParameter.java --- @@ -38,4 +38,10 @@

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471113#comment-16471113 ] ASF GitHub Bot commented on FLINK-8135: --- Github user walterddr commented on a diff in the pull

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471115#comment-16471115 ] ASF GitHub Bot commented on FLINK-8135: --- Github user walterddr commented on a diff in the pull

[jira] [Commented] (FLINK-8135) Add description to MessageParameter

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471114#comment-16471114 ] ASF GitHub Bot commented on FLINK-8135: --- Github user walterddr commented on a diff in the pull

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471146#comment-16471146 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ...

2018-05-10 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5931#discussion_r187466146 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -293,21 +293,16 @@ public void startNewWorker(ResourceProfile

[GitHub] flink issue #5983: [FLINK-7789][DataStream API] Add handler for Async IO ope...

2018-05-10 Thread kisimple
Github user kisimple commented on the issue: https://github.com/apache/flink/pull/5983 cc @tillrohrmann @kl0u ---

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471414#comment-16471414 ] ASF GitHub Bot commented on FLINK-7789: --- Github user kisimple commented on the issue:

[jira] [Commented] (FLINK-9332) Fix Codegen error of CallGenerator

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471501#comment-16471501 ] ASF GitHub Bot commented on FLINK-9332: --- GitHub user Xpray opened a pull request:

[jira] [Created] (FLINK-9333) QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options

2018-05-10 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-9333: -- Summary: QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options Key: FLINK-9333 URL: https://issues.apache.org/jira/browse/FLINK-9333 Project:

[jira] [Created] (FLINK-9332) Fix Codegen error of CallGenerator

2018-05-10 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9332: - Summary: Fix Codegen error of CallGenerator Key: FLINK-9332 URL: https://issues.apache.org/jira/browse/FLINK-9332 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471451#comment-16471451 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-9333) QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471510#comment-16471510 ] ASF GitHub Bot commented on FLINK-9333: --- GitHub user medcv opened a pull request:

[GitHub] flink pull request #5989: [FLINK-9333] QuickStart Docs Spelling fix and some...

2018-05-10 Thread medcv
GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/5989 [FLINK-9333] QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options ## What is the purpose of the change - Spelling fix for QuickStart Project Template for Java -

[GitHub] flink pull request #5988: [FLINK-9332][TableAPI & SQL] Fix Codegen error of ...

2018-05-10 Thread Xpray
GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/5988 [FLINK-9332][TableAPI & SQL] Fix Codegen error of CallGenerator ## What is the purpose of the change Fix bugs that nullTerm do not handle function call return value correctly.

[GitHub] flink issue #5908: [FLINK-9182]async checkpoints for timer service

2018-05-10 Thread makeyang
Github user makeyang commented on the issue: https://github.com/apache/flink/pull/5908 @StefanRRichter I definitely like u ideas about flat copy priority queue in sync and then handler key-group thing in async. so I'll get rid of my solution and try to implement u solution and then

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

2018-05-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471429#comment-16471429 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on the issue:

[GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ...

2018-05-10 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5931#discussion_r187514050 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -293,21 +293,16 @@ public void startNewWorker(ResourceProfile

<    1   2