[GitHub] flink issue #5923: [FLINK-9253][network] make the maximum floating buffers c...

2018-04-27 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/5923 Thanks for improving it, looks good from my point. :) ---

[GitHub] flink pull request #5925: [FLINK-8992] [e2e-tests] General purpose DataStrea...

2018-04-27 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5925 [FLINK-8992] [e2e-tests] General purpose DataStream e2e test ## What is the purpose of the change This PR adds a general purpose Flink DataStream end-to-end test job, whose purpose is to

[jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456042#comment-16456042 ] ASF GitHub Bot commented on FLINK-8992: --- GitHub user tzulitai opened a pull request:

[jira] [Commented] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456066#comment-16456066 ] ASF GitHub Bot commented on FLINK-9253: --- Github user zhijiangW commented on the issue:

[GitHub] flink pull request #5926: [FLINK-9073] [tests] Extend savepoint e2e tests fo...

2018-04-27 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5926 [FLINK-9073] [tests] Extend savepoint e2e tests for different state backends ## What is the purpose of the change This PR is based on the new general purpose DataStream job added in #5925.

[jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once

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

[jira] [Commented] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution"

2018-04-27 Thread Sampath Bhat (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456099#comment-16456099 ] Sampath Bhat commented on FLINK-9148: - You'll have create the job manager service like mentioned in

[GitHub] flink pull request #5925: [FLINK-8992] [e2e-tests] General purpose DataStrea...

2018-04-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5925#discussion_r184619113 --- Diff: flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/SemanticsCheckMapper.java --- @@ -21,17

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

2018-04-27 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5834 cc @zentol refactored based on your suggestion, please review it again ---

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

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

[GitHub] flink pull request #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-04-27 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5928 [hotfix][doc] fix doc of externalized checkpoint ## What is the purpose of the change This PR intend to fix the incorrect doc of externalized checkpoint. ## Brief change log

[jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once

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

[GitHub] flink pull request #5925: [FLINK-8992] [e2e-tests] General purpose DataStrea...

2018-04-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5925#discussion_r184647536 --- Diff: flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestProgram.java ---

[jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456044#comment-16456044 ] ASF GitHub Bot commented on FLINK-8992: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5925: [FLINK-8992] [e2e-tests] General purpose DataStream e2e t...

2018-04-27 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5925 @StefanRRichter since you worked on this in the beginning, do you want to take a look at my additional (small) changes? I did a review of the code already, and have addressed my own comments as

[GitHub] flink pull request #5927: [FLINK-8237] [BucketingSink] Better error message ...

2018-04-27 Thread pavel-shvetsov-git
GitHub user pavel-shvetsov-git opened a pull request: https://github.com/apache/flink/pull/5927 [FLINK-8237] [BucketingSink] Better error message added Added better error message as mentioned in issue description and comments. You can merge this pull request into a Git repository

[jira] [Commented] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456087#comment-16456087 ] ASF GitHub Bot commented on FLINK-8237: --- GitHub user pavel-shvetsov-git opened a pull request:

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

2018-04-27 Thread Tarush Grover (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456112#comment-16456112 ] Tarush Grover commented on FLINK-9178: -- [~tzulitai] Please assign this task to me. > Add rate

[GitHub] flink issue #5924: [hotfix][README.md] Update building prerequisites

2018-04-27 Thread W4anD0eR96
Github user W4anD0eR96 commented on the issue: https://github.com/apache/flink/pull/5924 @zentol (Just see you push commits on docs, know nobody to @ properly) This is quite a small modify. Once I use Java 9 to build flink project and fail, so I think it might be helpful to

[jira] [Commented] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456085#comment-16456085 ] ASF GitHub Bot commented on FLINK-9073: --- GitHub user tzulitai opened a pull request:

[GitHub] flink issue #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-04-27 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5928 cc @StefanRRichter @StephanEwen ---

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456223#comment-16456223 ] Xingcan Cui commented on FLINK-9219: Hi [~twalthr]] and [~fhueske], I‘ve tried to implement three

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184657584 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -185,36 +188,44 @@ public

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184657419 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java --- @@ -103,17 +104,17 @@ public void add(T value) throws

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184657398 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java --- @@ -49,17 +49,18 @@ /** * Creates a

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184675164 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---

[jira] [Commented] (FLINK-9263) Kafka010ITCase failed on travis flaky

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456324#comment-16456324 ] ASF GitHub Bot commented on FLINK-9263: --- Github user sihuazhou commented on the issue:

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456246#comment-16456246 ] ASF GitHub Bot commented on FLINK-8715: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5885: [FLINK-8715] Remove usage of StateDescriptor in state han...

2018-04-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5885 Had two more suggestions, otherwise this is 👍 for merging. ---

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456458#comment-16456458 ] ASF GitHub Bot commented on FLINK-8715: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184691691 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---

[GitHub] flink issue #5925: [FLINK-8992] [e2e-tests] General purpose DataStream e2e t...

2018-04-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5925 LGTM 👍 Will merge this. ---

[jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once

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

[GitHub] flink pull request #5925: [FLINK-8992] [e2e-tests] General purpose DataStrea...

2018-04-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5925 ---

[jira] [Created] (FLINK-9263) Kafka010ITCase failed on travis flaky

2018-04-27 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9263: - Summary: Kafka010ITCase failed on travis flaky Key: FLINK-9263 URL: https://issues.apache.org/jira/browse/FLINK-9263 Project: Flink Issue Type: Bug

[GitHub] flink issue #5930: [FLINK-9263][state] Fix concurrency problem in DefaultOpe...

2018-04-27 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5930 Hi @StefanRRichter, Could you please have a look at this? ---

[jira] [Commented] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

2018-04-27 Thread Edward Rojas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456371#comment-16456371 ] Edward Rojas commented on FLINK-9255: - I was not aware of that change. Effectively using the rest port

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184694977 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456480#comment-16456480 ] ASF GitHub Bot commented on FLINK-8992: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[jira] [Assigned] (FLINK-9263) Kafka010ITCase failed on travis flaky

2018-04-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9263: - Assignee: Sihua Zhou > Kafka010ITCase failed on travis flaky >

[GitHub] flink pull request #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE...

2018-04-27 Thread alexpf
GitHub user alexpf opened a pull request: https://github.com/apache/flink/pull/5929 [FLINK-8497] [connectors] KafkaConsumer throws NPE if topic doesn't exist ## What is the purpose of the change To make the Kafka connector behavior clearer for the API user, by throwing a

[GitHub] flink issue #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-04-27 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5928 Travis failed is unrelated, it cause by the concurrency problem in `DefaultOperatorStateBackend` when performing checkpoint, which this [PR](https://github.com/apache/flink/pull/5930) try to fix.

[jira] [Commented] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

2018-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456332#comment-16456332 ] Chesnay Schepler commented on FLINK-9255: - Note that if you set the cluster mode to legacy the

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184690567 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Updated] (FLINK-9263) Kafka010ITCase failed on travis because of the concurrency problem in DefaultOperateStateBackend

2018-04-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9263: -- Summary: Kafka010ITCase failed on travis because of the concurrency problem in

[jira] [Comment Edited] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456223#comment-16456223 ] Xingcan Cui edited comment on FLINK-9219 at 4/27/18 10:49 AM: -- Hi [~twalthr] 

[jira] [Comment Edited] (FLINK-9263) Kafka010ITCase failed on travis flaky

2018-04-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456275#comment-16456275 ] Sihua Zhou edited comment on FLINK-9263 at 4/27/18 12:08 PM: - This is because

[jira] [Commented] (FLINK-9263) Kafka010ITCase failed on travis flaky

2018-04-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456275#comment-16456275 ] Sihua Zhou commented on FLINK-9263: --- This is because the concurrency problem when do async checkpoint in

[jira] [Closed] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

2018-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9255. --- Resolution: Not A Problem In 1.5 we are changing the client to communicate via REST instead

[jira] [Closed] (FLINK-8992) Implement source and operator that validate exactly-once

2018-04-27 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8992. - Resolution: Fixed Merged in: master: 31c717697a52af2c64439aaaba2f6a1f97a22159 release 1.5: 

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

2018-04-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r184657676 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java --- @@ -61,8

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[GitHub] flink issue #5885: [FLINK-8715] Remove usage of StateDescriptor in state han...

2018-04-27 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5885 Hi @StefanRRichter, I've addressed your comments and also rebased the PR. Could you have a final pass through this? ---

[jira] [Updated] (FLINK-9263) Kafka010ITCase failed on travis flaky

2018-04-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9263: -- Priority: Blocker (was: Critical) > Kafka010ITCase failed on travis flaky >

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

2018-04-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9190: --- Assignee: Gary Yao (was: Sihua Zhou) > YarnResourceManager sometimes does not request new

[GitHub] flink issue #5899: Klink

2018-04-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5899 Hi @bitsilly, as @sihuazhou please describe the purpose of this PR. Also please translate the comments to English. Thanks, Fabian ---

[GitHub] flink pull request #5930: [FLINK-9263][state] Fix concurrency problem in Def...

2018-04-27 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5930 [FLINK-9263][state] Fix concurrency problem in DefaultOperatorStateBackend. ## What is the purpose of the change This PR fixes the concurrency problem in `DefaultOperatorStateBackend`,

[jira] [Commented] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456316#comment-16456316 ] ASF GitHub Bot commented on FLINK-8497: --- GitHub user alexpf opened a pull request:

[jira] [Commented] (FLINK-9263) Kafka010ITCase failed on travis flaky

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

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

2018-04-27 Thread sihuazhou
Github user sihuazhou closed the pull request at: https://github.com/apache/flink/pull/5881 ---

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184674886 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184675917 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184674272 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184673962 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184676876 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184675777 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184677353 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184676633 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184676032 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184678308 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184678944 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184676407 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184675061 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184677692 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184678745 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation...

2018-04-27 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5913#discussion_r184678478 --- Diff: docs/dev/table/sqlClient.md --- @@ -0,0 +1,538 @@ +--- +title: "SQL Client" +nav-parent_id: tableapi +nav-pos: 100 +is_beta: true

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

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

2018-04-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456337#comment-16456337 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on the issue:

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

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-9181) Add SQL Client documentation page

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

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[jira] [Commented] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

2018-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456336#comment-16456336 ] Chesnay Schepler commented on FLINK-9255: - Also note that the commit wasn't causing the issue.

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

2018-04-27 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5881 Hi @GJL I see you took over this ticket, I closing this PR now, looking forward your PR ;). ---

  1   2   >