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

2022-02-11 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

2022-02-04 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24661: - Labels: pull-request-available (was: pull-request-available stale-assigned) > ConfigOption add

[jira] [Updated] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml

2022-01-26 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25834: - Description: When we use 'flink run' or CliFrontend class to submit job. If not set -C/-classpaths, it

[jira] [Commented] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml

2022-01-26 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482860#comment-17482860 ] Ada Wong commented on FLINK-25834: -- I want to fix this. > 'flink run' command can not use

[jira] [Created] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml

2022-01-26 Thread Ada Wong (Jira)
Ada Wong created FLINK-25834: Summary: 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml Key: FLINK-25834 URL: https://issues.apache.org/jira/browse/FLINK-25834 Project: Flink

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Description: When we use multiple connectors could have class conflicts. This class conflict can not

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Issue Type: Bug (was: New Feature) > Loading and running connector code use separated ClassLoader. >

[jira] [Updated] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25804: - Priority: Blocker (was: Major) > Loading and running connector code use separated ClassLoader. >

[jira] [Created] (FLINK-25804) Loading and running connector code use separated ClassLoader.

2022-01-25 Thread Ada Wong (Jira)
Ada Wong created FLINK-25804: Summary: Loading and running connector code use separated ClassLoader. Key: FLINK-25804 URL: https://issues.apache.org/jira/browse/FLINK-25804 Project: Flink Issue

[jira] (FLINK-16222) Use plugins mechanism for initializing MetricReporters

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16222 ] Ada Wong deleted comment on FLINK-16222: -- was (Author: ana4): [~ana4]  > Use plugins mechanism for initializing MetricReporters > -- > >

[jira] [Commented] (FLINK-16222) Use plugins mechanism for initializing MetricReporters

2022-01-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481658#comment-17481658 ] Ada Wong commented on FLINK-16222: -- [~ana4]  > Use plugins mechanism for initializing MetricReporters

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

2022-01-24 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25795: - Description: https://issues.apache.org/jira/browse/FLINK-20732 the PR of this ticket is reviewd, we

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

2022-01-24 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481499#comment-17481499 ] Ada Wong commented on FLINK-25795: -- [~dianfu]  When the PR

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

2022-01-24 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25795: - External issue ID: (was: 20726) > Support Pulsar sink connector in Python DataStream API. >

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

2022-01-24 Thread Ada Wong (Jira)
Ada Wong created FLINK-25795: Summary: Support Pulsar sink connector in Python DataStream API. Key: FLINK-25795 URL: https://issues.apache.org/jira/browse/FLINK-25795 Project: Flink Issue Type:

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

2022-01-24 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481493#comment-17481493 ] Ada Wong commented on FLINK-25530: -- [~syhily]  Thanks, I create a pulsar python sink ticket. > Support

[jira] [Commented] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

2022-01-24 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481075#comment-17481075 ] Ada Wong commented on FLINK-18887: -- [~dianfu] I would like to take this. > Add ElasticSearch connector

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

2022-01-19 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479053#comment-17479053 ] Ada Wong commented on FLINK-25485: -- [~fpaul]  I want to work on this. > JDBC connector implicitly

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

2022-01-19 Thread Ada Wong (Jira)
[ 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 buffer-flush options of the mysql sink (sink.buffer-flush.max-rows

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

2022-01-19 Thread Ada Wong (Jira)
[ 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 buffer-flush options of the mysql sink (sink.buffer-flush.max-rows

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

2022-01-19 Thread Ada Wong (Jira)
[ 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 buffer-flush options of the mysql sink (sink.buffer-flush.max-rows

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

2022-01-19 Thread Ada Wong (Jira)
[ 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 buffer-flush options of the mysql sink (sink.buffer-flush.max-rows

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

2022-01-19 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478499#comment-17478499 ] Ada Wong commented on FLINK-25485: -- cc [~jark] [~fpaul] [~roman]  So many users reflect this problem

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

2022-01-19 Thread Ada Wong (Jira)
[ 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 buffer-flush options of the mysql sink, buffer-flush

[jira] [Comment Edited] (FLINK-20375) Support to control operator name in SQL

2022-01-17 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252560#comment-17252560 ] Ada Wong edited comment on FLINK-20375 at 1/18/22, 2:44 AM: My temporary fix

[jira] [Commented] (FLINK-25601) Update 'state.backend' in flink-conf.yaml

2022-01-10 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472442#comment-17472442 ] Ada Wong commented on FLINK-25601: -- [~yunta] I want to fix this. > Update 'state.backend' in

[jira] [Created] (FLINK-25601) Update 'state.backend' in flink-conf.yaml

2022-01-10 Thread Ada Wong (Jira)
Ada Wong created FLINK-25601: Summary: Update 'state.backend' in flink-conf.yaml Key: FLINK-25601 URL: https://issues.apache.org/jira/browse/FLINK-25601 Project: Flink Issue Type: Improvement

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

2022-01-10 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Affects Version/s: (was: 1.15.0) > Elasticsearch connector customize sink parallelism >

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

2022-01-05 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469632#comment-17469632 ] Ada Wong commented on FLINK-25141: -- [~fpaul] I have done, please review it, thanks. > Elasticsearch

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

2022-01-05 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141 ] Ada Wong deleted comment on FLINK-25141: -- was (Author: ana4): [~fpaul] I have done, please review it, thanks. > Elasticsearch connector customize sink parallelism >

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

2022-01-05 Thread Ada Wong (Jira)
[ 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-25530) Support Pulsar source connector in Python DataStream API.

2022-01-05 Thread Ada Wong (Jira)
[ 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] [Created] (FLINK-25530) Support Pulsar source connector in Python DataStream API.

2022-01-05 Thread Ada Wong (Jira)
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] [Comment Edited] (FLINK-20729) Pulsar DynamicTable

2022-01-05 Thread Ada Wong (Jira)
[ 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

2022-01-05 Thread Ada Wong (Jira)
[ 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-20729) Pulsar DynamicTable

2022-01-05 Thread Ada Wong (Jira)
[ 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] [Commented] (FLINK-25515) flink-kafka-consumer

2022-01-05 Thread Ada Wong (Jira)
[ 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] [Commented] (FLINK-25239) Delete useless variables

2022-01-04 Thread Ada Wong (Jira)
[ 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] [Comment Edited] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2022-01-03 Thread Ada Wong (Jira)
[ 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-25188) Cannot install PyFlink on MacOS with M1 chip

2022-01-03 Thread Ada Wong (Jira)
[ 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] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2021-12-30 Thread Ada Wong (Jira)
[ 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-25485) JDBC connector implicitly add options when use mysql

2021-12-30 Thread Ada Wong (Jira)
[ 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

2021-12-30 Thread Ada Wong (Jira)
[ 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] [Created] (FLINK-25485) JDBC connector implicitly add options when use mysql

2021-12-30 Thread Ada Wong (Jira)
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] [Created] (FLINK-25434) Throw an error when BigDecimal precision overflows.

2021-12-23 Thread Ada Wong (Jira)
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] [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

2021-12-22 Thread Ada Wong (Jira)
[ 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] [Commented] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-21 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-21 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25239) Delete useless variables

2021-12-20 Thread Ada Wong (Jira)
[ 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-25295) Update Log4j to 2.16.0

2021-12-14 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459111#comment-17459111 ] Ada Wong commented on FLINK-25295: -- cool ! > Update Log4j to 2.16.0 > -- > >

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

2021-12-13 Thread Ada Wong (Jira)
[ 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. >

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

2021-12-13 Thread Ada Wong (Jira)
[ 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-25239) Delete useless variables

2021-12-13 Thread Ada Wong (Jira)
[ 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-25141) Elasticsearch connector customize sink parallelism

2021-12-12 Thread Ada Wong (Jira)
[ 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-25240) Update log4j2 version to 2.15.0

2021-12-09 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25240: - Description: 2.0 <= Apache log4j2 <= 2.14.1 have a RCE zero day.

[jira] [Commented] (FLINK-25240) Update log4j2 version to 2.15.0

2021-12-09 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456899#comment-17456899 ] Ada Wong commented on FLINK-25240: -- I want to fix it. after 2.15.0 release I want to update it. >

[jira] [Comment Edited] (FLINK-25240) Update log4j2 version to 2.15.0

2021-12-09 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456899#comment-17456899 ] Ada Wong edited comment on FLINK-25240 at 12/10/21, 6:08 AM: - I want to fix

[jira] [Created] (FLINK-25240) Update log4j2 version to 2.15.0

2021-12-09 Thread Ada Wong (Jira)
Ada Wong created FLINK-25240: Summary: Update log4j2 version to 2.15.0 Key: FLINK-25240 URL: https://issues.apache.org/jira/browse/FLINK-25240 Project: Flink Issue Type: Bug

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

2021-12-09 Thread Ada Wong (Jira)
[ 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] [Created] (FLINK-25239) Delete useless variables

2021-12-09 Thread Ada Wong (Jira)
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] [Commented] (FLINK-25218) Performance issues with lookup join accessing external dimension tables

2021-12-08 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456188#comment-17456188 ] Ada Wong commented on FLINK-25218: -- We could import guava cache to cache the same primary key rows. >

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

2021-12-07 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454652#comment-17454652 ] Ada Wong commented on FLINK-25188: -- Apache-Beam in 2.34.0 version require 'numpy>=1.14.3,<1.21.0' >

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

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-07 Thread Ada Wong (Jira)
[ 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>= 1.24、pyarrow>=5.0.0、pandas>=1.3.0 and When set

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

2021-12-07 Thread Ada Wong (Jira)
[ 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>= 1.24、pyarrow>=5.0.0、pandas>=1.3.0 Numpy version:

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

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-07 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

2021-12-06 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-22071: - Priority: Major (was: Minor) > LookupTableSource.LookupRuntimeProvider customizes parallelism >

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

2021-12-06 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25188: - Priority: Blocker (was: Major) > Cannot install PyFlink on MacOS with M1 chip >

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

2021-12-06 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-06 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-06 Thread Ada Wong (Jira)
[ 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] [Created] (FLINK-25188) Cannot install PyFlink in M1 CPU

2021-12-06 Thread Ada Wong (Jira)
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-25141) Elasticsearch connector customize sink parallelism

2021-12-05 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Description: Inspired by JDBC and Kafka connector, add a 'sink.parallelism' option, and using

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

2021-12-02 Thread Ada Wong (Jira)
[ 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-25141) Elasticsearch connector customize sink parallelism

2021-12-01 Thread Ada Wong (Jira)
Ada Wong created FLINK-25141: Summary: Elasticsearch connector customize sink parallelism Key: FLINK-25141 URL: https://issues.apache.org/jira/browse/FLINK-25141 Project: Flink Issue Type:

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

2021-12-01 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452165#comment-17452165 ] Ada Wong commented on FLINK-25141: -- I want to fix this ticket. > Elasticsearch connector customize

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

2021-11-30 Thread Ada Wong (Jira)
[ 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-23324) Postgres of JDBC Connector enable case-sensitive.

2021-11-26 Thread Ada Wong (Jira)
[ 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] [Comment Edited] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

2021-10-28 Thread Ada Wong (Jira)
[ 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

2021-10-28 Thread Ada Wong (Jira)
[ 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] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-10-28 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

2021-10-27 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

2021-10-27 Thread Ada Wong (Jira)
[ 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] [Created] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

2021-10-26 Thread Ada Wong (Jira)
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] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-10-25 Thread Ada Wong (Jira)
[ 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] [Comment Edited] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-10-25 Thread Ada Wong (Jira)
[ 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] [Comment Edited] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-10-25 Thread Ada Wong (Jira)
[ 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.

2021-10-25 Thread Ada Wong (Jira)
[ 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] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-09-27 Thread Ada Wong (Jira)
[ 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] [Updated] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-09-27 Thread Ada Wong (Jira)
[ 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] [Created] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-09-27 Thread Ada Wong (Jira)
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] [Comment Edited] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

2021-09-10 Thread Ada Wong (Jira)
[ 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,

  1   2   >