[jira] [Commented] (FLINK-32896) Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity

2023-08-19 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756420#comment-17756420 ] Flavio Pompermaier commented on FLINK-32896: Good catch > Incorrect

[jira] [Commented] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code

2022-02-28 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498809#comment-17498809 ] Flavio Pompermaier commented on FLINK-25023: Any update on this? > ClassLoader leak on

[jira] [Comment Edited] (FLINK-17826) Add missing custom query support on new jdbc connector

2021-05-07 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340636#comment-17340636 ] Flavio Pompermaier edited comment on FLINK-17826 at 5/7/21, 7:26 AM: -

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2021-05-07 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340636#comment-17340636 ] Flavio Pompermaier commented on FLINK-17826: This feature was added in the old connecto[1]

[jira] [Updated] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

2021-04-30 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-20614: --- Priority: Critical (was: Minor) > Registered sql drivers not deregistered after

[jira] [Updated] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

2021-04-30 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-20614: --- Labels: (was: auto-deprioritized-major) > Registered sql drivers not deregistered

[jira] [Updated] (FLINK-10684) Improve the CSV reading process

2021-04-30 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-10684: --- Labels: CSV (was: auto-deprioritized-major) > Improve the CSV reading process >

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

2021-04-30 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-4785: -- Labels: csv (was: auto-deprioritized-major csv) > Flink string parser doesn't handle

[jira] [Updated] (FLINK-10684) Improve the CSV reading process

2021-04-30 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-10684: --- Priority: Major (was: Minor) > Improve the CSV reading process >

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

2021-04-30 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-4785: -- Priority: Major (was: Minor) > Flink string parser doesn't handle string fields

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2021-04-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333035#comment-17333035 ] Flavio Pompermaier commented on FLINK-17826: Is this PR still valid? Has anyone looked into

[jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector

2021-04-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-17826: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Add

[jira] [Commented] (FLINK-22414) Consider env.hadoop.conf.dir when looking for the hadoop configuration

2021-04-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331869#comment-17331869 ] Flavio Pompermaier commented on FLINK-22414: Hi [~fly_in_gis], I don't actually see any

[jira] [Commented] (FLINK-22414) Consider env.hadoop.conf.dir when looking for the hadoop configuration

2021-04-23 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330864#comment-17330864 ] Flavio Pompermaier commented on FLINK-22414: Yes, my problem as a user is that the

[jira] [Commented] (FLINK-22414) Consider env.hadoop.conf.dir when looking for the hadoop configuration

2021-04-23 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330115#comment-17330115 ] Flavio Pompermaier commented on FLINK-22414: Could it be that config.sh reads properties

[jira] [Updated] (FLINK-11852) Improve Processing function example

2021-04-23 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-11852: --- Labels: pull-request-available (was: pull-request-available stale-assigned) >

[jira] [Updated] (FLINK-22178) Support ignore-first-line option in new csv format

2021-04-19 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-22178: --- Labels: (was: stale-assigned) > Support ignore-first-line option in new csv

[jira] [Updated] (FLINK-10795) STDDEV_POP error

2021-04-16 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-10795: --- Labels: (was: stale-assigned) > STDDEV_POP error > > >

[jira] [Commented] (FLINK-17442) Cannot convert String or boxed-primitive arrays to DataStream using TypeInformation

2021-04-16 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322700#comment-17322700 ] Flavio Pompermaier commented on FLINK-17442: Any progress on this? > Cannot convert String

[jira] [Updated] (FLINK-10947) Document handling of null keys in the data types documentation

2021-04-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-10947: --- Priority: Major (was: Minor) > Document handling of null keys in the data types

[jira] [Commented] (FLINK-10947) Document handling of null keys in the data types documentation

2021-04-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321976#comment-17321976 ] Flavio Pompermaier commented on FLINK-10947: I think this should be fixed so I remove the

[jira] [Updated] (FLINK-10947) Document handling of null keys in the data types documentation

2021-04-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-10947: --- Labels: documentation key type-converter (was: documentation key stale-minor

[jira] [Updated] (FLINK-11852) Improve Processing function example

2021-04-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-11852: --- Labels: pull-request-available (was: pull-request-available stale-minor) > Improve

[jira] [Commented] (FLINK-11852) Improve Processing function example

2021-04-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321973#comment-17321973 ] Flavio Pompermaier commented on FLINK-11852: I think it could be still useful > Improve

[jira] [Commented] (FLINK-21786) sample Job execution failed

2021-03-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301483#comment-17301483 ] Flavio Pompermaier commented on FLINK-21786: Are you sure you have write permission to

[jira] [Commented] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

2020-12-21 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252707#comment-17252707 ] Flavio Pompermaier commented on FLINK-20614: Thank you [~kezhuw] for all your insights. I

[jira] [Commented] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

2020-12-16 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250199#comment-17250199 ] Flavio Pompermaier commented on FLINK-20614: I think that the Flink documentation is not

[jira] [Commented] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

2020-12-16 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250164#comment-17250164 ] Flavio Pompermaier commented on FLINK-20614: Could this problem be related also to a missing

[jira] [Commented] (FLINK-20333) Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

2020-11-25 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238754#comment-17238754 ] Flavio Pompermaier commented on FLINK-20333: Could this problem affect also normal java

[jira] [Created] (FLINK-20004) UpperLimitExceptionParameter description is misleading

2020-11-05 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-20004: -- Summary: UpperLimitExceptionParameter description is misleading Key: FLINK-20004 URL: https://issues.apache.org/jira/browse/FLINK-20004 Project: Flink

[jira] [Created] (FLINK-19969) CliFrontendParser does not provide any help for run-application

2020-11-04 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-19969: -- Summary: CliFrontendParser does not provide any help for run-application Key: FLINK-19969 URL: https://issues.apache.org/jira/browse/FLINK-19969 Project:

[jira] [Commented] (FLINK-9844) PackagedProgram does not close URLClassLoader

2020-10-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220797#comment-17220797 ] Flavio Pompermaier commented on FLINK-9844: --- Is this issue still present or can this issue be

[jira] [Comment Edited] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-08-18 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179401#comment-17179401 ] Flavio Pompermaier edited comment on FLINK-17826 at 8/18/20, 6:41 AM:

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-08-18 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179401#comment-17179401 ] Flavio Pompermaier commented on FLINK-17826: Unfortunately I can't fond the time to

[jira] [Commented] (FLINK-11746) Add thrift format support in Flink

2020-07-16 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159099#comment-17159099 ] Flavio Pompermaier commented on FLINK-11746: Any update on this? > Add thrift format

[jira] [Updated] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-18608: --- Description: The following program shows that nullability is not respected during

[jira] [Created] (FLINK-18608) CustomizedConvertRule#convertCast drops nullability

2020-07-15 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-18608: -- Summary: CustomizedConvertRule#convertCast drops nullability Key: FLINK-18608 URL: https://issues.apache.org/jira/browse/FLINK-18608 Project: Flink

[jira] [Commented] (FLINK-17852) FlinkSQL support WITH clause in query statement

2020-05-20 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112558#comment-17112558 ] Flavio Pompermaier commented on FLINK-17852: Can this be related to FLINK-17361 ? >

[jira] [Commented] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

2020-05-20 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112551#comment-17112551 ] Flavio Pompermaier commented on FLINK-17850: I'll try to look into it. This test was

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-05-20 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111895#comment-17111895 ] Flavio Pompermaier commented on FLINK-17826: Ok, it should not be too complicated. Assign

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-05-20 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111889#comment-17111889 ] Flavio Pompermaier commented on FLINK-17826: I hope to find the time within the end of this

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

2020-05-18 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110576#comment-17110576 ] Flavio Pompermaier commented on FLINK-17762: Now FLINK-17029 is unlocked and FLINK-17356. is

[jira] [Commented] (FLINK-17798) Align the behavior between the new and legacy JDBC table source

2020-05-18 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110097#comment-17110097 ] Flavio Pompermaier commented on FLINK-17798: Is this related to FLINK-17358? > Align the

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

2020-05-17 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109700#comment-17109700 ] Flavio Pompermaier commented on FLINK-17762: For the moment I've rebased the PR for

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

2020-05-16 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109181#comment-17109181 ] Flavio Pompermaier commented on FLINK-17762: Dies this depends on

[jira] [Created] (FLINK-17622) Remove useless switch for decimal in PostresCatalog

2020-05-11 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17622: -- Summary: Remove useless switch for decimal in PostresCatalog Key: FLINK-17622 URL: https://issues.apache.org/jira/browse/FLINK-17622 Project: Flink

[jira] [Commented] (FLINK-14101) Introduce SqlServerDialect

2020-05-05 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100033#comment-17100033 ] Flavio Pompermaier commented on FLINK-14101: Could you assign this to me as well? >

[jira] [Commented] (FLINK-14100) Introduce OracleDialect

2020-05-05 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100030#comment-17100030 ] Flavio Pompermaier commented on FLINK-14100: I used this scripts to test the upsert query

[jira] [Commented] (FLINK-14100) Introduce OracleDialect

2020-05-05 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099857#comment-17099857 ] Flavio Pompermaier commented on FLINK-14100: I was implementing the *getUpsertStatement()*

[jira] [Commented] (FLINK-14100) Introduce OracleDialect

2020-05-05 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099621#comment-17099621 ] Flavio Pompermaier commented on FLINK-14100: I want to implement this..can you assign it to

[jira] [Closed] (FLINK-17509) Support OracleDialect

2020-05-05 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-17509. -- Resolution: Duplicate > Support OracleDialect > - > >

[jira] [Commented] (FLINK-17509) Support OracleDialect

2020-05-05 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099618#comment-17099618 ] Flavio Pompermaier commented on FLINK-17509: Yes..sorry! I didn't notice it..I'll close this

[jira] [Created] (FLINK-17509) Support OracleDialect

2020-05-04 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17509: -- Summary: Support OracleDialect Key: FLINK-17509 URL: https://issues.apache.org/jira/browse/FLINK-17509 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17508) Develop OracleCatalog

2020-05-04 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17508: -- Summary: Develop OracleCatalog Key: FLINK-17508 URL: https://issues.apache.org/jira/browse/FLINK-17508 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-17361) Support creating of a JDBC table using a custom query

2020-05-04 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099106#comment-17099106 ] Flavio Pompermaier commented on FLINK-17361: As I commented in the PR I named the property

[jira] [Commented] (FLINK-17361) Support creating of a JDBC table using a custom query

2020-05-04 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098967#comment-17098967 ] Flavio Pompermaier commented on FLINK-17361: For the moment I can implement it without

[jira] [Commented] (FLINK-17361) Support creating of a JDBC table using a custom query

2020-05-04 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098893#comment-17098893 ] Flavio Pompermaier commented on FLINK-17361: [~jark] or [~Leonard Xu]: is there a way to

[jira] [Comment Edited] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093201#comment-17093201 ] Flavio Pompermaier edited comment on FLINK-17356 at 4/27/20, 8:47 AM:

[jira] [Commented] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093201#comment-17093201 ] Flavio Pompermaier commented on FLINK-17356: I think that it's not bad to have them

[jira] [Commented] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093166#comment-17093166 ] Flavio Pompermaier commented on FLINK-17356: Yes I know tat they are not used right now, but

[jira] [Commented] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093140#comment-17093140 ] Flavio Pompermaier commented on FLINK-17356: For me it's not a problem to revert those

[jira] [Commented] (FLINK-17385) Fix precision problem when converting JDBC numberic into Flink decimal type

2020-04-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092698#comment-17092698 ] Flavio Pompermaier commented on FLINK-17385: Now the 2 PR should be ok > Fix precision

[jira] [Commented] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092595#comment-17092595 ] Flavio Pompermaier commented on FLINK-17356: I took the freedom of changing the enum because

[jira] [Commented] (FLINK-17385) Fix precision problem when converting JDBC numberic into Flink decimal type

2020-04-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092593#comment-17092593 ] Flavio Pompermaier commented on FLINK-17385: Ok..can you assign this and the other realted

[jira] [Commented] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-25 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092358#comment-17092358 ] Flavio Pompermaier commented on FLINK-17356: Yes, you're right. My laziness told me to try

[jira] [Created] (FLINK-17366) Implement listViews

2020-04-24 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17366: -- Summary: Implement listViews Key: FLINK-17366 URL: https://issues.apache.org/jira/browse/FLINK-17366 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17361) Support creating of a JDBC table using a custom query

2020-04-23 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17361: -- Summary: Support creating of a JDBC table using a custom query Key: FLINK-17361 URL: https://issues.apache.org/jira/browse/FLINK-17361 Project: Flink

[jira] [Created] (FLINK-17360) Support custom partitioners in JDBCReadOptions

2020-04-23 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17360: -- Summary: Support custom partitioners in JDBCReadOptions Key: FLINK-17360 URL: https://issues.apache.org/jira/browse/FLINK-17360 Project: Flink

[jira] [Created] (FLINK-17358) JDBCTableSource support FiltertableTableSource

2020-04-23 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17358: -- Summary: JDBCTableSource support FiltertableTableSource Key: FLINK-17358 URL: https://issues.apache.org/jira/browse/FLINK-17358 Project: Flink

[jira] [Created] (FLINK-17357) add "DROP catalog" DDL to blink planner

2020-04-23 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17357: -- Summary: add "DROP catalog" DDL to blink planner Key: FLINK-17357 URL: https://issues.apache.org/jira/browse/FLINK-17357 Project: Flink Issue

[jira] [Created] (FLINK-17356) Properly set constraints (PK and UNIQUE)

2020-04-23 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17356: -- Summary: Properly set constraints (PK and UNIQUE) Key: FLINK-17356 URL: https://issues.apache.org/jira/browse/FLINK-17356 Project: Flink Issue

[jira] [Updated] (FLINK-17284) Support serial field type in PostgresCatalog

2020-04-23 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-17284: --- Parent: FLINK-15351 Issue Type: Sub-task (was: Improvement) > Support

[jira] [Commented] (FLINK-10795) STDDEV_POP error

2020-04-23 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090737#comment-17090737 ] Flavio Pompermaier commented on FLINK-10795: I didn't test it..can someone test this? >

[jira] [Created] (FLINK-17284) Support serial field type in PostgresCatalog

2020-04-20 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17284: -- Summary: Support serial field type in PostgresCatalog Key: FLINK-17284 URL: https://issues.apache.org/jira/browse/FLINK-17284 Project: Flink

[jira] [Commented] (FLINK-17062) Fix the conversion from Java row type to Python row type

2020-04-09 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079058#comment-17079058 ] Flavio Pompermaier commented on FLINK-17062: Maybe a stupid question: would it be possible

[jira] [Commented] (FLINK-11852) Improve Processing function example

2020-03-17 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061222#comment-17061222 ] Flavio Pompermaier commented on FLINK-11852: I think the PR is good to merge..anyone taking

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

2020-03-12 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-4491. - Resolution: Won't Fix > Handle index.number_of_shards in the ES connector >

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

2020-03-12 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-7930. - Resolution: Fixed > Support periodic jobs with state that gets restored and persisted in

[jira] [Closed] (FLINK-10562) Relax (or document) table name constraints

2020-03-12 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-10562. -- Resolution: Not A Problem > Relax (or document) table name constraints >

[jira] [Closed] (FLINK-10731) Support AVG on Date fields

2020-03-12 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-10731. -- Resolution: Won't Fix > Support AVG on Date fields > -- > >

[jira] [Commented] (FLINK-10795) STDDEV_POP error

2020-03-12 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057794#comment-17057794 ] Flavio Pompermaier commented on FLINK-10795: Any news on this? > STDDEV_POP error >

[jira] [Commented] (FLINK-10947) Document handling of null keys in the data types documentation

2020-03-12 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057793#comment-17057793 ] Flavio Pompermaier commented on FLINK-10947: Any news on this [~twalthr] and [~trohrmann]?

[jira] [Commented] (FLINK-14992) Add job submission listener to execution environments

2019-12-10 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992329#comment-16992329 ] Flavio Pompermaier commented on FLINK-14992: Thanks for this feature, it's SUPER useful

[jira] [Commented] (FLINK-14209) Add jackson-dataformat-xml to flink-shaded

2019-09-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939261#comment-16939261 ] Flavio Pompermaier commented on FLINK-14209: It's ok, no problem! > Add

[jira] [Comment Edited] (FLINK-11711) Add table and column stats

2019-09-27 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773850#comment-16773850 ] Flavio Pompermaier edited comment on FLINK-11711 at 9/27/19 7:46 AM: -

[jira] [Commented] (FLINK-14209) Add jackson-dataformat-xml to flink-shaded

2019-09-26 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938591#comment-16938591 ] Flavio Pompermaier commented on FLINK-14209: Hi [~gjy], of course I could use directly

[jira] [Commented] (FLINK-14209) Add jackson-dataformat-xml to flink-shaded

2019-09-25 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937654#comment-16937654 ] Flavio Pompermaier commented on FLINK-14209: If you use 

[jira] [Comment Edited] (FLINK-14209) Add jackson-dataformat-xml to flink-shaded

2019-09-25 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937654#comment-16937654 ] Flavio Pompermaier edited comment on FLINK-14209 at 9/25/19 11:40 AM:

[jira] [Created] (FLINK-14209) Add jackson-dataformat-xml to flink-shaded

2019-09-25 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-14209: -- Summary: Add jackson-dataformat-xml to flink-shaded Key: FLINK-14209 URL: https://issues.apache.org/jira/browse/FLINK-14209 Project: Flink Issue

[jira] [Commented] (FLINK-14075) Remove unnecessary resource close in JDBCOutputFormatTest.java

2019-09-23 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935802#comment-16935802 ] Flavio Pompermaier commented on FLINK-14075: If I look at 

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

2019-04-08 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1681#comment-1681 ] Flavio Pompermaier commented on FLINK-4785: --- Which url is no longer valid?

[jira] [Created] (FLINK-11852) Improve Processing function example

2019-03-07 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-11852: -- Summary: Improve Processing function example Key: FLINK-11852 URL: https://issues.apache.org/jira/browse/FLINK-11852 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2019-03-04 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783373#comment-16783373 ] Flavio Pompermaier commented on FLINK-11811: What about using Apache BookKeeper for that ?

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

2019-02-28 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-4785: -- Description: To reproduce the error run 

[jira] [Commented] (FLINK-11711) Add table and column stats

2019-02-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16775123#comment-16775123 ] Flavio Pompermaier commented on FLINK-11711: Also [https://github.com/addthis/stream-lib/] 

[jira] [Commented] (FLINK-11711) Add table and column stats

2019-02-21 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774045#comment-16774045 ] Flavio Pompermaier commented on FLINK-11711: It's a public repo and it's accessible. It

[jira] [Commented] (FLINK-11711) Add table and column stats

2019-02-21 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773850#comment-16773850 ] Flavio Pompermaier commented on FLINK-11711: We've just published a computation of those

[jira] [Commented] (FLINK-11525) Add option to manually set job ID

2019-02-05 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760794#comment-16760794 ] Flavio Pompermaier commented on FLINK-11525: You're right [~uce], I just saw some effort on

[jira] [Commented] (FLINK-11525) Add option to manually set job ID

2019-02-05 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760707#comment-16760707 ] Flavio Pompermaier commented on FLINK-11525: Do you think it could be possible to provide a

[jira] [Commented] (FLINK-10952) How to stream MySQl data and Store in Flink Dataset

2018-11-20 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693407#comment-16693407 ] Flavio Pompermaier commented on FLINK-10952: Try to look at [1] for batch or use Table API

  1   2   3   >