[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

2016-09-21 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2467 Hi @StephanEwen All images are coming from this repo: https://github.com/nathancahill/Split.js It has a very permissive license: https://github.com/nathancahill/Split.js/blob/master/L

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2016-09-21 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512390#comment-15512390 ] Ivan Mushketyk commented on FLINK-4641: --- Hi [~kervel] I think the method chaining w

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512350#comment-15512350 ] ASF GitHub Bot commented on FLINK-4564: --- Github user ex00 closed the pull request at

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

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

[jira] [Issue Comment Deleted] (FLINK-4564) [metrics] Delimiter should be configured per reporter

2016-09-21 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin updated FLINK-4564: Comment: was deleted (was: Not all clear. How should look like {{MetricGroup#getMetricIdentifier()}}

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512352#comment-15512352 ] ASF GitHub Bot commented on FLINK-4564: --- GitHub user ex00 reopened a pull request:

[GitHub] flink pull request #2517: [FLINK-4564] [metrics] Delimiter should be configu...

2016-09-21 Thread ex00
GitHub user ex00 reopened a pull request: https://github.com/apache/flink/pull/2517 [FLINK-4564] [metrics] Delimiter should be configured per reporter Hi It is my fix FLINK-4564. I want fix this issue, please send me your comments about this implementation. I could assign to

[GitHub] flink pull request #2517: [FLINK-4564] [metrics] Delimiter should be configu...

2016-09-21 Thread ex00
Github user ex00 closed the pull request at: https://github.com/apache/flink/pull/2517 --- 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 enable

[GitHub] flink issue #2517: [FLINK-4564] [metrics] Delimiter should be configured per...

2016-09-21 Thread ex00
Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2517 Not all clear. How should look like `MetricGroup#getMetricIdentifier()`call in this case? If we use single reporter for other reporters and know their indexes, we must know name or index where w

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-21 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 I agree with @delding here. >* Method that does a batch call on Deletes, Gets, Puts, Increments and Appends. * The ordering of execution of the actions is not defined. Meaning

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-21 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 ` #2330 updates the version of the batch TableInputFormat to HBase 1.1.2. I think we should use the same version here.` Valid point. But is it possible to upgrade to even newer version like 1.1

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-21 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 I can change back to HBase 1.1.2. The reason of using 2.0.0-SNAPSHOT is because this bug (https://issues.apache.org/jira/browse/HBASE-14963 ). It's only fixed for version 1.3.0+ and 2.0.0 and my exam

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-21 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @fhueske , in HBase writes to a single row have ACID guarantee. The exactly once semantic can be implemented the way CassandraSink did, storing input records in a state backend and flushing to HBa

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

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

[GitHub] flink pull request #2532: [FLINK-4494] Expose the TimeServiceProvider from t...

2016-09-21 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2532 [FLINK-4494] Expose the TimeServiceProvider from the Task to each Operator. This is a PR for both [FLINK-4496] and [FLINK-4494]. R: @aljoscha You can merge this pull request into a Git repository

[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

2016-09-21 Thread Nagarjun Guraja (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511311#comment-15511311 ] Nagarjun Guraja commented on FLINK-4650: [~StephanEwen] I haven't spent lot of tim

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Attachment: Screen Shot 2016-09-20 at 2.49.32 PM.png Screen Shot 2016-09-20 at 2.49.1

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-4660: Description: Flink job with checkpoints enabled and configured to use S3A file system backend, some

[jira] [Created] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2016-09-21 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4660: --- Summary: HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop Key: FLINK-4660 URL: https://issues.apache.org/jira/browse/FLINK-4660

[jira] [Created] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()

2016-09-21 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4659: - Summary: Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties() Key: FLINK-4659 URL: https://issues.apache.org/jira/browse/FLINK-4659

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo...

2016-09-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2303 I still think that methods should be named after what they do (and there is nothing numeric about their behavior) and not in which context they are supposed to be called. The error messages are numer

[GitHub] flink issue #2479: [FLINK-4537] [cluster management] ResourceManager registr...

2016-09-21 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2479 Thank you for the pull request! I've rebased the changes and will merge them to the master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Commented] (FLINK-4537) ResourceManager registration with JobManager

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

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

2016-09-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510680#comment-15510680 ] Fabian Hueske commented on FLINK-4506: -- I'm not sure about that. The CsvInputFormat s

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink issue #2451: [FLINK-4535] [cluster management] resourceManager process...

2016-09-21 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2451 Thank you for the pull request! I've rebased the changes and will merge them to the master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

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

2016-09-21 Thread Michael Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510589#comment-15510589 ] Michael Wong commented on FLINK-4506: - Ok, but let's forget about what was there befor

[GitHub] flink pull request #2531: [FLINK-4658] [rpc] Allow RpcService to execute Run...

2016-09-21 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2531 --- 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 i

[jira] [Closed] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor

2016-09-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4658. Resolution: Fixed Fixed via b5f6a06b01436a8b0e7243e3f8af7444f8058868 > Allow RpcService to execute

[jira] [Commented] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510460#comment-15510460 ] ASF GitHub Bot commented on FLINK-4658: --- Github user tillrohrmann closed the pull re

[jira] [Commented] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510452#comment-15510452 ] ASF GitHub Bot commented on FLINK-4658: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2531: [FLINK-4658] [rpc] Allow RpcService to execute Runnables ...

2016-09-21 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2531 Thanks for the review @mxm. Will merge it. --- 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 feat

[GitHub] flink issue #2531: [FLINK-4658] [rpc] Allow RpcService to execute Runnables ...

2016-09-21 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2531 +1 Looks good! --- 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

[jira] [Commented] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor

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

[jira] [Commented] (FLINK-4656) Port existing code to use Flink's future abstraction

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510429#comment-15510429 ] ASF GitHub Bot commented on FLINK-4656: --- Github user tillrohrmann closed the pull re

[jira] [Closed] (FLINK-4656) Port existing code to use Flink's future abstraction

2016-09-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4656. Resolution: Fixed Fixed via 31a091b930178bf2aec2881ee273fe0e5e17464d > Port existing code to use Fl

[GitHub] flink pull request #2530: [FLINK-4656] [rpc] Port the existing code to Flink...

2016-09-21 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2530 --- 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 i

[jira] [Commented] (FLINK-4656) Port existing code to use Flink's future abstraction

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510423#comment-15510423 ] ASF GitHub Bot commented on FLINK-4656: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2530: [FLINK-4656] [rpc] Port the existing code to Flink's own ...

2016-09-21 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2530 Will merge the PR since it's prone to merge conflicts. --- 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 ha

[GitHub] flink pull request #2531: [FLINK-4658] [rpc] Allow RpcService to execute Run...

2016-09-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2531 [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor The PR is based on #2530. The newly introduced methods are `void RpcService.execute(Runnable)` an

[jira] [Commented] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510421#comment-15510421 ] ASF GitHub Bot commented on FLINK-4658: --- GitHub user tillrohrmann opened a pull requ

[jira] [Comment Edited] (FLINK-4564) [metrics] Delimiter should be configured per reporter

2016-09-21 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509946#comment-15509946 ] Anton Mushin edited comment on FLINK-4564 at 9/21/16 4:10 PM: --

[jira] [Resolved] (FLINK-4645) Hard to register Kryo Serializers due to generics

2016-09-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4645. - Resolution: Fixed Fixed via 82ef021cb8f77635bcec61d49eedce1ddefd1e48 > Hard to register Kryo Seri

[jira] [Closed] (FLINK-4645) Hard to register Kryo Serializers due to generics

2016-09-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4645. --- > Hard to register Kryo Serializers due to generics > - >

[GitHub] flink pull request #2522: Parameterize Flink version in Quickstart bash scri...

2016-09-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2522 --- 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] [Closed] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

2016-09-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4640. --- > Serialization of the initialValue of a Fold on WindowedStream fails > --

[jira] [Resolved] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

2016-09-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4640. - Resolution: Fixed Fixed in - 1.1.3 via 52a4440d916fb450c4999f6e1f42f392e247b426 - 1.2.0 via 4d

[jira] [Created] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor

2016-09-21 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4658: Summary: Allow RpcService to execute Callables in the RpcService executor Key: FLINK-4658 URL: https://issues.apache.org/jira/browse/FLINK-4658 Project: Flink

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

2016-09-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4651: Fix Version/s: 1.2.0 > Re-register processing time timers at the WindowOperator upon recovery. > ---

[jira] [Commented] (FLINK-4656) Port existing code to use Flink's future abstraction

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510296#comment-15510296 ] ASF GitHub Bot commented on FLINK-4656: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

2016-09-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510313#comment-15510313 ] Aljoscha Krettek commented on FLINK-4616: - +1, I think this would be good to have.

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo...

2016-09-21 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2303 @fhueske I think we should keep the methods as they currently are. I renamed them to "nextNumericString"/"nextNumericStringEndPos" and added a explanation what a numeric string is. You are right they

[GitHub] flink pull request #2530: [FLINK-4656] [rpc] Port the existing code to Flink...

2016-09-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2530 [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction This pull request removes Scala's `Futures` from all new Flip-6 components and replaces them with Flink's own `Future

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2016-09-21 Thread Frank Dekervel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510291#comment-15510291 ] Frank Dekervel commented on FLINK-4641: --- i think the second option would made it har

[GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t...

2016-09-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2434#discussion_r79854335 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -365,19 +364,6 @@ public Long getValue() {

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510265#comment-15510265 ] ASF GitHub Bot commented on FLINK-4496: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t...

2016-09-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2434#discussion_r79858930 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/TimeProviderTest.java --- @@ -0,0 +1,198 @@ +/* + * Licens

[GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t...

2016-09-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2434#discussion_r79854646 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -326,6 +322,9 @@ public Long getValue() {

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510266#comment-15510266 ] ASF GitHub Bot commented on FLINK-4496: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510267#comment-15510267 ] ASF GitHub Bot commented on FLINK-4496: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510268#comment-15510268 ] ASF GitHub Bot commented on FLINK-4496: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t...

2016-09-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2434#discussion_r79854449 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -486,6 +472,9 @@ private void disposeAllOperato

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510269#comment-15510269 ] ASF GitHub Bot commented on FLINK-4496: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t...

2016-09-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2434#discussion_r79853936 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -212,10 +212,6 @@ public void setTimeService(Ti

[jira] [Commented] (FLINK-4241) Cryptic expression parser exceptions

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

[GitHub] flink pull request #2529: [FLINK-4241] [table] Cryptic expression parser exc...

2016-09-21 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2529 [FLINK-4241] [table] Cryptic expression parser exceptions Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Updated] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4657: -- Description: For flip-6, we will have ResourceManager and every JobManager as potential leader contende

[GitHub] flink issue #2525: [FLINK-4654] Small improvements to the docs.

2016-09-21 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2525 Thank you for the contribution @alpinegizmo. --- 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 featu

[jira] [Commented] (FLINK-4654) clean up docs

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

[GitHub] flink pull request #2528: [FLINK-4643] [gelly] Average Clustering Coefficien...

2016-09-21 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2528 [FLINK-4643] [gelly] Average Clustering Coefficient Questions: - Can we generalize "average" to operator on a common interface (i.e. "ScorableResult")? Here, the average clustering coefficient

[jira] [Commented] (FLINK-4643) Average Clustering Coefficient

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

[jira] [Created] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-21 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4657: - Summary: Implement HighAvailabilityServices based on zookeeper Key: FLINK-4657 URL: https://issues.apache.org/jira/browse/FLINK-4657 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-4654) clean up docs

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

[GitHub] flink issue #2525: [FLINK-4654] Small improvements to the docs.

2016-09-21 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2525 No worries. 😃 --- 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

[jira] [Closed] (FLINK-4654) clean up docs

2016-09-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4654. - Resolution: Implemented Implemented in 7212202036235f41e376872dc268735ba9ef81e9 > clean up docs > ---

[jira] [Commented] (FLINK-4654) clean up docs

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510155#comment-15510155 ] ASF GitHub Bot commented on FLINK-4654: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2525: [FLINK-4654] Small improvements to the docs.

2016-09-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2525 --- 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] [Commented] (FLINK-4654) clean up docs

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

[GitHub] flink issue #2525: [FLINK-4654] Small improvements to the docs.

2016-09-21 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2525 Oh no! I just committed. --- 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 wishe

[jira] [Updated] (FLINK-4654) clean up docs

2016-09-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4654: -- Fix Version/s: 1.2.0 > clean up docs > - > > Key: FLINK-4654 >

[jira] [Commented] (FLINK-4379) Add Rescalable Non-Partitioned State

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

[GitHub] flink issue #2512: [FLINK-4379] Rescalable non-partitioned state

2016-09-21 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2512 I think most of the proposed renames are good. One thing that would be good to change is to remove `SnapshotProvider` and just have that method directly on `OperatorStateBackend`. I really

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

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

[GitHub] flink pull request #2527: [FLINK-4624] Allow for null values in Graph Summar...

2016-09-21 Thread s1ck
GitHub user s1ck opened a pull request: https://github.com/apache/flink/pull/2527 [FLINK-4624] Allow for null values in Graph Summarization * Bug was caused by serializers that cannot handle null values (e.g. Long) * VertexGroupItem now uses Either instead of VV * Generalized

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

2016-09-21 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509946#comment-15509946 ] Anton Mushin commented on FLINK-4564: - Not all clear. How should look like MetricGroup

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-09-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509930#comment-15509930 ] ASF GitHub Bot commented on FLINK-4248: --- Github user fhueske commented on a diff in

  1   2   3   >