[jira] [Commented] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-9252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16451883#comment-16451883 ] Stefano Bortoli commented on FLINK-9252: ok, thanks. I will pull the patch.  > Op

[jira] [Created] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException

Stefano Bortoli created FLINK-9252: -- Summary: OperatorChain.pushToOperators NullPointerException when ClassCastException Key: FLINK-9252 URL: https://issues.apache.org/jira/browse/FLINK-9252 Project:

[jira] [Created] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

Stefano Bortoli created FLINK-7371: -- Summary: user defined aggregator assumes nr of arguments smaller or equal than number of row fields Key: FLINK-7371 URL: https://issues.apache.org/jira/browse/FLINK-7371

[jira] [Commented] (FLINK-7339) aggregationToString fails when user defined aggregation contains constants

[ https://issues.apache.org/jira/browse/FLINK-7339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109275#comment-16109275 ] Stefano Bortoli commented on FLINK-7339: {code} java.lang.RuntimeException: Error

[jira] [Created] (FLINK-7339) aggregationToString fails when user defined aggregation contains constants

Stefano Bortoli created FLINK-7339: -- Summary: aggregationToString fails when user defined aggregation contains constants Key: FLINK-7339 URL: https://issues.apache.org/jira/browse/FLINK-7339 Project:

[jira] [Created] (FLINK-7338) User Defined aggregation with constants causes error under in lowerbound over window extraction

Stefano Bortoli created FLINK-7338: -- Summary: User Defined aggregation with constants causes error under in lowerbound over window extraction Key: FLINK-7338 URL: https://issues.apache.org/jira/browse/FLINK-7338

[jira] [Updated] (FLINK-7338) User Defined aggregation with constants causes error under in lowerbound over window extraction

[ https://issues.apache.org/jira/browse/FLINK-7338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Bortoli updated FLINK-7338: --- Description: A user defined aggregation that passes a constant among the arguments causes a R

[jira] [Created] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

Stefano Bortoli created FLINK-6388: -- Summary: Add support for DISTINCT into Code Generated Aggregations Key: FLINK-6388 URL: https://issues.apache.org/jira/browse/FLINK-6388 Project: Flink I

[jira] [Commented] (FLINK-6335) Support DISTINCT over grouped window in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976889#comment-15976889 ] Stefano Bortoli commented on FLINK-6335: Right. So I guess you will be working on

[jira] [Commented] (FLINK-6335) Support DISTINCT over grouped window in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976817#comment-15976817 ] Stefano Bortoli commented on FLINK-6335: Indeed, we have a list of open issues. Pl

[jira] [Comment Edited] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972574#comment-15972574 ] Stefano Bortoli edited comment on FLINK-6250 at 4/18/17 2:22 PM: ---

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972574#comment-15972574 ] Stefano Bortoli commented on FLINK-6250: Hi [~fhueske], we are working with Calc

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972387#comment-15972387 ] Stefano Bortoli commented on FLINK-6250: [~fhueske], I just saw that you just merg

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967477#comment-15967477 ] Stefano Bortoli commented on FLINK-6250: Ok, as a workaround for the missing disti

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964250#comment-15964250 ] Stefano Bortoli commented on FLINK-6250: According to the JIRA issue open to Calci

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955200#comment-15955200 ] Stefano Bortoli commented on FLINK-6250: I am also fine implementing it extending

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955041#comment-15955041 ] Stefano Bortoli commented on FLINK-6250: I will approach this implementing a proce

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15901391#comment-15901391 ] Stefano Bortoli commented on FLINK-5653: What is the plan for this issue? > Add

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855942#comment-15855942 ] Stefano Bortoli commented on FLINK-5710: Just to track this, what you had in mind

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853698#comment-15853698 ] Stefano Bortoli commented on FLINK-5710: Sure. I could trigger the first PR today

[jira] [Created] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

Stefano Bortoli created FLINK-5710: -- Summary: Add ProcTime() function to indicate StreamSQL Key: FLINK-5710 URL: https://issues.apache.org/jira/browse/FLINK-5710 Project: Flink Issue Type: N

[jira] [Assigned] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Bortoli reassigned FLINK-5653: -- Assignee: Stefano Bortoli > Add processing time OVER ROWS BETWEEN x PRECEDING aggregati

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15842513#comment-15842513 ] Stefano Bortoli commented on FLINK-5653: Hi Fabian, I will start working on this i

[jira] [Issue Comment Deleted] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Bortoli updated FLINK-5653: --- Comment: was deleted (was: I would like to take this issue, please assign it to me.) > Add pr

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839701#comment-15839701 ] Stefano Bortoli commented on FLINK-5653: I would like to take this issue, please a

[jira] [Created] (FLINK-4909) JDBC Input format cast exception management

Stefano Bortoli created FLINK-4909: -- Summary: JDBC Input format cast exception management Key: FLINK-4909 URL: https://issues.apache.org/jira/browse/FLINK-4909 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306788#comment-15306788 ] Stefano Bortoli commented on FLINK-1827: The problem is not for the tests that dep

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15290779#comment-15290779 ] Stefano Bortoli commented on FLINK-1827: Moving the classes from test to main does

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288922#comment-15288922 ] Stefano Bortoli commented on FLINK-1827: During the PR review, Till suggested to m

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15284315#comment-15284315 ] Stefano Bortoli commented on FLINK-1827: Hi Josh, first of all, sorry for the tro

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14959143#comment-14959143 ] Stefano Bortoli commented on FLINK-2800: Ok, I have run a couple of tests more, an

[jira] [Comment Edited] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14958995#comment-14958995 ] Stefano Bortoli edited comment on FLINK-2800 at 10/15/15 3:42 PM: --

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14958995#comment-14958995 ] Stefano Bortoli commented on FLINK-2800: Hi guys. I have played around the KryoSer

[jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14958485#comment-14958485 ] Stefano Bortoli edited comment on FLINK-2763 at 10/15/15 8:17 AM: --

[jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14958485#comment-14958485 ] Stefano Bortoli commented on FLINK-2763: Kryo serialization/deserialization is not

[jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14958485#comment-14958485 ] Stefano Bortoli edited comment on FLINK-2763 at 10/15/15 8:00 AM: --

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945146#comment-14945146 ] Stefano Bortoli commented on FLINK-2800: Ok, I have some hints. Executing the cros

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945094#comment-14945094 ] Stefano Bortoli commented on FLINK-2800: Within the combine function I use anyway

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945078#comment-14945078 ] Stefano Bortoli commented on FLINK-2800: Nope, it comes when I use the BSONObject

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945008#comment-14945008 ] Stefano Bortoli commented on FLINK-2800: I have added a couple of them, but it did

[jira] [Comment Edited] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14944959#comment-14944959 ] Stefano Bortoli edited comment on FLINK-2800 at 10/6/15 12:38 PM: --

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14944959#comment-14944959 ] Stefano Bortoli commented on FLINK-2800: I don't think the functions are relevant.

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14944646#comment-14944646 ] Stefano Bortoli commented on FLINK-2800: I had the problem using both my POJO and

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14940984#comment-14940984 ] Stefano Bortoli commented on FLINK-2800: I don't know whether it is the same issue

[jira] [Created] (FLINK-2800) kryo serialization problem

Stefano Bortoli created FLINK-2800: -- Summary: kryo serialization problem Key: FLINK-2800 URL: https://issues.apache.org/jira/browse/FLINK-2800 Project: Flink Issue Type: Bug Compon

[jira] [Commented] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter

[ https://issues.apache.org/jira/browse/FLINK-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14640007#comment-14640007 ] Stefano Bortoli commented on FLINK-2394: I see. I was in fact a little disappointe

[jira] [Created] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter

Stefano Bortoli created FLINK-2394: -- Summary: HadoopOutFormat OutputCommitter is default to FileOutputCommiter Key: FLINK-2394 URL: https://issues.apache.org/jira/browse/FLINK-2394 Project: Flink