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

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

[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&focusedCommentId=17482860#comment-17482860 ] Ada Wong commented on FLINK-25834: -- I want to fix this. > 'flink run' command can not

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

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

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

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

[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&focusedCommentId=17481658#comment-17481658 ] Ada Wong commented on FLINK-16222: -- [~ana4]  > Use plugins mechanism for initializing

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

[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&focusedCommentId=17481499#comment-17481499 ] Ada Wong commented on FLINK-25795: -- [~dianfu]  When the PR ([https://github.com/apache/

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

[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&focusedCommentId=17481493#comment-17481493 ] Ada Wong commented on FLINK-25530: -- [~syhily]  Thanks, I create a pulsar python sink ti

[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&focusedCommentId=17481075#comment-17481075 ] Ada Wong commented on FLINK-18887: -- [~dianfu] I would like to take this. > Add Elastic

[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&focusedCommentId=17479053#comment-17479053 ] Ada Wong commented on FLINK-25485: -- [~fpaul]  I want to work on this. > JDBC connector

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

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

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

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

[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&focusedCommentId=17478499#comment-17478499 ] Ada Wong commented on FLINK-25485: -- cc [~jark] [~fpaul] [~roman]  So many users reflec

[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 options(sink.buf

[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&focusedCommentId=17252560#comment-17252560 ] Ada Wong edited comment on FLINK-20375 at 1/18/22, 2:44 AM:

[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&focusedCommentId=17472442#comment-17472442 ] Ada Wong commented on FLINK-25601: -- [~yunta] I want to fix this. > Update 'state.backe

[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&focusedCommentId=17469632#comment-17469632 ] Ada Wong commented on FLINK-25141: -- [~fpaul] I have done, please review it, thanks. >

[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&focusedCommentId=17469294#comment-17469294 ] Ada Wong commented on FLINK-25530: -- [~dianfu] I would like to take this. > Support Pul

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

[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&focusedCommentId=17469144#comment-17469144 ] Ada Wong edited comment on FLINK-20729 at 1/5/22, 9:17 AM: --- To

[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&focusedCommentId=17469144#comment-17469144 ] Ada Wong edited comment on FLINK-20729 at 1/5/22, 9:17 AM: --- To

[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&focusedCommentId=17469144#comment-17469144 ] Ada Wong commented on FLINK-20729: -- To achieve this, could we add a new 'flink-sql-conn

[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&focusedCommentId=17469122#comment-17469122 ] Ada Wong commented on FLINK-25515: -- https://issues.apache.org/jira/browse/FLINK-20170?f

[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&focusedCommentId=17468513#comment-17468513 ] Ada Wong commented on FLINK-25239: -- cc [~roman] Could assign to me, and review this pr.

[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&focusedCommentId=17468339#comment-17468339 ] Ada Wong edited comment on FLINK-25188 at 1/4/22, 3:36 AM: --- [~

[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&focusedCommentId=17468339#comment-17468339 ] Ada Wong commented on FLINK-25188: -- [~maver1ck]  I can run word_count.py and python gen

[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&focusedCommentId=17467071#comment-17467071 ] Ada Wong commented on FLINK-14902: -- [~michael ran] What do you want to implement async

[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, sink.buf

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

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

[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&focusedCommentId=17463766#comment-17463766 ] Ada Wong commented on FLINK-25418: -- cc [~dianfu] I want to fix this.  I will add the '-

[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&focusedCommentId=17463600#comment-17463600 ] Ada Wong commented on FLINK-25188: -- I have updated numpy version in Apache Beam. we cou

[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>= 1.20.3、pyarrow>=5.0.0、pandas>=1.3.0、apache-beam==2.36

[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&focusedCommentId=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: FLI

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

[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. [https://www.cyberkendra.com/2021/12/w

[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&focusedCommentId=17456899#comment-17456899 ] Ada Wong commented on FLINK-25240: -- I want to fix it. after 2.15.0 release I want to up

[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&focusedCommentId=17456899#comment-17456899 ] Ada Wong edited comment on FLINK-25240 at 12/10/21, 6:08 AM: -

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

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

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

[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&focusedCommentId=17456188#comment-17456188 ] Ada Wong commented on FLINK-25218: -- We could import guava cache to cache the same prima

[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&focusedCommentId=17454652#comment-17454652 ] Ada Wong commented on FLINK-25188: -- Apache-Beam in 2.34.0 version require 'numpy>=1.14.

[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.20.3、pyarrow>=5.0.0、pandas>=1.3.0、apache-beam==2.34

[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、apache-beam==2.34.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>= 1.24、pyarrow>=5.0.0、pandas>=1.3.0、apache-beam==2.34.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>= 1.24、pyarrow>=5.0.0、pandas>=1.3.0、apache-beam==2.34.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>= 1.24、pyarrow>=5.0.0、pandas>=1.3.0 and When set python

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

[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: /Users/foo/.pyenv/versions/

[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: /Users/foo/.pyenv/versions/

[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: /Users/foo/.pyenv/versions/

[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: /Users/foo/.pyenv/versions/

[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: /Users/foo/.pyenv/versions/

[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) > Cannot

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

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

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

[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&focusedCommentId=17452165#comment-17452165 ] Ada Wong commented on FLINK-25141: -- I want to fix this ticket. > Elasticsearch connect

[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&focusedCommentId=17451550#comment-17451550 ] Ada Wong commented on FLINK-23324: -- [~jark]  please assign someone to review it. > Pos

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

[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&focusedCommentId=17435367#comment-17435367 ] Ada Wong edited comment on FLINK-24661 at 10/28/21, 12:23 PM:

[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&focusedCommentId=17435367#comment-17435367 ] Ada Wong commented on FLINK-24661: -- [~chesnay] Could I continue to fix it.  > ConfigOp

[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&focusedCommentId=17435362#comment-17435362 ] Ada Wong commented on FLINK-24381: -- Could I take 2 PR to 1.12-release and 1.13-release?

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

2021-10-26 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 t

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

2021-10-26 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 m

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

[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&focusedCommentId=17434082#comment-17434082 ] Ada Wong commented on FLINK-24381: -- So I create a new ticket and PR to add support for

[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&focusedCommentId=17434082#comment-17434082 ] Ada Wong edited comment on FLINK-24381 at 10/26/21, 2:26 AM: -

[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&focusedCommentId=17433696#comment-17433696 ] Ada Wong edited comment on FLINK-24381 at 10/25/21, 11:26 AM:

[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&focusedCommentId=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&focusedCommentId=17420625#comment-17420625 ] Ada Wong commented on FLINK-24381: -- I agree with [~twalthr]. I want to fix this. > Hid

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

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

2021-09-26 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 Issu

[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&focusedCommentId=17413049#comment-17413049 ] Ada Wong edited comment on FLINK-22071 at 9/10/21, 8:31 AM:

  1   2   >