[GitHub] flink issue #2307: [FLINK-4269] Decrease log level in RuntimeMonitorHandler

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2307 +1 to merge. Just for future considerations: The Flink community uses rebasing instead of merging branches to avoid these pesky merge commits. :) --- If your project is set up for it, you ca

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[GitHub] flink issue #2307: [FLINK-4269] Decrease log level in RuntimeMonitorHandler

Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2307 Hi @aditivin , welcome to the community. Thank you for the PR as well. A few suggestions: 1) Upon opening a PR, it is best to add more information regarding testing or even checks that you ha

[jira] [Commented] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

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

[GitHub] flink pull request #2307: [FLINK-4269] Decrease log level in RuntimeMonitorH...

GitHub user aditivin opened a pull request: https://github.com/apache/flink/pull/2307 [FLINK-4269] Decrease log level in RuntimeMonitorHandler @uce - I changed the log level to DEBUG in RuntimeMonitorHandler. PS - This is my first contribution, please forgive any mistakes :

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1690 @shikhar Ok, sure no problem :) --- 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

[GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c...

Github user shikhar commented on the issue: https://github.com/apache/flink/pull/1690 @tzulitai sorry I meant I won't be able to get to this change at all, so anyone please feel free to take this up! --- If your project is set up for it, you can reply to this email and have your rep

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink pull request #1690: FLINK-3398: Allow for opting-out from Kafka offset...

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

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1690 @shikhar Sure, please feel free to tag me for a review once you are done. I think you'll need to manually close this PR yourself, you can close it when the new PR is opened. Another option is to reb

[jira] [Assigned] (FLINK-4094) Off heap memory deallocation might not properly work

[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-4094: - Assignee: ramkrishna.s.vasudevan > Off heap memory deallocation might not

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c...

Github user shikhar commented on the issue: https://github.com/apache/flink/pull/1690 Thanks @tzulitai! I like your proposal, I'm afraid I won't be able to get around to shaping up this PR though so might be best to start a new one (please feel free to close). --- If your project is

[jira] [Commented] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project

[ https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15398081#comment-15398081 ] Neelesh Srinivas Salian commented on FLINK-4278: [~tedyu] any thoughts how

[jira] [Created] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project

Neelesh Srinivas Salian created FLINK-4278: -- Summary: Unclosed FSDataOutputStream in multiple files in the project Key: FLINK-4278 URL: https://issues.apache.org/jira/browse/FLINK-4278 Projec

[jira] [Closed] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy()

[ https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-4259. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 5d7e949. > Unclosed FSDataOutputStream in

[jira] [Commented] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy()

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

[GitHub] flink pull request #2299: [FLINK-4259]: Unclosed FSDataOutputStream in FileC...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2299 --- 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-4094) Off heap memory deallocation might not properly work

[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15397634#comment-15397634 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Can I work on this? I saw t

[jira] [Updated] (FLINK-4266) Cassandra StateBackend

[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4266: Summary: Cassandra StateBackend (was: Cassandra Statebackend) > Cassandra StateBackend > --

[jira] [Created] (FLINK-4277) TaskManagerConfigurationTest fails

Chesnay Schepler created FLINK-4277: --- Summary: TaskManagerConfigurationTest fails Key: FLINK-4277 URL: https://issues.apache.org/jira/browse/FLINK-4277 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS

Chesnay Schepler created FLINK-4276: --- Summary: TextInputFormatTest.testNestedFileRead fails on Windows OS Key: FLINK-4276 URL: https://issues.apache.org/jira/browse/FLINK-4276 Project: Flink

[jira] [Created] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends

Gyula Fora created FLINK-4275: - Summary: Generic Folding, Reducing and List states behave differently from other state backends Key: FLINK-4275 URL: https://issues.apache.org/jira/browse/FLINK-4275 Projec

[jira] [Created] (FLINK-4274) Expose new JobClient in the DataSet/DataStream API

Maximilian Michels created FLINK-4274: - Summary: Expose new JobClient in the DataSet/DataStream API Key: FLINK-4274 URL: https://issues.apache.org/jira/browse/FLINK-4274 Project: Flink Is

[jira] [Created] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

Maximilian Michels created FLINK-4273: - Summary: Refactor JobClientActor to watch already submitted jobs Key: FLINK-4273 URL: https://issues.apache.org/jira/browse/FLINK-4273 Project: Flink

[jira] [Created] (FLINK-4272) Create a JobClient for job control and monitoring

Maximilian Michels created FLINK-4272: - Summary: Create a JobClient for job control and monitoring Key: FLINK-4272 URL: https://issues.apache.org/jira/browse/FLINK-4272 Project: Flink Is

[jira] [Updated] (FLINK-4272) Create a JobClient for job control and monitoring

[ https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4272: -- Priority: Minor (was: Major) > Create a JobClient for job control and monitoring > ---

[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&focusedCommentId=15397346#comment-15397346 ] ASF GitHub Bot commented on FLINK-4271: --- Github user wuchong commented on the issue:

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

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2305 The CI failed because of japicmp, as we changed the public API. Have no idea how to fix this... --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request #2306: [FLINK-4270] [table] fix 'as' in front of join doe...

GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2306 [FLINK-4270] [table] fix 'as' in front of join does not work Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-4270) 'as' in front of join does not work

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

[jira] [Assigned] (FLINK-4270) 'as' in front of join does not work

[ https://issues.apache.org/jira/browse/FLINK-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4270: -- Assignee: Jark Wu > 'as' in front of join does not work > --- > >

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink issue #1690: FLINK-3398: Allow for opting-out from Kafka offset auto-c...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1690 What's the status of this PR? I think it is a good functionality to add. @shikhar if you'd like to continue working on this, I'm happy to help shepherd this PR for merging. Some of my input

[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&focusedCommentId=15397229#comment-15397229 ] ASF GitHub Bot commented on FLINK-4271: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStrea...

GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2305 [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and JoinedStreams to set parallellism Thanks for contributing to Apache Flink. Before you open your pull request, please take the following chec

[jira] [Resolved] (FLINK-4179) Update TPCHQuery3Table example

[ https://issues.apache.org/jira/browse/FLINK-4179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4179. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 185b5f6c6b91e4ae61ff77c7d22d1296153a320c.

[GitHub] flink pull request #2232: FLINK-4179: Update TPCHQuery3Table example

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2232 --- 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-4179) Update TPCHQuery3Table example

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

[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&focusedCommentId=15397187#comment-15397187 ] Jark Wu commented on FLINK-4271: Yea, SingleOutputStreamOperator can set parallelism, uid,

[jira] [Comment Edited] (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&focusedCommentId=15397140#comment-15397140 ] Wenlong Lyu edited comment on FLINK-4271 at 7/28/16 7:05 AM: -

[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&focusedCommentId=15397140#comment-15397140 ] Wenlong Lyu commented on FLINK-4271: I think the solution can be better. Not only the