[jira] [Commented] (FLINK-1663) Add a FIFO job scheduler to the JobManager

2015-03-20 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371379#comment-14371379 ] Flavio Pompermaier commented on FLINK-1663: --- Do you think that an integration

[jira] [Commented] (FLINK-1663) Add a FIFO job scheduler to the JobManager

2015-03-09 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353246#comment-14353246 ] Flavio Pompermaier commented on FLINK-1663: --- Definitely useful! +1 Add a FIFO

[jira] [Commented] (FLINK-1828) Impossible to output data to an HBase table

2015-04-21 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14504799#comment-14504799 ] Flavio Pompermaier commented on FLINK-1828: --- Take into account that that

[jira] [Created] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-1978: - Summary: POJO serialization NPE Key: FLINK-1978 URL: https://issues.apache.org/jira/browse/FLINK-1978 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-1978: -- Description: NullPointer on serialization of a Date field: Caused by:

[jira] [Comment Edited] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530197#comment-14530197 ] Flavio Pompermaier edited comment on FLINK-1978 at 5/6/15 9:10 AM:

[jira] [Commented] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530197#comment-14530197 ] Flavio Pompermaier commented on FLINK-1978: --- The error can be reproduced with

[jira] [Created] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-1834: - Summary: Is mapred.output.dir conf parameter really required? Key: FLINK-1834 URL: https://issues.apache.org/jira/browse/FLINK-1834 Project: Flink

[jira] [Created] (FLINK-1828) Impossible to output data to an HBase table

2015-04-04 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-1828: - Summary: Impossible to output data to an HBase table Key: FLINK-1828 URL: https://issues.apache.org/jira/browse/FLINK-1828 Project: Flink Issue

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

2015-04-04 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-1827: - Summary: Move test classes in test folders and fix scope of test dependencies Key: FLINK-1827 URL: https://issues.apache.org/jira/browse/FLINK-1827

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

2015-04-08 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485261#comment-14485261 ] Flavio Pompermaier commented on FLINK-1827: --- I know that the problem is in

[jira] [Commented] (FLINK-2217) Web client does not remove uploaded JARs

2015-06-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588645#comment-14588645 ] Flavio Pompermaier commented on FLINK-2217: --- To me the fact that jars remain

[jira] [Commented] (FLINK-2217) Web client does not remove uploaded JARs

2015-06-17 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589397#comment-14589397 ] Flavio Pompermaier commented on FLINK-2217: --- The upload date (and also size or

[jira] [Created] (FLINK-2503) Inconsistencies in FileInputFormat hierarchy

2015-08-10 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-2503: - Summary: Inconsistencies in FileInputFormat hierarchy Key: FLINK-2503 URL: https://issues.apache.org/jira/browse/FLINK-2503 Project: Flink Issue

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

2015-10-26 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14975242#comment-14975242 ] Flavio Pompermaier commented on FLINK-1827: --- A lot of improvements regarding Flink tests are

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

2015-11-04 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989658#comment-14989658 ] Flavio Pompermaier commented on FLINK-2763: --- That fixed also my problem. Thanks Till > Bug in

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

2015-10-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14957172#comment-14957172 ] Flavio Pompermaier commented on FLINK-2763: --- Ok, just let me know if you need to test the patch

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

2015-10-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14963202#comment-14963202 ] Flavio Pompermaier commented on FLINK-2763: --- Actually the program was able to finish but there

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

2015-10-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-2763: -- Comment: was deleted (was: Actually the program was able to finish but there are

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

2015-10-15 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14958474#comment-14958474 ] Flavio Pompermaier commented on FLINK-2763: --- I think that this bug could be related to

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

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14960455#comment-14960455 ] Flavio Pompermaier edited comment on FLINK-2763 at 10/16/15 10:20 AM: --

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

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14960455#comment-14960455 ] Flavio Pompermaier commented on FLINK-2763: --- I don't know whether Stephano's patch made some

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

2015-10-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14960455#comment-14960455 ] Flavio Pompermaier edited comment on FLINK-2763 at 10/16/15 12:34 PM: --

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

2015-10-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier reopened FLINK-2763: --- Still the same error using the current master (0.10-SNAPSHOT): Caused by:

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-06-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316320#comment-15316320 ] Flavio Pompermaier commented on FLINK-3777: --- Hi Stephan, we decided to introduce the

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-06-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316318#comment-15316318 ] Flavio Pompermaier commented on FLINK-3777: --- Hi Stephan, we decided to introduce the

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-06-07 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15318374#comment-15318374 ] Flavio Pompermaier commented on FLINK-3777: --- In our use case we have this very complex query

[jira] [Commented] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

2016-06-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327105#comment-15327105 ] Flavio Pompermaier commented on FLINK-4061: --- Are you sure that you have only that exception? A

[jira] [Commented] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

2016-06-14 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329014#comment-15329014 ] Flavio Pompermaier commented on FLINK-4061: --- If you use flink 1.1-SNAPSHOT and you put the

[jira] [Created] (FLINK-4081) FieldParsers should support empty strings

2016-06-16 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-4081: - Summary: FieldParsers should support empty strings Key: FLINK-4081 URL: https://issues.apache.org/jira/browse/FLINK-4081 Project: Flink Issue

[jira] [Commented] (FLINK-4088) Add interface to save and load TableSources

2016-06-17 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15336349#comment-15336349 ] Flavio Pompermaier commented on FLINK-4088: --- Do you think you could add a Datasource-catalog to

[jira] [Created] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation

2016-02-05 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3348: - Summary: taskmanager.memory.off-heap missing bc documentation Key: FLINK-3348 URL: https://issues.apache.org/jira/browse/FLINK-3348 Project: Flink

[jira] [Created] (FLINK-3750) Make JDBCInputFormat a parallel source

2016-04-13 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3750: - Summary: Make JDBCInputFormat a parallel source Key: FLINK-3750 URL: https://issues.apache.org/jira/browse/FLINK-3750 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-3908) FieldParsers error state is not reset correctly to NONE

2016-05-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier reassigned FLINK-3908: - Assignee: Flavio Pompermaier > FieldParsers error state is not reset correctly

[jira] [Commented] (FLINK-3908) FieldParsers error state is not reset correctly to NONE

2016-05-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15290821#comment-15290821 ] Flavio Pompermaier commented on FLINK-3908: --- In order to make FLINK-3908 work properly this

[jira] [Issue Comment Deleted] (FLINK-3908) FieldParsers error state is not reset correctly to NONE

2016-05-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-3908: -- Comment: was deleted (was: In order to make FLINK-3908 work properly this issue should

[jira] [Commented] (FLINK-3908) FieldParsers error state is not reset correctly to NONE

2016-05-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15290824#comment-15290824 ] Flavio Pompermaier commented on FLINK-3908: --- In order to make FLINK-3901 work properly this

[jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor

2016-05-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15291351#comment-15291351 ] Flavio Pompermaier commented on FLINK-3922: --- I think that if you can run the code I attached

[jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor

2016-05-20 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294193#comment-15294193 ] Flavio Pompermaier commented on FLINK-3922: --- I confirm that this patch fixed my test! However

[jira] [Created] (FLINK-3900) Set nullCheck=true as default in TableConfig

2016-05-12 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3900: - Summary: Set nullCheck=true as default in TableConfig Key: FLINK-3900 URL: https://issues.apache.org/jira/browse/FLINK-3900 Project: Flink Issue

[jira] [Created] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API

2016-05-12 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3901: - Summary: Create a RowCsvInputFormat to use as default CSV IF in Table API Key: FLINK-3901 URL: https://issues.apache.org/jira/browse/FLINK-3901 Project:

[jira] [Assigned] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API

2016-05-12 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier reassigned FLINK-3901: - Assignee: Flavio Pompermaier > Create a RowCsvInputFormat to use as default CSV

[jira] [Created] (FLINK-3917) Remove mouse focus from plan visualizer

2016-05-17 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3917: - Summary: Remove mouse focus from plan visualizer Key: FLINK-3917 URL: https://issues.apache.org/jira/browse/FLINK-3917 Project: Flink Issue Type:

[jira] [Created] (FLINK-3908) FieldParsers error state is not reset correctly to NONE

2016-05-13 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3908: - Summary: FieldParsers error state is not reset correctly to NONE Key: FLINK-3908 URL: https://issues.apache.org/jira/browse/FLINK-3908 Project: Flink

[jira] [Updated] (FLINK-3908) FieldParsers error state is not reset correctly to NONE

2016-05-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-3908: -- Priority: Major (was: Blocker) > FieldParsers error state is not reset correctly to

[jira] [Updated] (FLINK-3922) Infinite recursion on TypeExtractor

2016-05-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-3922: -- Description: This program cause a StackOverflow (infinite recursion) in the

[jira] [Updated] (FLINK-3922) Infinite recursion on TypeExtractor

2016-05-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-3922: -- Description: This program cause a StackOverflow (infinite recursion) in the

[jira] [Created] (FLINK-3922) Infinite recursion on TypeExtractor

2016-05-18 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3922: - Summary: Infinite recursion on TypeExtractor Key: FLINK-3922 URL: https://issues.apache.org/jira/browse/FLINK-3922 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-3777: -- Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-3750) > Add

[jira] [Created] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-18 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-3777: - Summary: Add open and close methods to manage IF lifecycle Key: FLINK-3777 URL: https://issues.apache.org/jira/browse/FLINK-3777 Project: Flink

[jira] [Comment Edited] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245430#comment-15245430 ] Flavio Pompermaier edited comment on FLINK-3777 at 4/18/16 10:24 AM: -

[jira] [Comment Edited] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245430#comment-15245430 ] Flavio Pompermaier edited comment on FLINK-3777 at 4/18/16 10:24 AM: -

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245430#comment-15245430 ] Flavio Pompermaier commented on FLINK-3777: --- Ok. I could issue a PR for this if you don't mind.

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247406#comment-15247406 ] Flavio Pompermaier commented on FLINK-3777: --- I issued a PR yesterday

[jira] [Comment Edited] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247406#comment-15247406 ] Flavio Pompermaier edited comment on FLINK-3777 at 4/19/16 10:19 AM: -

[jira] [Assigned] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-18 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier reassigned FLINK-3777: - Assignee: Flavio Pompermaier > Add open and close methods to manage IF lifecycle

[jira] [Commented] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API

2016-07-11 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370532#comment-15370532 ] Flavio Pompermaier commented on FLINK-3901: --- +1 for me!Thanks a lot to taking care of this

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2017-02-01 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848105#comment-15848105 ] Flavio Pompermaier commented on FLINK-5353: --- My previous PR was

[jira] [Updated] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-5907: -- Description: The following snippet reproduce the problem (using the attached file as

[jira] [Updated] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-5907: -- Description: The following snippet reproduce the problem (using the attacched file as

[jira] [Updated] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-5907: -- Attachment: test.tsv Test file > RowCsvInputFormat bug on parsing tsv >

[jira] [Created] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-5907: - Summary: RowCsvInputFormat bug on parsing tsv Key: FLINK-5907 URL: https://issues.apache.org/jira/browse/FLINK-5907 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4491) Handle index.number_of_shards in the ES connector

2016-08-25 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-4491: - Summary: Handle index.number_of_shards in the ES connector Key: FLINK-4491 URL: https://issues.apache.org/jira/browse/FLINK-4491 Project: Flink

[jira] [Commented] (FLINK-4628) User class loader unavailable during input split assignment

2016-09-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495945#comment-15495945 ] Flavio Pompermaier commented on FLINK-4628: --- Could this be also the cause of

[jira] [Commented] (FLINK-4719) KryoSerializer random exception

2016-09-30 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535535#comment-15535535 ] Flavio Pompermaier commented on FLINK-4719: --- Using the Flink 1.1.1 code my job fails frequently,

[jira] [Created] (FLINK-4719) KryoSerializer random exception

2016-09-30 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-4719: - Summary: KryoSerializer random exception Key: FLINK-4719 URL: https://issues.apache.org/jira/browse/FLINK-4719 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector

2016-10-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15597497#comment-15597497 ] Flavio Pompermaier commented on FLINK-4491: --- You're probably right Mike. Is it something that I

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-11-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686075#comment-15686075 ] Flavio Pompermaier commented on FLINK-5122: --- Can you try and see if our pull request fix your

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-11-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686354#comment-15686354 ] Flavio Pompermaier commented on FLINK-5122: --- Actually the current ES sink implementation check

[jira] [Created] (FLINK-4785) Flink string parser doesn't handle string fields containing double quotes

2016-10-10 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-4785: - Summary: Flink string parser doesn't handle string fields containing double quotes Key: FLINK-4785 URL: https://issues.apache.org/jira/browse/FLINK-4785

[jira] [Created] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2016-12-16 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-5353: - Summary: Elasticsearch Sink loses well-formed documents when there are malformed documents Key: FLINK-5353 URL: https://issues.apache.org/jira/browse/FLINK-5353

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2016-12-16 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15754350#comment-15754350 ] Flavio Pompermaier commented on FLINK-5353: --- The ES connector should be made tolerant to

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-12-01 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712488#comment-15712488 ] Flavio Pompermaier commented on FLINK-5122: --- Hi @static-max, we've closed our PR to add the

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2016-12-19 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15761472#comment-15761472 ] Flavio Pompermaier commented on FLINK-5353: --- I just remember that in the afterBulk the error was

[jira] [Commented] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-23 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15937924#comment-15937924 ] Flavio Pompermaier commented on FLINK-6103: --- Here's the PR link:

[jira] [Assigned] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-23 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier reassigned FLINK-6103: - Assignee: Flavio Pompermaier > LocalFileSystem rename() uses File.renameTo() >

[jira] [Commented] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15936845#comment-15936845 ] Flavio Pompermaier commented on FLINK-6103: --- Maybe also BlobServerConnection could benefit from

[jira] [Commented] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-17 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930143#comment-15930143 ] Flavio Pompermaier commented on FLINK-6103: --- I've tried {{com.google.common.io.Files.move()}}

[jira] [Created] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-17 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-6103: - Summary: LocalFileSystem rename() uses File.renameTo() Key: FLINK-6103 URL: https://issues.apache.org/jira/browse/FLINK-6103 Project: Flink Issue

[jira] [Updated] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-17 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-6103: -- Description: I've tried to move a directory to another on the LocalFilesystem and it

[jira] [Updated] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

2017-03-17 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-6103: -- Description: I've tried to move a directory to another on the LocalFilesystem and it

[jira] [Updated] (FLINK-6271) NumericBetweenParametersProvider NullPointer

2017-04-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-6271: -- Summary: NumericBetweenParametersProvider NullPointer (was:

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

2017-03-10 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904899#comment-15904899 ] Flavio Pompermaier commented on FLINK-6022: --- HI [~rmetzger], does this apply also to Thrift and

[jira] [Created] (FLINK-5988) Show start-cluster.sh failures

2017-03-07 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-5988: - Summary: Show start-cluster.sh failures Key: FLINK-5988 URL: https://issues.apache.org/jira/browse/FLINK-5988 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6271) NumericBetweenParametersProvider NullPinter

2017-04-06 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-6271: - Summary: NumericBetweenParametersProvider NullPinter Key: FLINK-6271 URL: https://issues.apache.org/jira/browse/FLINK-6271 Project: Flink Issue

[jira] [Created] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-10-16 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-7845: - Summary: Netty Exception when submitting batch job repeatedly Key: FLINK-7845 URL: https://issues.apache.org/jira/browse/FLINK-7845 Project: Flink

[jira] [Updated] (FLINK-7605) JDBCOutputFormat autoCommit

2017-09-08 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-7605: -- Description: Currently, if a connection is not created with autoCommit = true by

[jira] [Updated] (FLINK-7605) JDBCOutputFormat autoCommit

2017-09-08 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-7605: -- Description: Currently, if a connection is not created with autoCommit = true by

[jira] [Updated] (FLINK-7605) JDBCOutputFormat autoCommit

2017-09-08 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-7605: -- Description: Currently, if a connection is not created with autoCommit = true by

[jira] [Created] (FLINK-7605) JDBCOutputFormat autoCommit

2017-09-08 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-7605: - Summary: JDBCOutputFormat autoCommit Key: FLINK-7605 URL: https://issues.apache.org/jira/browse/FLINK-7605 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249256#comment-16249256 ] Flavio Pompermaier commented on FLINK-7845: --- Done.

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249366#comment-16249366 ] Flavio Pompermaier commented on FLINK-7845: --- Updated scala to 2.11. Maybe it could be a good

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-11 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248737#comment-16248737 ] Flavio Pompermaier commented on FLINK-7845: --- Same error also using flink 1.4-SNAPSHOT:

[jira] [Comment Edited] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-11 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248737#comment-16248737 ] Flavio Pompermaier edited comment on FLINK-7845 at 11/12/17 12:05 AM: --

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249545#comment-16249545 ] Flavio Pompermaier commented on FLINK-7845: --- [~pnowojski] now I've pushed a version of the job

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249653#comment-16249653 ] Flavio Pompermaier commented on FLINK-7845: --- Also looking at the Flink code it seems that only

[jira] [Closed] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-7845. - Resolution: Not A Problem The problem was in the test program > Netty Exception when

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249571#comment-16249571 ] Flavio Pompermaier commented on FLINK-7845: --- The job always fails with the same error (Caused

[jira] [Comment Edited] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249571#comment-16249571 ] Flavio Pompermaier edited comment on FLINK-7845 at 11/13/17 1:53 PM: -

[jira] [Created] (FLINK-7930) Support periodic jobs with state that gets restored and persisted in a savepoint

2017-10-26 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-7930: - Summary: Support periodic jobs with state that gets restored and persisted in a savepoint Key: FLINK-7930 URL: https://issues.apache.org/jira/browse/FLINK-7930

  1   2   3   >