[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499762#comment-16499762 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r192630255 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79

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

[ https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499754#comment-16499754 ] ASF GitHub Bot commented on FLINK-9483: --- Github user bowenli86 commented on a diff in the pull

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499749#comment-16499749 ] ASF GitHub Bot commented on FLINK-9483: --- Github user Aitozi commented on a diff in the pull

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

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

[jira] [Comment Edited] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499672#comment-16499672 ] Sihua Zhou edited comment on FLINK-9506 at 6/4/18 2:22 AM: --- Hi [~yow] could you

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499672#comment-16499672 ] Sihua Zhou commented on FLINK-9506: --- Hi [~yow] could you please just replace the getKey() as follow and

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499667#comment-16499667 ] swy commented on FLINK-9506: Thanks for pointing out, this is a mistake in the sample. In real application

[jira] [Updated] (FLINK-9509) CLI usage are not same as CLI docs

[ https://issues.apache.org/jira/browse/FLINK-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9509: --- Component/s: Documentation Client > CLI usage are not same as CLI docs >

[jira] [Created] (FLINK-9509) CLI usage are not same as CLI docs

Yazdan Shirvany created FLINK-9509: -- Summary: CLI usage are not same as CLI docs Key: FLINK-9509 URL: https://issues.apache.org/jira/browse/FLINK-9509 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9508) General Spell Check on Flink Docs

[ https://issues.apache.org/jira/browse/FLINK-9508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499569#comment-16499569 ] ASF GitHub Bot commented on FLINK-9508: --- GitHub user medcv opened a pull request:

[GitHub] flink pull request #6112: [FLINK-9508][Docs]General Spell Check on Flink Doc...

GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/6112 [FLINK-9508][Docs]General Spell Check on Flink Docs ## What is the purpose of the change General spell check for Flink docs ## Does this pull request potentially affect one of

[jira] [Created] (FLINK-9508) General Spell Check on Flink Docs

Yazdan Shirvany created FLINK-9508: -- Summary: General Spell Check on Flink Docs Key: FLINK-9508 URL: https://issues.apache.org/jira/browse/FLINK-9508 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499560#comment-16499560 ] Ken Krugler commented on FLINK-9506: Why are you creating a new {{AggregrationFunction}} every time

[jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Carter updated FLINK-9126: -- Description: Currently the DataSet API only has the ability to output data received from

[jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Carter updated FLINK-9126: -- Affects Version/s: 1.5.0 > Creation of the CassandraPojoInputFormat class to output data into

[jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Carter updated FLINK-9126: -- Labels: InputFormat cassandra features (was: InputFormat cassandra easyfix features) >

[jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Carter updated FLINK-9126: -- Labels: InputFormat cassandra easyfix features (was: easyfix features newbie) > Creation of

[jira] [Commented] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499467#comment-16499467 ] aitozi commented on FLINK-9507: --- Hi [~kkl0u] Thanks for your quick answer, I have apply the patch

[jira] [Commented] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499464#comment-16499464 ] Kostas Kloudas commented on FLINK-9507: --- Hi [~aitozi]! This is a very nice idea and something that

[jira] [Created] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

aitozi created FLINK-9507: - Summary: Introduce ReduceFunction to CEP to minor the cost for IterativeCondition Key: FLINK-9507 URL: https://issues.apache.org/jira/browse/FLINK-9507 Project: Flink

[jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi updated FLINK-9507: -- Description: When we use the cep to describe a condition about the events that has been matched, we have to

[jira] [Comment Edited] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499445#comment-16499445 ] swy edited comment on FLINK-9506 at 6/3/18 3:04 PM: what we want to know is: Is this

[jira] [Comment Edited] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499445#comment-16499445 ] swy edited comment on FLINK-9506 at 6/3/18 3:03 PM: what we want to know is: Is this

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499445#comment-16499445 ] swy commented on FLINK-9506: what we want to know is: Is this something expected or something wrong in our

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6103 By the way, Till. I was wondering how can you find this issue ? Does this issue reported by the user ? ---

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

[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499415#comment-16499415 ] ASF GitHub Bot commented on FLINK-9413: --- Github user zhangminglei commented on the issue:

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499412#comment-16499412 ] swy commented on FLINK-9506: Hi [~sihuazhou] the keyby is comes from one of the private member in POJO.

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499401#comment-16499401 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on the issue:

[GitHub] flink issue #6043: [FLINK-7386] evolve RequestIndexer API to make it working...

Github user cjolif commented on the issue: https://github.com/apache/flink/pull/6043 > @cjolif do you think it would be possible that with a clean cut using a REST implementation, we no longer need to have separate modules anymore for ES 6.x, 7.x, 8.x or so on? i.e., it would

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499395#comment-16499395 ] Sihua Zhou commented on FLINK-9506: --- Hi [~yow] could you please give some information of the `keyBy()`?

[jira] [Issue Comment Deleted] (FLINK-9442) Flink Scaling not working

[ https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] swy updated FLINK-9442: --- Comment: was deleted (was: ok will post to mailing list as well. thanks. by the way once we change to

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499393#comment-16499393 ] swy commented on FLINK-9506: Hi Fabian, 1. Yes. 2. Yes. The state is suppose to store in Task Manager's

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

[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499367#comment-16499367 ] ASF GitHub Bot commented on FLINK-9413: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6103 @tillrohrmann I updated the code. Please review again. Thank you till. ---

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499356#comment-16499356 ] Fabian Hueske commented on FLINK-9506: -- Thanks for opening this issue. I have a few questions: 1)

[jira] [Updated] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9506: - Description: Hi, we found out application performance drop more than 100% when

[jira] [Updated] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] swy updated FLINK-9506: --- Attachment: flink.png > Flink ReducingState.add causing more than 100% performance drop >

[jira] [Created] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

swy created FLINK-9506: -- Summary: Flink ReducingState.add causing more than 100% performance drop Key: FLINK-9506 URL: https://issues.apache.org/jira/browse/FLINK-9506 Project: Flink Issue Type: