[jira] [Created] (FLINK-33700) CustomSSLEngineProvider supports SHA-256

2023-11-29 Thread Bo Cui (Jira)
Bo Cui created FLINK-33700: -- Summary: CustomSSLEngineProvider supports SHA-256 Key: FLINK-33700 URL: https://issues.apache.org/jira/browse/FLINK-33700 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33809) HiveCatalog load hivemetastore.xml

2023-12-12 Thread Bo Cui (Jira)
Bo Cui created FLINK-33809: -- Summary: HiveCatalog load hivemetastore.xml Key: FLINK-33809 URL: https://issues.apache.org/jira/browse/FLINK-33809 Project: Flink Issue Type: Improvement Re

[jira] [Updated] (FLINK-33809) HiveCatalog load hivemetastore.xml

2023-12-12 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-33809: --- Affects Version/s: 1.17.1 1.19.0 1.18.1 > HiveCatalog load hiv

[jira] [Updated] (FLINK-33809) HiveCatalog load hivemetastore.xml

2023-12-12 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-33809: --- Component/s: Connectors / Hive > HiveCatalog load hivemetastore.xml > -- > >

[jira] [Commented] (FLINK-30943) Hide sensitive command-line configurations

2023-02-13 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688273#comment-17688273 ] Bo Cui commented on FLINK-30943: The jira tries to hidden the value who's separated from

[jira] [Created] (FLINK-32454) deserializeStreamStateHandle of checkpoint read byte

2023-06-27 Thread Bo Cui (Jira)
Bo Cui created FLINK-32454: -- Summary: deserializeStreamStateHandle of checkpoint read byte Key: FLINK-32454 URL: https://issues.apache.org/jira/browse/FLINK-32454 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32575) Unified the Cpu of JobManager Name

2023-07-11 Thread Bo Cui (Jira)
Bo Cui created FLINK-32575: -- Summary: Unified the Cpu of JobManager Name Key: FLINK-32575 URL: https://issues.apache.org/jira/browse/FLINK-32575 Project: Flink Issue Type: New Feature Re

[jira] [Created] (FLINK-30943) Hide sensitive command-line configurations

2023-02-07 Thread Bo Cui (Jira)
Bo Cui created FLINK-30943: -- Summary: Hide sensitive command-line configurations Key: FLINK-30943 URL: https://issues.apache.org/jira/browse/FLINK-30943 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-30943) Hide sensitive command-line configurations

2023-02-07 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-30943: --- Issue Type: Bug (was: Improvement) > Hide sensitive command-line configurations > -

[jira] [Updated] (FLINK-30943) Hide sensitive command-line configurations

2023-02-07 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-30943: --- Description: When a job is submitted from the command line, log prints jvm options and application dynamic

[jira] [Created] (FLINK-32159) Hudi Source throws NPE

2023-05-22 Thread Bo Cui (Jira)
Bo Cui created FLINK-32159: -- Summary: Hudi Source throws NPE Key: FLINK-32159 URL: https://issues.apache.org/jira/browse/FLINK-32159 Project: Flink Issue Type: Bug Affects Versions: 1.17.0, 1.16

[jira] [Updated] (FLINK-32159) Hudi Source throws NPE

2023-05-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-32159: --- Description: spark/hive write hudi, and flink read hudi and job failed. because  !image-2023-05-23-14-45-29

[jira] [Updated] (FLINK-32159) Hudi Source throws NPE

2023-05-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-32159: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Hudi Source throws NPE > ---

[jira] [Created] (FLINK-30597) Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules

2023-01-08 Thread Bo Cui (Jira)
Bo Cui created FLINK-30597: -- Summary: Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules Key: FLINK-30597 URL: https://issues.apache.org/jira/browse/FLINK-30597 Project: Flink Issue Ty

[jira] [Created] (FLINK-31844) DefaultPackagedProgramRetriever#getClasspathsFromUserLibDir supports loading profile

2023-04-18 Thread Bo Cui (Jira)
Bo Cui created FLINK-31844: -- Summary: DefaultPackagedProgramRetriever#getClasspathsFromUserLibDir supports loading profile Key: FLINK-31844 URL: https://issues.apache.org/jira/browse/FLINK-31844 Project: Fl

[jira] [Updated] (FLINK-31844) DefaultPackagedProgramRetriever#getClasspathsFromUserLibDir supports loading profile

2023-04-18 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-31844: --- Description: now getClasspathsFromUserLibDir only load JarFile, i dont know why, but i think we can add non

[jira] [Commented] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME()

2023-04-23 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715562#comment-17715562 ] Bo Cui commented on FLINK-21714: [~leonard] hi Have you tested the sql? val table = tEnv

[jira] [Comment Edited] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME()

2023-04-23 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715562#comment-17715562 ] Bo Cui edited comment on FLINK-21714 at 4/24/23 3:03 AM: - [~leon

[jira] [Created] (FLINK-32017) DISTINCT COUNT result is incorrect with ttl

2023-05-05 Thread Bo Cui (Jira)
Bo Cui created FLINK-32017: -- Summary: DISTINCT COUNT result is incorrect with ttl Key: FLINK-32017 URL: https://issues.apache.org/jira/browse/FLINK-32017 Project: Flink Issue Type: Bug Affects V

[jira] [Created] (FLINK-31595) MiniBatchLocalGroupAggFunction produces wrong aggregate results with state clean up

2023-03-23 Thread Bo Cui (Jira)
Bo Cui created FLINK-31595: -- Summary: MiniBatchLocalGroupAggFunction produces wrong aggregate results with state clean up Key: FLINK-31595 URL: https://issues.apache.org/jira/browse/FLINK-31595 Project: Flin

[jira] [Commented] (FLINK-31595) MiniBatchLocalGroupAggFunction produces wrong aggregate results with state clean up

2023-03-26 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705135#comment-17705135 ] Bo Cui commented on FLINK-31595: like the sql: select a, max(b), max(c) from (   selec

[jira] [Issue Comment Deleted] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-19 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-21640: --- Comment: was deleted (was: [~knaufk] hi,can u rerun PR ci for me? because in my pc, all tests are ok) > Job

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-19 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305293#comment-17305293 ] Bo Cui commented on FLINK-21640: [~rmetzger] can u review and merge the PR? > Job fails

[jira] [Comment Edited] (FLINK-15911) Flink does not work over NAT

2021-03-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305826#comment-17305826 ] Bo Cui edited comment on FLINK-15911 at 3/22/21, 2:17 AM: -- [~xi

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2021-03-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305826#comment-17305826 ] Bo Cui commented on FLINK-15911: [~xintongsong] in yarn cluster, what are bind-address

[jira] [Comment Edited] (FLINK-15911) Flink does not work over NAT

2021-03-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305826#comment-17305826 ] Bo Cui edited comment on FLINK-15911 at 3/22/21, 2:33 AM: -- [~xi

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2021-03-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305869#comment-17305869 ] Bo Cui commented on FLINK-15911: 1、all 0 has some security risks. 2、i think add new conf

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2021-03-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305915#comment-17305915 ] Bo Cui commented on FLINK-15911: 1、 all client IP can access the port through any NIC. y

[jira] [Comment Edited] (FLINK-15911) Flink does not work over NAT

2021-03-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305915#comment-17305915 ] Bo Cui edited comment on FLINK-15911 at 3/22/21, 6:38 AM: -- 1、 a

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305982#comment-17305982 ] Bo Cui commented on FLINK-15911: got...thank you very much [~xintongsong](y) > Flink do

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306067#comment-17306067 ] Bo Cui commented on FLINK-15911: but *on yarn*, taskmanager.host can not be null, and Al

[jira] [Updated] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-21640: --- Component/s: Client / Job Submission API / Core > Job fails to be submitted in tenant scena

[jira] [Updated] (FLINK-15911) Flink does not work over NAT

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-15911: --- Attachment: screenshot-2.png > Flink does not work over NAT > > >

[jira] [Updated] (FLINK-15911) Flink does not work over NAT

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-15911: --- Attachment: screenshot-1.png > Flink does not work over NAT > > >

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306173#comment-17306173 ] Bo Cui commented on FLINK-15911: !screenshot-1.png! !screenshot-2.png! i think it mi

[jira] [Comment Edited] (FLINK-15911) Flink does not work over NAT

2021-03-22 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306173#comment-17306173 ] Bo Cui edited comment on FLINK-15911 at 3/22/21, 12:51 PM: --- !s

[jira] [Created] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-25 Thread Bo Cui (Jira)
Bo Cui created FLINK-21981: -- Summary: Increase the priority of the parameter in flink-conf Key: FLINK-21981 URL: https://issues.apache.org/jira/browse/FLINK-21981 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-25 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-21981: --- Component/s: Deployment / YARN Client / Job Submission > Increase the priority of the param

[jira] [Updated] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-25 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-21981: --- Component/s: (was: Deployment / YARN) > Increase the priority of the parameter in flink-conf > -

[jira] [Created] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn

2021-03-25 Thread Bo Cui (Jira)
Bo Cui created FLINK-21982: -- Summary: jobs should use client org.apache.hadoop.config on yarn Key: FLINK-21982 URL: https://issues.apache.org/jira/browse/FLINK-21982 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn

2021-03-26 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309260#comment-17309260 ] Bo Cui commented on FLINK-21982: the configuration of all jobs may be different...like

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-26 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309373#comment-17309373 ] Bo Cui commented on FLINK-21640: {quote} Beyond the implementation, actually I have a co

[jira] [Comment Edited] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-26 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309373#comment-17309373 ] Bo Cui edited comment on FLINK-21640 at 3/26/21, 11:25 AM: --- {q

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-26 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309380#comment-17309380 ] Bo Cui commented on FLINK-21981: yes, but Preferential use of `env.hadoop.conf.dir` may

[jira] [Commented] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn

2021-03-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310354#comment-17310354 ] Bo Cui commented on FLINK-21982: thx [~xintongsong] FLINK-16005 only solves part of my

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310355#comment-17310355 ] Bo Cui commented on FLINK-21981: the client side has 2 hdfs-silt (default hdfs-site and

[jira] [Comment Edited] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310355#comment-17310355 ] Bo Cui edited comment on FLINK-21981 at 3/29/21, 3:33 AM: -- the

[jira] [Commented] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn

2021-03-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310358#comment-17310358 ] Bo Cui commented on FLINK-21982: when new configuration, configuration will load core-si

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

2021-03-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310388#comment-17310388 ] Bo Cui commented on FLINK-21981: [~Paul Lin] yes, the current plan is like `export ...`,

[jira] [Created] (FLINK-23174) Log improvement in Task throws Error

2021-06-28 Thread Bo Cui (Jira)
Bo Cui created FLINK-23174: -- Summary: Log improvement in Task throws Error Key: FLINK-23174 URL: https://issues.apache.org/jira/browse/FLINK-23174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-05 Thread Bo Cui (Jira)
Bo Cui created FLINK-21640: -- Summary: Job fails to be submitted in tenant scenario Key: FLINK-21640 URL: https://issues.apache.org/jira/browse/FLINK-21640 Project: Flink Issue Type: Bug Affects

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298764#comment-17298764 ] Bo Cui commented on FLINK-21640: in secure env, multiple users submit jobs on yarn at th

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298792#comment-17298792 ] Bo Cui commented on FLINK-21640: i think root znode should 31 and anyone. 1) all users c

[jira] [Comment Edited] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298792#comment-17298792 ] Bo Cui edited comment on FLINK-21640 at 3/10/21, 12:38 PM: --- i

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

2021-03-11 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300024#comment-17300024 ] Bo Cui commented on FLINK-21640: [~knaufk] hi,can u rerun PR ci for me? because in my pc

[jira] [Created] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

2021-05-07 Thread Bo Cui (Jira)
Bo Cui created FLINK-22602: -- Summary: Upgrade parquet to 1.12.0 due to CVEs Key: FLINK-22602 URL: https://issues.apache.org/jira/browse/FLINK-22602 Project: Flink Issue Type: Bug Component

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

2021-05-09 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341679#comment-17341679 ] Bo Cui commented on FLINK-9844: --- hi [~chesnay]  but after the patch, `flink run -m yarn-cl

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

2021-05-09 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341679#comment-17341679 ] Bo Cui edited comment on FLINK-9844 at 5/10/21, 6:10 AM: - hi [~ch

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

2021-05-09 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341685#comment-17341685 ] Bo Cui commented on FLINK-9844: --- The reason for this exception is that when userCodeClassLo

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

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341739#comment-17341739 ] Bo Cui commented on FLINK-9844: --- yes Do you want to fix it? [~chesnay] > PackagedProgram d

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

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341739#comment-17341739 ] Bo Cui edited comment on FLINK-9844 at 5/10/21, 7:30 AM: - yes Do

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341766#comment-17341766 ] Bo Cui commented on FLINK-19916: yes, when userCodeClassLoader was closed, we had no way

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341796#comment-17341796 ] Bo Cui commented on FLINK-19916: no,  CoreOptions.CHECK_LEAKED_CLASSLOADER is not being

[jira] [Comment Edited] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341796#comment-17341796 ] Bo Cui edited comment on FLINK-19916 at 5/10/21, 9:36 AM: -- no, 

[jira] [Created] (FLINK-24349) Support customized Calalogs via JDBC

2021-09-21 Thread Bo Cui (Jira)
Bo Cui created FLINK-24349: -- Summary: Support customized Calalogs via JDBC Key: FLINK-24349 URL: https://issues.apache.org/jira/browse/FLINK-24349 Project: Flink Issue Type: Bug Components

[jira] [Updated] (FLINK-24349) Support customized Calalogs via JDBC

2021-09-21 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-24349: --- Issue Type: Improvement (was: Bug) > Support customized Calalogs via JDBC > ---

[jira] [Created] (FLINK-23786) Avoid multiple authentication

2021-08-15 Thread Bo Cui (Jira)
Bo Cui created FLINK-23786: -- Summary: Avoid multiple authentication Key: FLINK-23786 URL: https://issues.apache.org/jira/browse/FLINK-23786 Project: Flink Issue Type: Bug Reporter: Bo Cu

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

2021-08-05 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394469#comment-17394469 ] Bo Cui commented on FLINK-22246: i think the issue can be solved in HiveTableUtil#instan

[jira] [Comment Edited] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

2021-08-05 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394469#comment-17394469 ] Bo Cui edited comment on FLINK-22246 at 8/6/21, 3:14 AM: - i also

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

2021-08-06 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395044#comment-17395044 ] Bo Cui commented on FLINK-22246: yes, we can use sessionstate. but i wouldn't recommend

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

2021-08-06 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395045#comment-17395045 ] Bo Cui commented on FLINK-22246: [~lirui] Why dont you need real user? authentication re

[jira] [Comment Edited] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

2021-08-06 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395045#comment-17395045 ] Bo Cui edited comment on FLINK-22246 at 8/7/21, 3:43 AM: - [~liru

[jira] [Created] (FLINK-25169) CsvFileSystemFormatFactory#CsvInputFormat supports recursion

2021-12-05 Thread Bo Cui (Jira)
Bo Cui created FLINK-25169: -- Summary: CsvFileSystemFormatFactory#CsvInputFormat supports recursion Key: FLINK-25169 URL: https://issues.apache.org/jira/browse/FLINK-25169 Project: Flink Issue Type:

[jira] [Created] (FLINK-29127) upgrade to chill java to 0.11.0 and kryo-shaded to 4.0.2

2022-08-28 Thread Bo Cui (Jira)
Bo Cui created FLINK-29127: -- Summary: upgrade to chill java to 0.11.0 and kryo-shaded to 4.0.2 Key: FLINK-29127 URL: https://issues.apache.org/jira/browse/FLINK-29127 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-29127) upgrade to chill java to 0.11.0 and kryo-shaded to 4.0.2

2022-08-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-29127: --- Description: upgrade to chill java to 0.11.0 and kryo-shaded to 4.0.2 My job depends on flink1.15 and hudi

[jira] [Commented] (FLINK-29127) upgrade to chill java to 0.11.0 and kryo-shaded to 4.0.2

2022-08-28 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17596933#comment-17596933 ] Bo Cui commented on FLINK-29127: I will create a pr later > upgrade to chill java to 0.

[jira] [Created] (FLINK-29770) hbase connector supports out-of-order data

2022-10-26 Thread Bo Cui (Jira)
Bo Cui created FLINK-29770: -- Summary: hbase connector supports out-of-order data Key: FLINK-29770 URL: https://issues.apache.org/jira/browse/FLINK-29770 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29435) securityConfiguration supports dynamic configuration

2022-09-27 Thread Bo Cui (Jira)
Bo Cui created FLINK-29435: -- Summary: securityConfiguration supports dynamic configuration Key: FLINK-29435 URL: https://issues.apache.org/jira/browse/FLINK-29435 Project: Flink Issue Type: Improvem

[jira] [Updated] (FLINK-29435) securityConfiguration supports dynamic configuration

2022-09-27 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-29435: --- Description: when different tenants submit jobs using the same _flink-conf.yaml_, the same user is displaye

[jira] [Commented] (FLINK-14304) Avoid task starvation with mailbox

2022-01-19 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478503#comment-17478503 ] Bo Cui commented on FLINK-14304: hi [~arvid]  why add the condition? https://github.com

[jira] [Comment Edited] (FLINK-14304) Avoid task starvation with mailbox

2022-01-19 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478503#comment-17478503 ] Bo Cui edited comment on FLINK-14304 at 1/19/22, 10:01 AM: --- hi

[jira] [Comment Edited] (FLINK-14304) Avoid task starvation with mailbox

2022-01-19 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478503#comment-17478503 ] Bo Cui edited comment on FLINK-14304 at 1/19/22, 10:01 AM: --- hi

[jira] [Created] (FLINK-25835) The task initialization duration is recorded in logs

2022-01-26 Thread Bo Cui (Jira)
Bo Cui created FLINK-25835: -- Summary: The task initialization duration is recorded in logs Key: FLINK-25835 URL: https://issues.apache.org/jira/browse/FLINK-25835 Project: Flink Issue Type: Improvem

[jira] [Comment Edited] (FLINK-25835) The task initialization duration is recorded in logs

2022-01-30 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484481#comment-17484481 ] Bo Cui edited comment on FLINK-25835 at 1/31/22, 12:55 AM: --- [~

[jira] [Commented] (FLINK-25835) The task initialization duration is recorded in logs

2022-01-30 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484481#comment-17484481 ] Bo Cui commented on FLINK-25835: [~yunta] hi  The Task initialization log will only be

[jira] [Commented] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

2022-03-20 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509557#comment-17509557 ] Bo Cui commented on FLINK-24528: +1, the same problem we occurred. > Flink HBase Asyc L

[jira] [Commented] (FLINK-24349) Support customized Calalogs via JDBC

2022-03-20 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509561#comment-17509561 ] Bo Cui commented on FLINK-24349: [~RocMarshal] [~martijnvisser] Okay, you can update it,

[jira] [Created] (FLINK-25535) The JVM parameter does not take effect

2022-01-05 Thread Bo Cui (Jira)
Bo Cui created FLINK-25535: -- Summary: The JVM parameter does not take effect Key: FLINK-25535 URL: https://issues.apache.org/jira/browse/FLINK-25535 Project: Flink Issue Type: Bug Affects Versio

[jira] [Created] (FLINK-25565) Write and Read Parquet INT64 Timestamp

2022-01-07 Thread Bo Cui (Jira)
Bo Cui created FLINK-25565: -- Summary: Write and Read Parquet INT64 Timestamp Key: FLINK-25565 URL: https://issues.apache.org/jira/browse/FLINK-25565 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-25535) The JVM parameter does not take effect

2022-01-08 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui closed FLINK-25535. -- Resolution: Not A Problem > The JVM parameter does not take effect > -- >

[jira] [Commented] (FLINK-25169) CsvFileSystemFormatFactory#CsvInputFormat supports recursion

2022-01-08 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471021#comment-17471021 ] Bo Cui commented on FLINK-25169: [~monster#12]  yes, Recursively reads files in folder

[jira] [Created] (FLINK-26581) Job supports the specified HADOOP_USER_NAME

2022-03-10 Thread Bo Cui (Jira)
Bo Cui created FLINK-26581: -- Summary: Job supports the specified HADOOP_USER_NAME Key: FLINK-26581 URL: https://issues.apache.org/jira/browse/FLINK-26581 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-26581) Job supports the HADOOP_USER_NAME

2022-03-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-26581: --- Summary: Job supports the HADOOP_USER_NAME (was: Job supports the specified HADOOP_USER_NAME) > Job supp

[jira] [Commented] (FLINK-26581) Job supports the HADOOP_USER_NAME

2022-03-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504694#comment-17504694 ] Bo Cui commented on FLINK-26581: HI [~gaborgsomogyi]  >From YARN logci. APPMaster will

[jira] [Commented] (FLINK-26581) Job supports the HADOOP_USER_NAME

2022-03-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504696#comment-17504696 ] Bo Cui commented on FLINK-26581: bq. Not sure what do you expect here to do. In non-secu