[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&focusedCommentId=17371988#comment-17371988 ] Ada Wong commented on FLINK-23074: -- [~luoyuxia] When I use HDFS read or write parquet a

[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&focusedCommentId=17372601#comment-17372601 ] Ada Wong commented on FLINK-23074: -- I custom a HDFS connector, it use ExampleParquetWri

[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&focusedCommentId=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:05 AM:

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

[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&focusedCommentId=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:41 AM:

[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&focusedCommentId=17372601#comment-17372601 ] Ada Wong edited comment on FLINK-23074 at 7/1/21, 10:41 AM:

[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&focusedCommentId=17374776#comment-17374776 ] Ada Wong commented on FLINK-23074: -- [~lirui] Could we name 'org.apache.flink.hive.reloc

[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] [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. "Sou

[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] [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&focusedCommentId=17375144#comment-17375144 ] Ada Wong commented on FLINK-23074: -- I agree > There is a class conflict between flink-

[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&focusedCommentId=17377207#comment-17377207 ] Ada Wong commented on FLINK-23074: -- [~lirui] I has fixed in release 1.13 and 1.12. plea

[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&focusedCommentId=17377832#comment-17377832 ] Ada Wong commented on FLINK-23324: -- Please assign to me, thanks. > Postgres of JDBC Co

[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&focusedCommentId=17377835#comment-17377835 ] Ada Wong commented on FLINK-23324: -- [~Leonard Xu][~jark] > Postgres of JDBC Connector

[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&focusedCommentId=17381186#comment-17381186 ] Ada Wong commented on FLINK-23324: -- This following is Postgres table DDL . {code:sql}

[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&focusedCommentId=17381189#comment-17381189 ] Ada Wong commented on FLINK-23324: -- if we don't use double double quotes, we can't writ

[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&focusedCommentId=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 8:57 AM:

[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&focusedCommentId=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 8:58 AM:

[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&focusedCommentId=17381189#comment-17381189 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:00 AM:

[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&focusedCommentId=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:37 AM:

[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&focusedCommentId=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:37 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388397#comment-17388397 ] Ada Wong commented on FLINK-23263: -- This happen in double stream join and I don't set t

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

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388397#comment-17388397 ] Ada Wong edited comment on FLINK-23263 at 7/28/21, 2:12 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388575#comment-17388575 ] Ada Wong commented on FLINK-23263: -- I use Blink SQL, and inner join task backpressure s

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

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

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

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

[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] [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&focusedCommentId=17366957#comment-17366957 ] Ada Wong commented on FLINK-23074: -- cc [~lzljs3620320] > There is a class conflict bet

[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 flink-connec

[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&focusedCommentId=17366957#comment-17366957 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:02 AM:

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong commented on FLINK-23074: -- Could we add a parquet-hadoop in connector-hive p

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:09 AM:

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:19 AM:

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:09 AM:

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:11 AM:

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM:

[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&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM:

[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&focusedCommentId=17367118#comment-17367118 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 8:12 AM:

[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&focusedCommentId=17367118#comment-17367118 ] Ada Wong commented on FLINK-23074: -- If we cloud relocation org.apache.parquet. please a

[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 flink-p

[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&focusedCommentId=17367986#comment-17367986 ] Ada Wong commented on FLINK-23074: -- cc [~luoyuxia] flink-connector-hive 2.3.6 depend hi

[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&focusedCommentId=17367986#comment-17367986 ] Ada Wong edited comment on FLINK-23074 at 6/23/21, 9:26 AM:

[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] [Commented] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

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

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

[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&focusedCommentId=17413049#comment-17413049 ] Ada Wong commented on FLINK-22071: -- If no problem, please assign to me. I have finished

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

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

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

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

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

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

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

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

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

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

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

[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] [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: - Description: Inspired by JDBC and Kafka connector, add a 'sink.parallelism' option, and using SinkProvi

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

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

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

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

[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: - Priority: Blocker (was: Major) > Cannot install PyFlink on MacOS with M1 chip > ---

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

[jira] [Commented] (FLINK-25218) Performance issues with lookup join accessing external dimension tables

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

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

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

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] [Comment Edited] (FLINK-25240) Update log4j2 version to 2.15.0

[ 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] [Commented] (FLINK-25240) Update log4j2 version to 2.15.0

[ 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] [Updated] (FLINK-25240) Update log4j2 version to 2.15.0

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

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

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

[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&focusedCommentId=17406509#comment-17406509 ] Ada Wong commented on FLINK-23723: -- cc [~jark] We should decouple lookup join from the

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

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

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

[ 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] [Created] (FLINK-25141) Elasticsearch connector customize sink parallelism

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-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&focusedCommentId=17433696#comment-17433696 ] Ada Wong commented on FLINK-24381: -- As [~chesnay] comment in PR, could I directly use

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

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

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

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

  1   2   >