[jira] [Created] (FLINK-4516) ResourceManager leadership election

zhangjing created FLINK-4516: Summary: ResourceManager leadership election Key: FLINK-4516 URL: https://issues.apache.org/jira/browse/FLINK-4516 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #1985: [FLINK-1979] Add logistic loss, hinge loss and regulariza...

Github user skavulya commented on the issue: https://github.com/apache/flink/pull/1985 hi @chiwanpark sorry, I hadn't checked this PR for a while. I merged the latest master. Do you have any preference on an alternative name for RegularizationPenalty? Would Regularizer work better?

[jira] [Commented] (FLINK-1979) Implement Loss Functions

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

[jira] [Assigned] (FLINK-4516) ResourceManager leadership election

[ https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing reassigned FLINK-4516: Assignee: zhangjing > ResourceManager leadership election > --- >

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2388 I think i shall do the resolving thing. The commits are squashed and conflicts been resolved. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4347) Implement SlotManager core

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

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2109 @aljoscha As already pointed out in the JIRA issue, the method is not new. A now obsolete method has been deprecated (the diff is hard to read). --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

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

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438936#comment-15438936 ] Maximilian Michels commented on FLINK-3677: --- No worries. Your changes are not wrong in any way.

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

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

[jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better

[ https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439112#comment-15439112 ] Maximilian Michels commented on FLINK-4487: --- I totally forgot that there is also a way to

[GitHub] flink pull request #2391: [FLINK-3580] [table] Implement FLOOR/CEIL for time...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2391 --- 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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better

[ https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438662#comment-15438662 ] Aljoscha Krettek commented on FLINK-4487: - This could also already be addressed by the work on

[GitHub] flink issue #2422: FLINK-4499: Introduce findbugs maven plugin

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2422 Thanks for adding this. I think that pure warning by the plugin will not be read and respected really. So it makes only sense when a "bug" detected by the plugin fails the build.

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438716#comment-15438716 ] Ivan Mushketyk commented on FLINK-3677: --- Stephan, Aljoscha Thank you for pointing this out. I'll

[jira] [Commented] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

[ https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438754#comment-15438754 ] Chesnay Schepler commented on FLINK-4502: - Alright, so let's break this down point by point:

[jira] [Commented] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets

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

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

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

[jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better

[ https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438883#comment-15438883 ] Maximilian Michels commented on FLINK-4487: --- {quote} 1. If there is already a yarn-session

[GitHub] flink pull request #2374: [FLINK-3950] Add Meter Metric Type

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2374#discussion_r76411144 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Meter.java --- @@ -0,0 +1,51 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438935#comment-15438935 ] Maximilian Michels commented on FLINK-3677: --- I reviewed the pull requests and I was aware of

[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=15439102#comment-15439102 ] ASF GitHub Bot commented on FLINK-4311: --- Github user nielsbasjes commented on the issue:

[GitHub] flink pull request #2374: [FLINK-3950] Add Meter Metric Type

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2374#discussion_r76410471 --- Diff: flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardMeterWrapperTest.java --- @@ -0,0 +1,60 @@

[jira] [Created] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests

Stefan Richter created FLINK-4508: - Summary: Consolidate DummyEnvironment and MockEnvironment for Tests Key: FLINK-4508 URL: https://issues.apache.org/jira/browse/FLINK-4508 Project: Flink

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

Github user nielsbasjes commented on the issue: https://github.com/apache/flink/pull/2330 I managed to resolve the problems with running these unit tests. These problems were caused by version conflicts in guava. Now we have a HBaseMiniCluster that is started, a table with

[GitHub] flink issue #2391: [FLINK-3580] [table] Implement FLOOR/CEIL for time points

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2391 Thanks @fhueske. I will address your comments and merge this. --- 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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink pull request #2374: [FLINK-3950] Add Meter Metric Type

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2374#discussion_r76410073 --- Diff: docs/monitoring/metrics.md --- @@ -155,6 +155,55 @@ public class MyMapper extends RichMapFunction { } {% endhighlight %}

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

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

[jira] [Commented] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438685#comment-15438685 ] Maximilian Michels commented on FLINK-4486: --- The {{YarnClusterClient}} delays checking for the

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2109 Hi, I just saw that this was merged but I still have some comments. What is the reason for the added Guava (test)-dependency? (Probably a leftover but should nevertheless not be in this) And

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

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

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

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

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438697#comment-15438697 ] Stephan Ewen commented on FLINK-3677: - I agree with Aljoscha. I am against adding that new method the

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Updated] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4486: -- Fix Version/s: 1.1.2 1.2.0 > JobManager not fully running when

[GitHub] flink pull request #:

Github user mushketyk commented on the pull request: https://github.com/apache/flink/commit/abb4496781883937a935113c1e33ae1174aafa73#commitcomment-18789946 Hi Stephan. I think you are right. I'll update the testing as soon as possible and create a different PR to address

[jira] [Assigned] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4486: - Assignee: Maximilian Michels > JobManager not fully running when yarn-session.sh

[jira] [Commented] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator.

[ https://issues.apache.org/jira/browse/FLINK-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438695#comment-15438695 ] Aljoscha Krettek commented on FLINK-4494: - +1 that would be a very good change > Expose the

[GitHub] flink issue #2269: [FLINK-4190] Generalise RollingSink to work with arbitrar...

Github user joshfg commented on the issue: https://github.com/apache/flink/pull/2269 Hi Aljoscha, just wanted to remind you about this - any idea when the changes will be merged in? Thanks! --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438661#comment-15438661 ] Aljoscha Krettek commented on FLINK-4486: - Or that a {{JobManager}} takes the job and blocks and

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

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

[GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2305 The methods look good. They need a `@PublicEvolving` annotation and I think we should mark them with `@Deprecated` and comment that they are a temporary workaround while the `apply()` method has

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438745#comment-15438745 ] Zhijiang Wang commented on FLINK-4363: -- Hi [~mxm], I have created the FLINK-4505 for

[jira] [Updated] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

[ https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4502: Component/s: Cassandra Connector > Cassandra connector documentation has misleading

[jira] [Updated] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4498: Component/s: Cassandra Connector > Better Cassandra sink documentation >

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

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

[jira] [Created] (FLINK-4507) Deprecate savepoint backend config

Ufuk Celebi created FLINK-4507: -- Summary: Deprecate savepoint backend config Key: FLINK-4507 URL: https://issues.apache.org/jira/browse/FLINK-4507 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #2244: [FLINK-3874] Add a Kafka TableSink with JSON seria...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2244 --- 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

[GitHub] flink pull request #:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/4810910431e01bf143ae77a6e93a86f2fafbccd0#commitcomment-18789532 There is some followup discussion on this in the JIRA issue: https://issues.apache.org/jira/browse/FLINK-3677 --- If your

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438710#comment-15438710 ] Stephan Ewen commented on FLINK-3874: - I think this needs some improvement. I also commented on the

[jira] [Comment Edited] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438710#comment-15438710 ] Stephan Ewen edited comment on FLINK-3874 at 8/26/16 9:25 AM: -- I think this

[GitHub] flink pull request #:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/abb4496781883937a935113c1e33ae1174aafa73#commitcomment-18789807 Can I re-iterate on this issue? Do we need tests here that fire up Kafka clusters? Those are very time intensive,

[GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2305 Hi @StephanEwen , comments addressed. I'm not sure whether the comments are correct. Let me know if I'm wrong. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request #2423: [FLINK-4486] detached YarnSession: wait until clus...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2423 [FLINK-4486] detached YarnSession: wait until cluster startup is complete You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-4486

[jira] [Commented] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

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

[GitHub] flink issue #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2361 Could someone please take a look at this PR? It has been here without a review for more than 2 weeks. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better

[ https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438690#comment-15438690 ] Stephan Ewen commented on FLINK-4487: - I think that the last changes for cluster management by [~mxm]

[jira] [Created] (FLINK-4505) Implement abstract TaskManagerFactory to bring up TaskManager for different modes

Zhijiang Wang created FLINK-4505: Summary: Implement abstract TaskManagerFactory to bring up TaskManager for different modes Key: FLINK-4505 URL: https://issues.apache.org/jira/browse/FLINK-4505

[jira] [Updated] (FLINK-4505) Implement TaskManagerFactory to bring up TaskManager for different modes

[ https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-4505: - Summary: Implement TaskManagerFactory to bring up TaskManager for different modes (was:

[jira] [Assigned] (FLINK-4505) Implement TaskManagerFactory to bring up TaskManager for different modes

[ https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-4505: Assignee: Zhijiang Wang > Implement TaskManagerFactory to bring up TaskManager for

[jira] [Created] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

Michael Wong created FLINK-4506: --- Summary: CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true Key: FLINK-4506 URL: https://issues.apache.org/jira/browse/FLINK-4506

[jira] [Created] (FLINK-4511) Schedule periodic savepoints

Ufuk Celebi created FLINK-4511: -- Summary: Schedule periodic savepoints Key: FLINK-4511 URL: https://issues.apache.org/jira/browse/FLINK-4511 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4512) Add option for persistent checkpoints

Ufuk Celebi created FLINK-4512: -- Summary: Add option for persistent checkpoints Key: FLINK-4512 URL: https://issues.apache.org/jira/browse/FLINK-4512 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4510) Always create CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4510: Assignee: Jark Wu > Always create CheckpointCoordinator > --- > >

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

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

[jira] [Updated] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream

[ https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4514: --- Affects Version/s: 1.1.1 1.1.0 > ExpiredIteratorException in

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2418 The funky thing is that internally the ObjectName reconverts the Hashtable to a Map... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request #2425: FLINK-3930 Added shared secret based authorization...

GitHub user vijikarthi opened a pull request: https://github.com/apache/flink/pull/2425 FLINK-3930 Added shared secret based authorization for Flink service … This PR addresses FLINK-3930 requirements. It enables shared secret based secure cookie authorization for the following

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[jira] [Commented] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests

[ https://issues.apache.org/jira/browse/FLINK-4508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439165#comment-15439165 ] Aljoscha Krettek commented on FLINK-4508: - Plus there's custom-mocked Environments in some tests.

[GitHub] flink pull request #2424: [FLINK-4459][Scheduler] Introduce SlotProvider for...

GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/2424 [FLINK-4459][Scheduler] Introduce SlotProvider for Scheduler Introduce SlotProvider, prepare for the further slot allocation refactoring You can merge this pull request into a Git repository by

[jira] [Commented] (FLINK-4459) Introduce SlotProvider for Scheduler

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

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2109 @mxm @mushketyk Technically this change does add a new method that is the now deprecated method minus the `FilePathFilter`. That's a good change, though, since it simplifies the API in the long

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

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

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439292#comment-15439292 ] Jark Wu commented on FLINK-4510: Hi [~uce] , I would like to contribute this issue. > Always create

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2109 Ah, got it too now. The diff only makes it appear like the deprecated method is new. Then I take that back :-) A followup on removing Guava would be nice, through... --- If your project is

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2418 Looks good to me! The only not-so-nice thing is that we have to convert the `Map` to a `HashTable` for every metric. Given how we tried to optimize the metric creation overhead, this it

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[jira] [Commented] (FLINK-4347) Implement SlotManager core

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

[jira] [Commented] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

[ https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439445#comment-15439445 ] Elias Levy commented on FLINK-4502: --- Chesnay, thanks for correcting me about the overwriting issue. I

[jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

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

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2388 Looks quite good all in all. Be good to get this in, so that JobManager followup work can build on this. I would take this, rebase it, and merge it. If I find some issues I would

[jira] [Commented] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs

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

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2418 Actually, it may be possible, and not too bad if we assume the Hashtable is immutable. Something like this: ```java public class HashtableWrapper extends Hashtable {

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

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

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2109 @mxm @aljoscha @StephanEwen Thank you for your comments. Seems like this is sorted out :) I'll remove Guava calls today at the evening. --- If your project is set up for it, you can reply to

[GitHub] flink issue #2376: [FLINK-3755] Introduce key groups for key-value state to ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2376 Very good work and very nice code! Some comments after a joint review: - The most critical issue is that there should not be any blocking on async threads during task

[GitHub] flink pull request #2383: [FLINK-4418] [client] Improve resilience when Inet...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2383 --- 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

[jira] [Created] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream

Tzu-Li (Gordon) Tai created FLINK-4514: -- Summary: ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream Key: FLINK-4514 URL: https://issues.apache.org/jira/browse/FLINK-4514

[jira] [Updated] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream

[ https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4514: --- Description: Original mailing thread for the reported issue:

[GitHub] flink issue #2419: [FLINK-4488] only automatically shutdown clusters for det...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2419 Our currents tests make it difficult to test such behavior. Added a check to the `YarnTestBase`. Basically, I'm skipping the cluster shutdown to check if the JobManager is still alive and hasn't been

[jira] [Commented] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

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

[GitHub] flink pull request #2416: FLINK-4480: Incorrect link to elastic.co in docume...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2416 --- 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

[jira] [Commented] (FLINK-4480) Incorrect link to elastic.co in documentation

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

[jira] [Closed] (FLINK-4440) Make API for edge/vertex creation less verbose

[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk closed FLINK-4440. - Resolution: Not A Problem > Make API for edge/vertex creation less verbose >

[GitHub] flink issue #2269: [FLINK-4190] Generalise RollingSink to work with arbitrar...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2269 Hi, I'm very for the delays! I still have this sitting at the top of my list and I'm hoping to get this in by beginning of next week. --- If your project is set up for it, you can reply to

  1   2   >