[GitHub] flink pull request #5076: [FLINK-7574][build] POM Cleanup flink-clients

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/5076 [FLINK-7574][build] POM Cleanup flink-clients Re-created #4712. ## What is the purpose of the change This PR changes the `flink-clients` pom to - contain unused dependencie

[jira] [Commented] (FLINK-7574) flink-clients

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

[jira] [Updated] (FLINK-7777) Bump japicmp to 0.11.0

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-: -- Affects Version/s: (was: 1.3.2) 1.5.0 > Bump japicmp to 0.11.0 >

[jira] [Commented] (FLINK-8144) Optimize the timer logic in RowTimeUnboundedOver

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

[GitHub] flink issue #5063: [FLINK-8144] [table] Optimize the timer logic in RowTimeU...

Github user dianfu commented on the issue: https://github.com/apache/flink/pull/5063 @fhueske Yes, the bad performance is related to the way we generate the watermarks. But this is the way how punctuated watermark works. If we do not optimize for punctuated watermark, then are we sug

[jira] [Created] (FLINK-8156) Bump commons-beanutils version to 1.9.3

Hai Zhou UTC+8 created FLINK-8156: - Summary: Bump commons-beanutils version to 1.9.3 Key: FLINK-8156 URL: https://issues.apache.org/jira/browse/FLINK-8156 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8156) Bump commons-beanutils version to 1.9.3

[ https://issues.apache.org/jira/browse/FLINK-8156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-8156: -- Description: Commons-beanutils v1.8.0 dependency is not security compliant. See [CVE-2014-0114|

[jira] [Updated] (FLINK-7982) Bump commons-configuration to 2.2

[ https://issues.apache.org/jira/browse/FLINK-7982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7982: -- Summary: Bump commons-configuration to 2.2 (was: Bump commons-configuration to 2.1.1) > Bump c

[jira] [Updated] (FLINK-7982) Bump commons-configuration to 2.2

[ https://issues.apache.org/jira/browse/FLINK-7982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7982: -- Description: Currently the dependency {{org.apache.commons:commons-configuration (version:1.7, S

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

Github user dikei commented on the issue: https://github.com/apache/flink/pull/1668 Hi. Do we have any updates on this :) ---

[GitHub] flink pull request #5075: [hotfix] [docs] Fix typos in State Backends doc

GitHub user casidiablo opened a pull request: https://github.com/apache/flink/pull/5075 [hotfix] [docs] Fix typos in State Backends doc You can merge this pull request into a Git repository by running: $ git pull https://github.com/casidiablo/flink wording-state-backends Alte

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266336#comment-16266336 ] ASF GitHub Bot commented on FLINK-7873: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5074: [FLINK-7873] [runtime] Introduce local recovery

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5074 @StefanRRichter Could you please have a look at this? ---

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

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

[GitHub] flink pull request #5074: [FLINK-7873] [runtime] Introduce local recovery

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5074 [FLINK-7873] [runtime] Introduce local recovery ## What is the purpose of the change This PR fixes [FLINK-7873](https://issues.apache.org/jira/browse/FLINK-7873). Current recover strateg

[jira] [Reopened] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reopened FLINK-7873: --- reopen for PR. > Introduce CheckpointCacheManager for reading checkpoint data locally when > performing

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266320#comment-16266320 ] ASF GitHub Bot commented on FLINK-4520: --- Github user haoch closed the pull request a

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink pull request #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l...

Github user haoch closed the pull request at: https://github.com/apache/flink/pull/2487 ---

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

Github user haoch commented on the issue: https://github.com/apache/flink/pull/2487 Finally, the PR merged into https://github.com/apache/bahir-flink/pull/22, thanks everyone for the review! ---

[jira] [Resolved] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Chen resolved FLINK-4520. - Resolution: Resolved Release Note: Merged Bahir Flink: * https://issues.apache.org/jira/browse/BAHIR

[jira] [Resolved] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7718. -- Resolution: Done Added via 1119c48c2470e280aaf3441ce170245070dd0986 > Port JobVertixMetricsHand

[jira] [Commented] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266144#comment-16266144 ] ASF GitHub Bot commented on FLINK-7718: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5055: [FLINK-7718] [flip6] Add JobVertexMetricsHandler t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5055 ---

[GitHub] flink pull request #5073: [FLINK-8124] Make Trigger implementations more gen...

GitHub user casidiablo opened a pull request: https://github.com/apache/flink/pull/5073 [FLINK-8124] Make Trigger implementations more generic # What is the purpose of the change Flink provides implementations of the `Trigger` class that are unnecessarily specific. `Eve

[jira] [Commented] (FLINK-8124) EventTimeTrigger (and other triggers) could have less specific generic types

[ https://issues.apache.org/jira/browse/FLINK-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266099#comment-16266099 ] ASF GitHub Bot commented on FLINK-8124: --- GitHub user casidiablo opened a pull reques

[jira] [Commented] (FLINK-7984) Bump snappy-java to 1.1.4

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

[GitHub] flink pull request #5072: [FLINK-7984][build] Bump snappy-java to 1.1.4

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/5072 [FLINK-7984][build] Bump snappy-java to 1.1.4 ## What is the purpose of the change This PR bumps the snappy-java version to 1.1.14. snappy-java-1.1.4 (2017-05-22): - Fix a 1% performa

[jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface

[ https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16266003#comment-16266003 ] Gabor Gevay commented on FLINK-8116: Hi, The mentions of the Checkpointed interface n

[jira] [Updated] (FLINK-8155) Class org.apache.hadoop.yarn.client.RequestHedgingRMFailoverProxyProvider not found

[ https://issues.apache.org/jira/browse/FLINK-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiesen.li updated FLINK-8155: - Description: There was an error when I start flink 1.3.2 on yarn of hdp2.6, but when I tried remove +YARN

[jira] [Commented] (FLINK-7907) Flink Metrics documentation missing Scala examples

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

[GitHub] flink pull request #5071: [FLINK-7907][docs] The metrics documentation missi...

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/5071 [FLINK-7907][docs] The metrics documentation missing scala snippets ## What is the purpose of the change *The metrics documentation is missing Scala examples for many of the metrics types. T

[jira] [Created] (FLINK-8155) Class org.apache.hadoop.yarn.client.RequestHedgingRMFailoverProxyProvider not found

jiesen.li created FLINK-8155: Summary: Class org.apache.hadoop.yarn.client.RequestHedgingRMFailoverProxyProvider not found Key: FLINK-8155 URL: https://issues.apache.org/jira/browse/FLINK-8155 Project: Fl

[jira] [Created] (FLINK-8154) JobSubmissionClientActor submited job,but there is no connection to a JobManager

Gregory Melekh created FLINK-8154: - Summary: JobSubmissionClientActor submited job,but there is no connection to a JobManager Key: FLINK-8154 URL: https://issues.apache.org/jira/browse/FLINK-8154 Pro

[jira] [Assigned] (FLINK-3829) flink-java

[ https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-3829: - Assignee: Hai Zhou UTC+8 > flink-java > -- > > Key: FLINK-3829 >