[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=16451883#comment-16451883 ] Stefano Bortoli commented on FLINK-9252: ok, thanks. I will pull the patch.  >

[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

[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=16109275#comment-16109275 ] Stefano Bortoli commented on FLINK-7339: {code} java.lang.RuntimeException: Error while applying

[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

[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

[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

[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=15976889#comment-15976889 ] Stefano Bortoli commented on FLINK-6335: Right. So I guess you will be working on group windows

[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=15976817#comment-15976817 ] Stefano Bortoli commented on FLINK-6335: Indeed, we have a list of open issues. Please have a look

[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=15972574#comment-15972574 ] Stefano Bortoli edited comment on FLINK-6250 at 4/18/17 2:22 PM: - Hi

[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=15972574#comment-15972574 ] Stefano Bortoli commented on FLINK-6250: Hi [~fhueske], we are working with Calcite to bring in

[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=15972387#comment-15972387 ] Stefano Bortoli commented on FLINK-6250: [~fhueske], I just saw that you just merged FLINK-6240...

[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=15967477#comment-15967477 ] Stefano Bortoli commented on FLINK-6250: Ok, as a workaround for the missing distinct aggregation,

[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=15964250#comment-15964250 ] Stefano Bortoli commented on FLINK-6250: According to the JIRA issue open to Calcite, there is no

[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=15955200#comment-15955200 ] Stefano Bortoli commented on FLINK-6250: I am also fine implementing it extending the existing

[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=15955041#comment-15955041 ] Stefano Bortoli commented on FLINK-6250: I will approach this implementing a processing function

[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=15901391#comment-15901391 ] Stefano Bortoli commented on FLINK-5653: What is the plan for this issue? > Add processing time

[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=15855942#comment-15855942 ] Stefano Bortoli commented on FLINK-5710: Just to track this, what you had in mind is something

[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=15853698#comment-15853698 ] Stefano Bortoli commented on FLINK-5710: Sure. I could trigger the first PR today with what I

[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:

[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

[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=15842513#comment-15842513 ] Stefano Bortoli commented on FLINK-5653: Hi Fabian, I will start working on this issue in the next

[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

[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=15839701#comment-15839701 ] Stefano Bortoli commented on FLINK-5653: I would like to take this issue, please assign it to me.

[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:

[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=15306788#comment-15306788 ] Stefano Bortoli commented on FLINK-1827: The problem is not for the tests that depend on

[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=15290779#comment-15290779 ] Stefano Bortoli commented on FLINK-1827: Moving the classes from test to main does not allow to

[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=15288922#comment-15288922 ] Stefano Bortoli commented on FLINK-1827: During the PR review, Till suggested to move the

[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=15284315#comment-15284315 ] Stefano Bortoli commented on FLINK-1827: Hi Josh, first of all, sorry for the troubles caused!

[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=14958485#comment-14958485 ] Stefano Bortoli edited comment on FLINK-2763 at 10/15/15 8:17 AM: -- Kryo

[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=14958485#comment-14958485 ] Stefano Bortoli commented on FLINK-2763: Kryo serialization/deserialization is not threadsafe. In

[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=14958485#comment-14958485 ] Stefano Bortoli edited comment on FLINK-2763 at 10/15/15 8:00 AM: -- Kryo

[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=14958995#comment-14958995 ] Stefano Bortoli edited comment on FLINK-2800 at 10/15/15 3:42 PM: -- Hi

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

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

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

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

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

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

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

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

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

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

[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=14944959#comment-14944959 ] Stefano Bortoli edited comment on FLINK-2800 at 10/6/15 12:38 PM: -- I

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

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

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

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

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

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

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

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

[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

[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-tabpanelfocusedCommentId=14640007#comment-14640007 ] Stefano Bortoli commented on FLINK-2394: I see. I was in fact a little

[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