[jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

[ https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314630#comment-15314630 ] ramkrishna.s.vasudevan commented on FLINK-3850: --- [~fhueske] Is it possible that I could work

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322334#comment-15322334 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- [~till.rohrmann], [~trohrm...@apache.org]

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15313977#comment-15313977 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- [~till.rohrmann] [~fhueske] Any chance of a

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345820#comment-15345820 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- Can I take this up? Planning to read the

[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=15339332#comment-15339332 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- So if the direct memory cannot be reused

[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=15339331#comment-15339331 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Offheap direct memory cannot be cleared

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15348283#comment-15348283 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- I checked this JIRA and the one prior to

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347836#comment-15347836 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Your thoughts here? > Failed

[jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15118624#comment-15118624 ] ramkrishna.s.vasudevan commented on FLINK-3135: --- Thank you. > Add chainable driver for

[jira] [Assigned] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3179: - Assignee: ramkrishna.s.vasudevan > Combiner is not injected if Reduce or

[jira] [Reopened] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reopened FLINK-3135: --- Assignee: ramkrishna.s.vasudevan Reopening for changing the assignment.

[jira] [Closed] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan closed FLINK-3135. - Resolution: Fixed > Add chainable driver for UNARY_NO_OP strategy >

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

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15119858#comment-15119858 ] ramkrishna.s.vasudevan commented on FLINK-2055: --- [~vanaepi] Using TableOutputFormat will be

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

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121196#comment-15121196 ] ramkrishna.s.vasudevan commented on FLINK-2055: --- Is some one working on this -

[jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116688#comment-15116688 ] ramkrishna.s.vasudevan commented on FLINK-3135: --- [~fhueske] Is there any way to assign an

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

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15126221#comment-15126221 ] ramkrishna.s.vasudevan commented on FLINK-2055: --- Thanks for your inputs. For the batch case

[jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15110498#comment-15110498 ] ramkrishna.s.vasudevan commented on FLINK-3135: --- Ping for reviews!! > Add chainable driver

[jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15110525#comment-15110525 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Is there any one working on this? If not

[jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15111005#comment-15111005 ] ramkrishna.s.vasudevan commented on FLINK-3135: --- Ping [~fhueske] and [~chengxiang li]. >

[jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113602#comment-15113602 ] ramkrishna.s.vasudevan commented on FLINK-3135: --- [~rmetzger] Thank you for writing. Let me

[jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113603#comment-15113603 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- [~fhueske] Thanks for the update. > Add

[jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy

[ https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115498#comment-15115498 ] ramkrishna.s.vasudevan commented on FLINK-3135: --- [~fhueske] Thanks for the review and your

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148072#comment-15148072 ] ramkrishna.s.vasudevan commented on FLINK-3179: --- I have updated the PR [~fhueske]. Things

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15202565#comment-15202565 ] ramkrishna.s.vasudevan commented on FLINK-3179: --- bq.Sorry again @ramkrish86 that I lead you

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15190715#comment-15190715 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- When we have f0 (VARCHAR) and f1(INTEGER),

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15190553#comment-15190553 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Went thro the code. Seems the RelBuilder in

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15192836#comment-15192836 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Any thoughts here [~twalthr]. > Improve

[jira] [Comment Edited] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193215#comment-15193215 ] ramkrishna.s.vasudevan edited comment on FLINK-3579 at 3/14/16 12:48 PM:

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193215#comment-15193215 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- I created a pull request with a necessary

[jira] [Assigned] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3579: - Assignee: ramkrishna.s.vasudevan > Improve String concatenation >

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195309#comment-15195309 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- There is one thing wrong in my last pull

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195331#comment-15195331 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Created an updated pull. But am still

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15186929#comment-15186929 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~twalthr] Once I analyse this then I will

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197227#comment-15197227 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~twalthr] Just a ping, in case you have

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15198735#comment-15198735 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Okie. This time I can see the JIRA getting

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15191247#comment-15191247 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Ping [~twalthr]. > Improve String

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234427#comment-15234427 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- Ping for reviews

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234428#comment-15234428 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~till.rohrmann], [~till.rohrmann] - You

[jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations

[ https://issues.apache.org/jira/browse/FLINK-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227709#comment-15227709 ] ramkrishna.s.vasudevan commented on FLINK-3086: --- This also includes abs() operator when used

[jira] [Commented] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

[ https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1528#comment-1528 ] ramkrishna.s.vasudevan commented on FLINK-3631: --- Can I take this JIRA [~fhueske]? >

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203687#comment-15203687 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~twalthr] - This PR got closed not sure

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201316#comment-15201316 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~twalthr]? > Improve String concatenation

[jira] [Assigned] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

[ https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3631: - Assignee: ramkrishna.s.vasudevan > CodeGenerator does not check type

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206145#comment-15206145 ] ramkrishna.s.vasudevan commented on FLINK-3179: --- So good to close this JIRA then? >

[jira] [Commented] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

[ https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206144#comment-15206144 ] ramkrishna.s.vasudevan commented on FLINK-3631: --- So can we close this JIRA? Thanks for the

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199424#comment-15199424 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Ping [~twalthr] > Improve String

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15185140#comment-15185140 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- Is it possible for me to work on this JIRA,

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182594#comment-15182594 ] ramkrishna.s.vasudevan commented on FLINK-3179: --- [~fhueske], [~fhue...@gmail.com] I have

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15213732#comment-15213732 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- Can I work on this later next this week or

[jira] [Assigned] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3650: - Assignee: ramkrishna.s.vasudevan > Add maxBy/minBy to Scala DataSet API

[jira] [Commented] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

[ https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201221#comment-15201221 ] ramkrishna.s.vasudevan commented on FLINK-3631: --- Thank you [~fhueske]. I was able to spot

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263517#comment-15263517 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Can I take this issue now? Will come with a

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296733#comment-15296733 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- [~till.rohrmann] - Any comments on the

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397018#comment-15397018 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- [~aljoscha] Any feed back/suggestions here?

[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=15397634#comment-15397634 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Can I work on this? I saw the code - if

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391103#comment-15391103 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] bq.I fear though that these changes

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15389062#comment-15389062 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] A gentle ping !!! :) > Failed

[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

[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=15399085#comment-15399085 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- [~mxm] Thanks for the comment. My comment

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15400422#comment-15400422 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- Thanks for the comments/feedback. I could

[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=15403843#comment-15403843 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Ok. bq.If we use pooling, I think we should

[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=15404384#comment-15404384 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- I can do this Log update and document

[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=15404378#comment-15404378 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- bq. We cannot really manually release the

[jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

[ https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418752#comment-15418752 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- I can take this up and come up with a patch

[jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

[ https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418777#comment-15418777 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- When I commented there I saw it as

[jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

[ https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419861#comment-15419861 ] ramkrishna.s.vasudevan commented on FLINK-4388: --- [~StephanEwen] I think it happened because

[jira] [Assigned] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3397: - Assignee: ramkrishna.s.vasudevan > Failed streaming jobs should fall

[jira] [Assigned] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3674: - Assignee: ramkrishna.s.vasudevan > Add an interface for EventTime aware

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380873#comment-15380873 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- Thanks for the valuable feedback. >>This is

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15381706#comment-15381706 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Thanks for your comments. Any

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15379266#comment-15379266 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Just a gentle reminder, in case you

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353430#comment-15353430 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- So in all the Stream UDF implementations if

[jira] [Updated] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan updated FLINK-3397: -- Attachment: FLINK-3397.pdf Just adding a doc to highlight how things work now.

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15363810#comment-15363810 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] As per the suggestion I have already

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367226#comment-15367226 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Any feedback here on the doc? >

[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=15409350#comment-15409350 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Updated the PR. Pls check. [~StephanEwen]

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409799#comment-15409799 ] ramkrishna.s.vasudevan commented on FLINK-4322: --- bq.jobs should be able to resume from

[jira] [Assigned] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-4253: - Assignee: ramkrishna.s.vasudevan > Rename "recovery.mode" config key to

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409453#comment-15409453 ] ramkrishna.s.vasudevan commented on FLINK-4253: --- I can take this up. > Rename

[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=15408274#comment-15408274 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- I created the log related msg and the doc.

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410662#comment-15410662 ] ramkrishna.s.vasudevan commented on FLINK-4322: --- Ok, got it. I understand. Thanks. > Unify

[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=15403533#comment-15403533 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- bq.So, another option to fix this would be

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356513#comment-15356513 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- [~aljoscha] Thanks for the feedback. Let me

[jira] [Commented] (FLINK-4130) CallGenerator could generate illegal code when taking no operands

[ https://issues.apache.org/jira/browse/FLINK-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356535#comment-15356535 ] ramkrishna.s.vasudevan commented on FLINK-4130: --- I can take this up if the fix is not super

[jira] [Commented] (FLINK-4130) CallGenerator could generate illegal code when taking no operands

[ https://issues.apache.org/jira/browse/FLINK-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356540#comment-15356540 ] ramkrishna.s.vasudevan commented on FLINK-4130: --- Oh I see. No problem. > CallGenerator

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15360501#comment-15360501 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- [~aljoscha] I read thro the code in

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355534#comment-15355534 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] Any feedback here. Is this going to

[jira] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847206#comment-15847206 ] ramkrishna.s.vasudevan commented on FLINK-4810: --- bq.numUnsuccessfulCheckpointsTriggers

[jira] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

Title: Message Title ramkrishna.s.vasudevan commented on FLINK-4810

[jira] (FLINK-4461) Ensure all the classes are tagged with suitable annotations

Title: Message Title ramkrishna.s.vasudevan commented on FLINK-4461

[jira] (FLINK-4808) Allow skipping failed checkpoints

Title: Message Title ramkrishna.s.vasudevan commented on FLINK-4808

[jira] [Commented] (FLINK-5698) Add NestedFieldsProjectableTableSource interface

[ https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859353#comment-15859353 ] ramkrishna.s.vasudevan commented on FLINK-5698: --- Thanks for the PR. I think I get the idea

[jira] [Created] (FLINK-5752) Support push down projections for HBaseTableSource

ramkrishna.s.vasudevan created FLINK-5752: - Summary: Support push down projections for HBaseTableSource Key: FLINK-5752 URL: https://issues.apache.org/jira/browse/FLINK-5752 Project: Flink

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859357#comment-15859357 ] ramkrishna.s.vasudevan commented on FLINK-5752: --- Since FLINK-5698 is in progress I thnk my

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863265#comment-15863265 ] ramkrishna.s.vasudevan commented on FLINK-5752: --- Yes. I know that. the only thing I wanted

[jira] [Commented] (FLINK-5554) Add sql operator to table api for getting columns from HBase

[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829453#comment-15829453 ] ramkrishna.s.vasudevan commented on FLINK-5554: --- Thanks for starting this thread via JIRA

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823811#comment-15823811 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Few questions on the package structure

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15825551#comment-15825551 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Trying your suggestions bq.Since the code

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824291#comment-15824291 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- bq.However, I think we would need a custom

[jira] [Assigned] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp

[ https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-4417: - Assignee: ramkrishna.s.vasudevan > Checkpoints should be subsumed by

  1   2   >