[jira] [Commented] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used

[ https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544960#comment-15544960 ] Melmoth commented on FLINK-4724: Hi [~eronwright], makes sense, that way always the log4j

[jira] [Commented] (FLINK-3656) Rework Table API tests

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

[GitHub] flink pull request #2567: [FLINK-3656] [table] Convert expression tests to u...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2567 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Created] (FLINK-4733) Port WebFrontend to new metric system

Chesnay Schepler created FLINK-4733: --- Summary: Port WebFrontend to new metric system Key: FLINK-4733 URL: https://issues.apache.org/jira/browse/FLINK-4733 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-4732) Maven junction plugin security threat

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

[GitHub] flink issue #2586: [FLINK-4732] remove maven junction plugin

Github user uce commented on the issue: https://github.com/apache/flink/pull/2586 Thanks! It's good to address this. I really liked the symbolic link, maybe we can enable it again after this has been resolved by the Maven plugin. +1 to merge this to `master` and `release-1.1`

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[GitHub] flink issue #2330: FLINK-4311 Fixed several problems in TableInputFormat

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2330 Hi @nielsbasjes, I just posted to the dev mailinglist and proposed to update the HBase dependency to 1.2.3 (as [FLINK-2765](https://issues.apache.org/jira/browse/FLINK-2765) suggests). By the end of

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

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

[GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2571 @KurtYoung I see, that makes sense. When the TM looses connection to the RM, it will eventually be detected by the heartbeating and the list of pending slot allocation removal requests will be cleared. T

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544874#comment-15544874 ] Timo Walther commented on FLINK-4604: - Hi [~anmu], 1. Yes, the test should look like t

[jira] [Commented] (FLINK-4732) Maven junction plugin security threat

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

[GitHub] flink pull request #2586: [FLINK-4732] remove maven junction plugin

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2586 [FLINK-4732] remove maven junction plugin On Windows, the plugin may download code from the author's web site. The downloaded file is not signed in the same way as Maven artifacts from Maven cent

[jira] [Commented] (FLINK-4732) Maven junction plugin security threat

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

[GitHub] flink issue #2586: [FLINK-4732] remove maven junction plugin

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2586 CC @uce --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the featur

[jira] [Updated] (FLINK-4732) Maven junction plugin security threat

[ https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4732: -- Description: We use the Maven Junction plugin http://pyx4j.com/pyx4j-maven-plugins/mave

[jira] [Created] (FLINK-4732) Maven junction plugin security threat

Maximilian Michels created FLINK-4732: - Summary: Maven junction plugin security threat Key: FLINK-4732 URL: https://issues.apache.org/jira/browse/FLINK-4732 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read

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

[jira] [Commented] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in

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

[GitHub] flink pull request #2584: [FLINK-4731] Bugfix for HeapKeyedStateBackend scal...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2584 [FLINK-4731] Bugfix for HeapKeyedStateBackend scale-in and additional tests in RescalingITCase Restoring the HeapKeyedStateBackend was broken in case that parallelism is reduced. The restore

[GitHub] flink pull request #2585: [FLINK-4727] [kafka-connector] Set missing initial...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/2585 [FLINK-4727] [kafka-connector] Set missing initial offset states with starting KafkaConsumer position This was fixed for the 0.8 consumer before. This PR adds the behaviour to the 0.9 consumer.

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Updated] (FLINK-4730) Introduce CheckpointMetaData

[ https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4730: -- Component/s: State Backends, Checkpointing > Introduce CheckpointMetaData >

[jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in

Stefan Richter created FLINK-4731: - Summary: HeapKeyedStateBackend restorig broken for scale-in Key: FLINK-4731 URL: https://issues.apache.org/jira/browse/FLINK-4731 Project: Flink Issue Type

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 @greghogan @vasia I've update the code according to your suggestion. The only thing that I did differently: I return Tuple4 from a more complete version of a bottom/top projections it contains v

[jira] [Commented] (FLINK-4730) Introduce CheckpointMetaData

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

[GitHub] flink pull request #2583: [FLINK-4730] Introduce checkpoint meta data

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2583 [FLINK-4730] Introduce checkpoint meta data Currently, the meta data for each checkpoint consists of up to 5 long values which are passed through several functions. When adding/removing meta

[jira] [Created] (FLINK-4730) Introduce CheckpointMetaData

Stefan Richter created FLINK-4730: - Summary: Introduce CheckpointMetaData Key: FLINK-4730 URL: https://issues.apache.org/jira/browse/FLINK-4730 Project: Flink Issue Type: Bug Repo

[jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09

[ https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544170#comment-15544170 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/4/16 7:41 AM: ---

<    1   2