[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499194#comment-16499194 ] ASF GitHub Bot commented on FLINK-9168: --- Github user sijie commented on the issue:

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-02 Thread sijie
Github user sijie commented on the issue: https://github.com/apache/flink/pull/5845 @tzulitai what is your opinion about @XiaoZYang 's comment? ---

[jira] [Comment Edited] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499099#comment-16499099 ] Yazdan Shirvany edited comment on FLINK-9505 at 6/2/18 3:33 PM: ---

[jira] [Assigned] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany reassigned FLINK-9505: -- Assignee: Yazdan Shirvany > End-to-end test: Flink-Example module [flink-examples-stre

[jira] [Commented] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499099#comment-16499099 ] Yazdan Shirvany commented on FLINK-9505: [~Zentol] As we discussed (on quickstar

[GitHub] flink issue #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-02 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6059 After go through the whole change, i think it is extremely a good feature 👍, and i will apply this patch to our inner library to test how much the performance improved. A little question: why t

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Description: Write End-to-End test for Flink-Example -  [flink-examples-streaming] submodule

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Summary: End-to-end test: Flink-Example module [flink-examples-streaming] (was: End-to-end t

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Description: Write End-to-End test for Flink-Example submodules *  flink-examples-batch *

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Description: Write End-to-End test for Flink-Example submodules *  flink-examples-batch * f

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Description: Write End-to-End test for Flink-Example submodules - flink-examples-batch - fl

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Summary: End-to-end test: Flink- (was: End-to-end test: Quickstarts for Scala) > End-to-end

[jira] [Created] (FLINK-9505) End-to-end test: Quickstarts for Scala

2018-06-02 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-9505: -- Summary: End-to-end test: Quickstarts for Scala Key: FLINK-9505 URL: https://issues.apache.org/jira/browse/FLINK-9505 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module

2018-06-02 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9505: --- Summary: End-to-end test: Flink-Example module (was: End-to-end test: Flink-) > End-to-end

[jira] [Assigned] (FLINK-9503) Migrate integration tests for iterative aggregators

2018-06-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9503: --- Assignee: vinoyang > Migrate integration tests for iterative aggregators > -

[jira] [Assigned] (FLINK-9497) Job Configuration showing the password in plain text

2018-06-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9497: --- Assignee: vinoyang > Job Configuration showing the password in plain text >

[jira] [Assigned] (FLINK-9496) Job created time is reset after restart

2018-06-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9496: --- Assignee: vinoyang > Job created time is reset after restart > -

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

2018-06-02 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499082#comment-16499082 ] Kostas Kloudas commented on FLINK-7789: --- And on 1.5 with 08f83f2261dc66127bf2e639ed

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

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499076#comment-16499076 ] ASF GitHub Bot commented on FLINK-7789: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499075#comment-16499075 ] ASF GitHub Bot commented on FLINK-9413: --- Github user zhangminglei commented on a di

[GitHub] flink pull request #6091: [FLINK-7789][DataStream API] Add handler for Async...

2018-06-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6091 ---

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

2018-06-02 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7789. - Resolution: Fixed Merged on master with 56df6904688642b1c8f9a287646c163dfae7edfd > Add handler f

[GitHub] flink pull request #6103: [FLINK-9413] [distributed coordination] Tasks can ...

2018-06-02 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6103#discussion_r192559985 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputChannelDeploymentDescriptor.java --- @@ -103,9 +103,7 @@ public String t

[jira] [Commented] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499051#comment-16499051 ] ASF GitHub Bot commented on FLINK-9504: --- GitHub user Aitozi opened a pull request:

[GitHub] flink pull request #6111: [FLINK-9504]Change the log level of checkpoint dur...

2018-06-02 Thread Aitozi
GitHub user Aitozi opened a pull request: https://github.com/apache/flink/pull/6111 [FLINK-9504]Change the log level of checkpoint duration to debug Now, every time checkpoint it will log with the OperatorStateBackend and KeyedStateBackend with per partition/parallel time cost, it o

[jira] [Created] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log

2018-06-02 Thread aitozi (JIRA)
aitozi created FLINK-9504: - Summary: Change checkpoint duration log level to debug to avoid too much log Key: FLINK-9504 URL: https://issues.apache.org/jira/browse/FLINK-9504 Project: Flink Issue Ty

[jira] [Commented] (FLINK-9464) Clean up pom files

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499045#comment-16499045 ] ASF GitHub Bot commented on FLINK-9464: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6093: [FLINK-9464] Various pom.xml file clean ups

2018-06-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6093 ---

[jira] [Closed] (FLINK-9464) Clean up pom files

2018-06-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9464. Resolution: Fixed Fixed via b038055012 8f9c45aa52 94aa5c7ccf cf34e3056a c02cc1766e > Clean up pom

[GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-02 Thread Aitozi
Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6059#discussion_r192558813 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventWrapper.java --- @@ -0,0 +1,188 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499042#comment-16499042 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on the

[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

2018-06-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6083 Thanks for opening the PR @medcv. I will try to take a look next week. ---

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499040#comment-16499040 ] ASF GitHub Bot commented on FLINK-9413: --- Github user tillrohrmann commented on a di

[GitHub] flink pull request #6103: [FLINK-9413] [distributed coordination] Tasks can ...

2018-06-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6103#discussion_r192558687 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputChannelDeploymentDescriptor.java --- @@ -103,9 +103,7 @@ public String t

[jira] [Commented] (FLINK-9500) FileUploadHandler does not handle EmptyLastHttpContent

2018-06-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499039#comment-16499039 ] Till Rohrmann commented on FLINK-9500: -- If the decoder cannot handle {{EmptyLastHttp

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498938#comment-16498938 ] ASF GitHub Bot commented on FLINK-9168: --- Github user XiaoZYang commented on the iss

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-02 Thread XiaoZYang
Github user XiaoZYang commented on the issue: https://github.com/apache/flink/pull/5845 Hi @sijie @tzulitai, since there will be serial of commits about *pulsar connector*, what about close this pr and reopen a new PR which is going to merge to a new branch named "pulsar-connector". S

[jira] [Commented] (FLINK-9483) "Building Flink" doc doesn't highlight quick build command

2018-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498926#comment-16498926 ] ASF GitHub Bot commented on FLINK-9483: --- Github user zentol commented on a diff in

[GitHub] flink pull request #6109: [FLINK-9483] 'Building Flink' doc doesn't highligh...

2018-06-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6109#discussion_r192553046 --- Diff: docs/start/building.md --- @@ -50,7 +50,11 @@ mvn clean install -DskipTests This instructs [Maven](http://maven.apache.org) (`mvn`) to fir