[GitHub] flink issue #4668: [FLINK-7617] Remove string format in BitSet to improve th...

2017-09-13 Thread JingsongLi
Github user JingsongLi commented on the issue: https://github.com/apache/flink/pull/4668 ## Performance - HashVsSortMiniBenchmark: use buildSideOuterJoin testBuildFirst: 16s 208ms(before)10s 98ms(after) testBuildSecond:7s 793ms(before) 6s 67ms(after)

[jira] [Commented] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165836#comment-16165836 ] ASF GitHub Bot commented on FLINK-7617: --- Github user JingsongLi commented on the iss

[jira] [Commented] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165830#comment-16165830 ] ASF GitHub Bot commented on FLINK-7617: --- GitHub user JingsongLi opened a pull reques

[GitHub] flink pull request #4668: [FLINK-7617] Remove string format in BitSet to imp...

2017-09-13 Thread JingsongLi
GitHub user JingsongLi opened a pull request: https://github.com/apache/flink/pull/4668 [FLINK-7617] Remove string format in BitSet to improve the performance of BuildSideOuterjoin *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165823#comment-16165823 ] ASF GitHub Bot commented on FLINK-5859: --- GitHub user godfreyhe opened a pull request

[GitHub] flink pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource ...

2017-09-13 Thread godfreyhe
GitHub user godfreyhe opened a pull request: https://github.com/apache/flink/pull/4667 [FLINK-5859] [table] Add PartitionableTableSource for partition pruning ## What is the purpose of the change This pull request adds PartitionableTableSource for partition pruning when opt

[jira] [Commented] (FLINK-7606) Memory leak on NestedMapsStateTable

2017-09-13 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165815#comment-16165815 ] Dian Fu commented on FLINK-7606: Hi [~matteoferrario29], {quote} What we've seen is that

[jira] [Commented] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-13 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165786#comment-16165786 ] Jingsong Lee commented on FLINK-7617: - Can someone give me the right to assign to me?

[jira] [Created] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-13 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-7617: --- Summary: Remove string format in BitSet to improve the performance of BuildSideOuterjoin Key: FLINK-7617 URL: https://issues.apache.org/jira/browse/FLINK-7617 Project:

[jira] [Comment Edited] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

2017-09-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069086#comment-16069086 ] Ted Yu edited comment on FLINK-7049 at 9/14/17 4:30 AM: Stack trac

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-13 Thread Aitozi
Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r138789377 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -132,6 +133,13 @@ */

[jira] [Commented] (FLINK-7616) Fix missing markups in Execution Configuration

2017-09-13 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165650#comment-16165650 ] Raymond Tay commented on FLINK-7616: The PR is here https://github.com/apache/flink/pu

[jira] [Created] (FLINK-7616) Fix missing markups in Execution Configuration

2017-09-13 Thread Raymond Tay (JIRA)
Raymond Tay created FLINK-7616: -- Summary: Fix missing markups in Execution Configuration Key: FLINK-7616 URL: https://issues.apache.org/jira/browse/FLINK-7616 Project: Flink Issue Type: Task

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-13 Thread Aitozi
Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r138778844 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -132,6 +133,13 @@ */

[jira] [Commented] (FLINK-4256) Fine-grained recovery

2017-09-13 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165537#comment-16165537 ] Eron Wright commented on FLINK-4256: - Is the scope of FLINK-4256 covering batch jobs

[jira] [Commented] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule

2017-09-13 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165474#comment-16165474 ] Eron Wright commented on FLINK-7615: - [~addis...@gmail.com] thanks for the report.

[jira] [Closed] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule

2017-09-13 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-7615. --- Resolution: Duplicate > Under mesos when using a role, TaskManagers fail to schedule > ---

[jira] [Commented] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165292#comment-16165292 ] ASF GitHub Bot commented on FLINK-7609: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4662: [FLINK-7609][examples] WindowWordCount example doesn't pr...

2017-09-13 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4662 @zentol Done ---

[jira] [Closed] (FLINK-2395) Check Scala catch blocks for Throwable

2017-09-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2395. Resolution: Won't Fix > Check Scala catch blocks for Throwable > ---

[jira] [Commented] (FLINK-2395) Check Scala catch blocks for Throwable

2017-09-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165290#comment-16165290 ] Till Rohrmann commented on FLINK-2395: -- I think this issue can be closed since we are

[jira] [Commented] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule

2017-09-13 Thread Addison Higham (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165288#comment-16165288 ] Addison Higham commented on FLINK-7615: --- I should mention, looking at the code, thi

[jira] [Created] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule

2017-09-13 Thread Addison Higham (JIRA)
Addison Higham created FLINK-7615: - Summary: Under mesos when using a role, TaskManagers fail to schedule Key: FLINK-7615 URL: https://issues.apache.org/jira/browse/FLINK-7615 Project: Flink

[jira] [Commented] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165206#comment-16165206 ] ASF GitHub Bot commented on FLINK-7609: --- Github user zentol commented on the issue:

[GitHub] flink issue #4662: [FLINK-7609][examples] WindowWordCount example doesn't pr...

2017-09-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4662 lets go with 10/5 then. ---

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r138723827 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -132,6 +133,13 @@ */

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r138724464 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -132,6 +133,13 @@ */

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r138724269 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -132,6 +133,13 @@ */

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

2017-09-13 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165109#comment-16165109 ] Elias Levy commented on FLINK-4814: --- Wondering what is the status of this? The current

[jira] [Commented] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164966#comment-16164966 ] ASF GitHub Bot commented on FLINK-7508: --- Github user bowenli86 commented on the issu

[jira] [Commented] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164965#comment-16164965 ] ASF GitHub Bot commented on FLINK-7600: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4656: [FLINK-7508][kinesis] switch FlinkKinesisProducer to use ...

2017-09-13 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4656 @tzulitai Hi Gordon, can you please take a look at this PR? ---

[GitHub] flink issue #4657: [FLINK-7600][kinesis] shorten delay of KinesisProducerCon...

2017-09-13 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4657 @tzulitai Hi Gordon, can you please take a look at this PR? ---

[jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164915#comment-16164915 ] ASF GitHub Bot commented on FLINK-7294: --- Github user EronWright commented on the iss

[GitHub] flink issue #4622: [FLINK-7294]:[flink-mesos] mesos.resourcemanager.framewor...

2017-09-13 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/4622 @tillrohrmann please take a look and merge if you're OK with it. ---

[jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164522#comment-16164522 ] ASF GitHub Bot commented on FLINK-7294: --- Github user bbayani commented on the issue:

[GitHub] flink issue #4622: [FLINK-7294]:[flink-mesos] mesos.resourcemanager.framewor...

2017-09-13 Thread bbayani
Github user bbayani commented on the issue: https://github.com/apache/flink/pull/4622 @EronWright Yes, I have verified the case when mesos.resourcemanager.framework.role is not configured in flink-conf.yaml (and thus defaults to *). In this case, it launched all the tasks only on work

[jira] [Created] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation

2017-09-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7614: -- Summary: Add a code snippet example of a valid POJO to "Data Types" documentation Key: FLINK-7614 URL: https://issues.apache.org/jira/browse/FLINK-7614 Pr

[jira] [Commented] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs

2017-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164347#comment-16164347 ] ASF GitHub Bot commented on FLINK-7474: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4535: [FLINK-7474] [ Streaming Connectors] AzureEventhubs-conne...

2017-09-13 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4535 @zhuganghuaonnet it doesn't seem like the PR is correctly rebased. Ideally, you should rebase your development branch to the latest master, and the PR only contains for your changes, and not others.

[jira] [Comment Edited] (FLINK-4500) Cassandra sink can lose messages

2017-09-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160180#comment-16160180 ] Michael Fong edited comment on FLINK-4500 at 9/13/17 7:54 AM: --