[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360588#comment-17360588 ] Ada Wong commented on FLINK-14902: -- I want to contribute this ticket. I want to use VertX to support

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366411#comment-17366411 ] Ada Wong commented on FLINK-14902: -- [~michael ran] DataSource (HikariCP and Druid) is pluggable when we

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367986#comment-17367986 ] Ada Wong edited comment on FLINK-23074 at 6/23/21, 9:26 AM: cc [~luoyuxia]

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367986#comment-17367986 ] Ada Wong commented on FLINK-23074: -- cc [~luoyuxia] flink-connector-hive 2.3.6 depend hive-exec.

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23074: - Affects Version/s: 1.13.1 1.12.4 > There is a class conflict between

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366957#comment-17366957 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:02 AM: cc

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong commented on FLINK-23074: -- Could we add a parquet-hadoop in connector-hive pom. {code:xml}

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:11 AM: Could we add a

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366957#comment-17366957 ] Ada Wong commented on FLINK-23074: -- cc [~lzljs3620320] > There is a class conflict between

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:19 AM: Could we add a

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM: Could we add a

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM: Could we add a

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:09 AM: Could we add a

[jira] [Created] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

Ada Wong created FLINK-23074: Summary: There is a class conflict between flink-connector-hive and flink-parquet Key: FLINK-23074 URL: https://issues.apache.org/jira/browse/FLINK-23074 Project: Flink

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:09 AM: Could we add a

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367118#comment-17367118 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 8:12 AM: If we cloud

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367118#comment-17367118 ] Ada Wong commented on FLINK-23074: -- If we cloud relocation org.apache.parquet. please assign this

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23074: - Issue Type: Bug (was: Improvement) > There is a class conflict between flink-connector-hive and

[jira] [Commented] (FLINK-22776) Delete casting to byte[]

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351449#comment-17351449 ] Ada Wong commented on FLINK-22776: -- [~Leonard Xu] > Delete casting to byte[] >

[jira] [Comment Edited] (FLINK-22776) Delete casting to byte[]

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351449#comment-17351449 ] Ada Wong edited comment on FLINK-22776 at 5/26/21, 2:43 AM: cc [~Leonard Xu]

[jira] [Created] (FLINK-22776) Delete casting to byte[]

Ada Wong created FLINK-22776: Summary: Delete casting to byte[] Key: FLINK-22776 URL: https://issues.apache.org/jira/browse/FLINK-22776 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-22776: - Description: Casting to 'byte[]' is redundant. Could we delete it? {code:java} case

[jira] [Updated] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-22776: - Summary: Delete casting to byte[] in AbstractJdbcRowConverter class (was: Delete casting to byte[]) >

[jira] [Commented] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351451#comment-17351451 ] Ada Wong commented on FLINK-22776: -- If we can do it, please assign to me. > Delete casting to byte[]

[jira] [Commented] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356118#comment-17356118 ] Ada Wong commented on FLINK-22776: -- cc [~jark] please assign it to me. thanks. > Delete casting to

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-20696: - Priority: Major (was: Minor) > Yarn Session Blob Directory is not deleted. >

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377207#comment-17377207 ] Ada Wong commented on FLINK-23074: -- [~lirui] I has fixed in release 1.13 and 1.12. please review it.

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23074: - Attachment: screenshot-1.png > There is a class conflict between flink-connector-hive and flink-parquet

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:41 AM: [~luoyuxia] I

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:41 AM: [~luoyuxia] I

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23074: - Attachment: screenshot-4.png > There is a class conflict between flink-connector-hive and flink-parquet

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372601#comment-17372601 ] Ada Wong commented on FLINK-23074: -- I custom a HDFS connector, it use ExampleParquetWriter class

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:05 AM: [~luoyuxia] I

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:25 AM: [~luoyuxia] I

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371988#comment-17371988 ] Ada Wong commented on FLINK-23074: -- [~luoyuxia] When I use HDFS read or write parquet and use flink

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23074: - Attachment: screenshot-3.png > There is a class conflict between flink-connector-hive and flink-parquet

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17374776#comment-17374776 ] Ada Wong commented on FLINK-23074: -- [~lirui] Could we name 'org.apache.flink.hive.relocated.parquet'.

[jira] [Created] (FLINK-23263) LocalBufferPool can not request memory.

Ada Wong created FLINK-23263: Summary: LocalBufferPool can not request memory. Key: FLINK-23263 URL: https://issues.apache.org/jira/browse/FLINK-23263 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375144#comment-17375144 ] Ada Wong commented on FLINK-23074: -- I agree > There is a class conflict between flink-connector-hive

[jira] [Updated] (FLINK-23263) LocalBufferPool can not request memory.

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23263: - Description: Flink job is running, bug it can not consume kafka data. This following is exception.

[jira] [Updated] (FLINK-23263) LocalBufferPool can not request memory.

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23263: - Issue Type: Bug (was: Improvement) > LocalBufferPool can not request memory. >

[jira] [Created] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

Ada Wong created FLINK-23324: Summary: Postgres of JDBC Connector enable case-sensitive. Key: FLINK-23324 URL: https://issues.apache.org/jira/browse/FLINK-23324 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377832#comment-17377832 ] Ada Wong commented on FLINK-23324: -- Please assign to me, thanks. > Postgres of JDBC Connector enable

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377835#comment-17377835 ] Ada Wong commented on FLINK-23324: -- [~Leonard Xu][~jark] > Postgres of JDBC Connector enable

[jira] [Commented] (FLINK-23723) Look up join support PROCTIME() function

[ https://issues.apache.org/jira/browse/FLINK-23723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406509#comment-17406509 ] Ada Wong commented on FLINK-23723: -- cc [~jark] We should decouple lookup join from the source table

[jira] [Commented] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

[ https://issues.apache.org/jira/browse/FLINK-22071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413023#comment-17413023 ] Ada Wong commented on FLINK-22071: -- Some lookup operator is a lot of time-consuming. Could we add a

[jira] [Comment Edited] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

[ https://issues.apache.org/jira/browse/FLINK-22071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413049#comment-17413049 ] Ada Wong edited comment on FLINK-22071 at 9/10/21, 8:31 AM: If no problem,

[jira] [Commented] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

[ https://issues.apache.org/jira/browse/FLINK-22071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413049#comment-17413049 ] Ada Wong commented on FLINK-22071: -- If no problem, please assign to me. I have finished the code》 >

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong commented on FLINK-23324: -- This following is Postgres table DDL . {code:sql} create table foo

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381189#comment-17381189 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:00 AM: If we don't use

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 8:58 AM: This following

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381189#comment-17381189 ] Ada Wong commented on FLINK-23324: -- if we don't use double double quotes, we can't write data into

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 8:57 AM: This following

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:37 AM: This following

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:37 AM: This following

[jira] [Updated] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24381: - Description: This following is error message. Password is 'bar' and is displayed. Could we hidden it

[jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420625#comment-17420625 ] Ada Wong commented on FLINK-24381: -- I agree with [~twalthr]. I want to fix this. > Hidden password

[jira] [Created] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

Ada Wong created FLINK-24381: Summary: Hidden password value when Flink SQL connector throw exception. Key: FLINK-24381 URL: https://issues.apache.org/jira/browse/FLINK-24381 Project: Flink

[jira] [Created] (FLINK-25188) Cannot install PyFlink in M1 CPU

Ada Wong created FLINK-25188: Summary: Cannot install PyFlink in M1 CPU Key: FLINK-25188 URL: https://issues.apache.org/jira/browse/FLINK-25188 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25188: - Summary: Cannot install PyFlink on MacOS with M1 chip (was: Cannot install PyFlink in M1 CPU) >

[jira] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25188: - Description:   {code:java} ERROR: Command errored out with exit status 1:

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451550#comment-17451550 ] Ada Wong commented on FLINK-23324: -- [~jark]  please assign someone to review it. > Postgres of JDBC

[jira] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25188: - Description:   {code:java} ERROR: Command errored out with exit status 1:

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467071#comment-17467071 ] Ada Wong commented on FLINK-14902: -- [~michael ran] What do you want to implement async using

[jira] [Updated] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25239: - Component/s: Table SQL / Ecosystem > Delete useless variables > > >

[jira] [Commented] (FLINK-20729) Pulsar DynamicTable

[ https://issues.apache.org/jira/browse/FLINK-20729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469144#comment-17469144 ] Ada Wong commented on FLINK-20729: -- To achieve this, could we add a new 'flink-sql-connector-pulsar'

[jira] [Comment Edited] (FLINK-20729) Pulsar DynamicTable

[ https://issues.apache.org/jira/browse/FLINK-20729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469144#comment-17469144 ] Ada Wong edited comment on FLINK-20729 at 1/5/22, 9:17 AM: --- To achieve this,

[jira] [Comment Edited] (FLINK-20729) Pulsar DynamicTable

[ https://issues.apache.org/jira/browse/FLINK-20729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469144#comment-17469144 ] Ada Wong edited comment on FLINK-20729 at 1/5/22, 9:17 AM: --- To achieve this,

[jira] [Commented] (FLINK-25515) flink-kafka-consumer

[ https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469122#comment-17469122 ] Ada Wong commented on FLINK-25515: -- https://issues.apache.org/jira/browse/FLINK-20170?filter=-2

[jira] [Created] (FLINK-25530) Support Pulsar source connector in Python DataStream API.

Ada Wong created FLINK-25530: Summary: Support Pulsar source connector in Python DataStream API. Key: FLINK-25530 URL: https://issues.apache.org/jira/browse/FLINK-25530 Project: Flink Issue

[jira] [Updated] (FLINK-25530) Support Pulsar source connector in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25530: - Component/s: Connectors / Pulsar > Support Pulsar source connector in Python DataStream API. >

[jira] [Commented] (FLINK-25530) Support Pulsar source connector in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469294#comment-17469294 ] Ada Wong commented on FLINK-25530: -- [~dianfu] I would like to take this. > Support Pulsar source

[jira] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25188: - Description: Need to update dependencies: numpy>=

[jira] [Created] (FLINK-25434) Throw an error when BigDecimal precision overflows.

Ada Wong created FLINK-25434: Summary: Throw an error when BigDecimal precision overflows. Key: FLINK-25434 URL: https://issues.apache.org/jira/browse/FLINK-25434 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25485) JDBC connector implicitly add options when use mysql

Ada Wong created FLINK-25485: Summary: JDBC connector implicitly add options when use mysql Key: FLINK-25485 URL: https://issues.apache.org/jira/browse/FLINK-25485 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25485) JDBC connector implicitly add options when use mysql

[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25485: - Description: When we directly use mysql sink, buffer-flush options(sink.buffer-flush.max-rows, 

[jira] [Updated] (FLINK-25485) JDBC connector implicitly append url options when use mysql

[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25485: - Summary: JDBC connector implicitly append url options when use mysql (was: JDBC connector implicitly

[jira] [Commented] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468339#comment-17468339 ] Ada Wong commented on FLINK-25188: -- [~maver1ck]  I can run word_count.py and python general UDF. >

[jira] [Comment Edited] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468339#comment-17468339 ] Ada Wong edited comment on FLINK-25188 at 1/4/22, 3:36 AM: --- [~maver1ck]  I can

[jira] [Commented] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468513#comment-17468513 ] Ada Wong commented on FLINK-25239: -- cc [~roman] Could assign to me, and review this pr. > Delete

[jira] [Commented] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463600#comment-17463600 ] Ada Wong commented on FLINK-25188: -- I have updated numpy version in Apache Beam. we could bump to Beam

[jira] [Commented] (FLINK-25418) The dir_cache is specified in the flick task. When there is no network, you will still download the python third-party library

[ https://issues.apache.org/jira/browse/FLINK-25418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463766#comment-17463766 ] Ada Wong commented on FLINK-25418: -- cc [~dianfu] I want to fix this.  I will add the '--no-index'

[jira] [Updated] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23324: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Postgres of JDBC

[jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435362#comment-17435362 ] Ada Wong commented on FLINK-24381: -- Could I take 2 PR to 1.12-release and 1.13-release? [~chesnay] >

[jira] [Comment Edited] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435367#comment-17435367 ] Ada Wong edited comment on FLINK-24661 at 10/28/21, 12:23 PM: -- [~chesnay] 

[jira] [Commented] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435367#comment-17435367 ] Ada Wong commented on FLINK-24661: -- [~chesnay] Could I continue to fix it.  > ConfigOption add

[jira] [Comment Edited] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433696#comment-17433696 ] Ada Wong edited comment on FLINK-24381 at 10/25/21, 11:26 AM: -- As

[jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433696#comment-17433696 ] Ada Wong commented on FLINK-24381: -- As [~chesnay] comment in PR, could I directly use

[jira] [Created] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

Ada Wong created FLINK-24661: Summary: ConfigOption add isSecret method to judge sensitive options Key: FLINK-24661 URL: https://issues.apache.org/jira/browse/FLINK-24661 Project: Flink Issue

[jira] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24661: - Description: Related ticket https://issues.apache.org/jira/browse/FLINK-24381 [~chesnay] This ticket

[jira] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24661: - Description: Related ticket https://issues.apache.org/jira/browse/FLINK-24381 [~chesnay] Should this

[jira] [Comment Edited] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434082#comment-17434082 ] Ada Wong edited comment on FLINK-24381 at 10/26/21, 2:26 AM: - So I create a

[jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434082#comment-17434082 ] Ada Wong commented on FLINK-24381: -- So I create a new ticket and PR to add support for using 

[jira] [Updated] (FLINK-25141) Elasticsearch connector customize sink parallelism

[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Component/s: Table SQL / Ecosystem > Elasticsearch connector customize sink parallelism >

[jira] [Created] (FLINK-25239) Delete useless variables

Ada Wong created FLINK-25239: Summary: Delete useless variables Key: FLINK-25239 URL: https://issues.apache.org/jira/browse/FLINK-25239 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25239: - Description:    DEFAULT_FLUSH_MAX_SIZE and DEFAULT_FLUSH_INTERVAL_MILLS in JdbcOutputFormat class are

[jira] [Updated] (FLINK-25141) Elasticsearch connector customize sink parallelism

[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Fix Version/s: 1.15.0 > Elasticsearch connector customize sink parallelism >

[jira] [Updated] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25239: - Fix Version/s: 1.15.0 > Delete useless variables > > > Key:

[jira] [Updated] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25239: - Fix Version/s: 1.14.1 > Delete useless variables > > > Key:

[jira] [Updated] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23324: - Fix Version/s: 1.15.0 1.14.1 > Postgres of JDBC Connector enable case-sensitive. >

  1   2   >