[jira] [Created] (FLINK-29346) File naming configuration for filesink output

2022-09-19 Thread Kwang-in (Dennis) JUNG (Jira)
Kwang-in (Dennis) JUNG created FLINK-29346: -- Summary: File naming configuration for filesink output Key: FLINK-29346 URL: https://issues.apache.org/jira/browse/FLINK-29346 Project: Flink

Re: Kubernetes Operator 1.2.0 release

2022-09-19 Thread Yang Wang
Thanks Gyula for managing the release. +1 for the time schedule. Best, Yang Őrhidi Mátyás 于2022年9月19日周一 22:28写道: > Thanks Gyula! > > Sounds good! Happy to help as always. > > Cheers, > Matyas > > On Mon, Sep 19, 2022 at 1:37 PM Gyula Fóra wrote: > > > Hi Devs! > > > > The originally

[jira] [Created] (FLINK-29345) Too many open files in table store orc writer

2022-09-19 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29345: Summary: Too many open files in table store orc writer Key: FLINK-29345 URL: https://issues.apache.org/jira/browse/FLINK-29345 Project: Flink Issue Type:

[jira] [Created] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management

2022-09-19 Thread Xintong Song (Jira)
Xintong Song created FLINK-29344: Summary: Make Adaptive Scheduler supports Fine-Grained Resource Management Key: FLINK-29344 URL: https://issues.apache.org/jira/browse/FLINK-29344 Project: Flink

[jira] [Created] (FLINK-29343) Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement

2022-09-19 Thread luoyuxia (Jira)
luoyuxia created FLINK-29343: Summary: Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement Key: FLINK-29343 URL: https://issues.apache.org/jira/browse/FLINK-29343 Project:

Re: [VOTE] Release 1.14.6, release candidate #2

2022-09-19 Thread Jingsong Li
+1 (binding) - Check if checksums and GPG files match the corresponding release files - Verify that the source archives do not contains any binaries - Build the source with Maven - Check that POM files point to the same version - Started session cluster and SQL-Client Best, Jingsong On Thu, Sep

Re: [DISCUSS] Restructure FLIP pages with page properties

2022-09-19 Thread weijie guo
+1 Thanks for proposing that, Chesnay. It is really too complicated to manually update the overview page of FLIP, especially if it needs to be updated more than once. Best regards, Weijie Sergey Nuyanzin 于2022年9月19日周一 20:57写道: > Thanks for the proposal and for driving this Chesnay! > It

[jira] [Created] (FLINK-29342) Do not query writer.length() per record in RollingFileWriter

2022-09-19 Thread Jane Chan (Jira)
Jane Chan created FLINK-29342: - Summary: Do not query writer.length() per record in RollingFileWriter Key: FLINK-29342 URL: https://issues.apache.org/jira/browse/FLINK-29342 Project: Flink

Re: [Discuss] Let's Session Cluster JobManager take a breather (FLIP-257: Flink JobManager Process Split)

2022-09-19 Thread Shammon FY
Thanks @XintongSong and sorry for replying late. Also thanks Zhengyu for bringing this discussion up. We use flink session cluster to run olap queries in ByteDance, and have supported several users in production. The maximum single cluster has 2000 cores, and we focus on the job scheduling

[jira] [Created] (FLINK-29341) Upgrade Apache Kafka version to 7.1.1-ccs to resolve CVE-2021-38153

2022-09-19 Thread Sanjay Nathani (Jira)
Sanjay Nathani created FLINK-29341: -- Summary: Upgrade Apache Kafka version to 7.1.1-ccs to resolve CVE-2021-38153 Key: FLINK-29341 URL: https://issues.apache.org/jira/browse/FLINK-29341 Project:

[jira] [Created] (FLINK-29340) ResourceManagerTest#testProcessResourceRequirementsWhenRecoveryFinished prone to race condition

2022-09-19 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29340: Summary: ResourceManagerTest#testProcessResourceRequirementsWhenRecoveryFinished prone to race condition Key: FLINK-29340 URL:

[jira] [Created] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

2022-09-19 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29339: Summary: JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread Key: FLINK-29339 URL:

[jira] [Created] (FLINK-29338) Try to unify observe/deploy config handling in the operator

2022-09-19 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-29338: -- Summary: Try to unify observe/deploy config handling in the operator Key: FLINK-29338 URL: https://issues.apache.org/jira/browse/FLINK-29338 Project: Flink

Re: Kubernetes Operator 1.2.0 release

2022-09-19 Thread Őrhidi Mátyás
Thanks Gyula! Sounds good! Happy to help as always. Cheers, Matyas On Mon, Sep 19, 2022 at 1:37 PM Gyula Fóra wrote: > Hi Devs! > > The originally planned (October 1) release date for 1.2.0 is fast > approaching and we are already slightly behind schedule. There are a couple > outstanding bug

Re: Metrics for ElasticsearchSink and JdbcTableSource

2022-09-19 Thread Martijn Visser
Hi Satish, The Elasticsearch sink uses the new Sink, so the only possible metrics that it can send by default are the ones documented in FLIP-33 [1]. Since the JDBC connector doesn't use these interfaces, I don't think these metrics are available out of the box. Best regards, Martijn [1]

Re: [DISCUSS] TLS issues

2022-09-19 Thread Martijn Visser
Hi Jean-Damien, One of the volunteers from the Flink Community needs to review your PR and if accepted, then it can be merged by a committer. I'll see if I can find a contributor who can help out here. Best regards, Martijn Op ma 19 sep. 2022 om 15:29 schreef Jean-Damien Hatzenbuhler : >

Re: [DISCUSS] TLS issues

2022-09-19 Thread Jean-Damien Hatzenbuhler
Hello, I have proposed a PR for https://issues.apache.org/jira/browse/FLINK-28520. What is the process after that ? Regards, On Tue, Jul 19, 2022 at 5:21 PM Jean-Damien Hatzenbuhler < jean-damien.hatzenbuh...@contentsquare.com> wrote: > Hello Martijn, > > Thank you I will propose PRs to correct

Re: [DISCUSS] Restructure FLIP pages with page properties

2022-09-19 Thread Sergey Nuyanzin
Thanks for the proposal and for driving this Chesnay! It already looks much better. There are some thoughts about that. The list of FLIPs that appears in the menu as part of the FLIP overview [1] exceeds 200 now which results in Confluence applying pagination. Users have to click an additional

[jira] [Created] (FLINK-29337) Fix fail to use HiveDialect for non-hive table

2022-09-19 Thread luoyuxia (Jira)
luoyuxia created FLINK-29337: Summary: Fix fail to use HiveDialect for non-hive table Key: FLINK-29337 URL: https://issues.apache.org/jira/browse/FLINK-29337 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29336) SubtaskState#discardState swallows exceptions

2022-09-19 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29336: - Summary: SubtaskState#discardState swallows exceptions Key: FLINK-29336 URL: https://issues.apache.org/jira/browse/FLINK-29336 Project: Flink Issue Type:

[jira] [Created] (FLINK-29335) OperatorSubtaskState swallows exception

2022-09-19 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29335: - Summary: OperatorSubtaskState swallows exception Key: FLINK-29335 URL: https://issues.apache.org/jira/browse/FLINK-29335 Project: Flink Issue Type:

[jira] [Created] (FLINK-29334) StateHandleStore#releaseAndTryRemoveAll is not used and can be removed

2022-09-19 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29334: - Summary: StateHandleStore#releaseAndTryRemoveAll is not used and can be removed Key: FLINK-29334 URL: https://issues.apache.org/jira/browse/FLINK-29334 Project:

Kubernetes Operator 1.2.0 release

2022-09-19 Thread Gyula Fóra
Hi Devs! The originally planned (October 1) release date for 1.2.0 is fast approaching and we are already slightly behind schedule. There are a couple outstanding bug tickets with 2 known blockers at the moment that should be fixed in the next few days. As we are not aware of any larger critical

[jira] [Created] (FLINK-29333) Flink SQL Planner Module doesn't read config from flink-conf.yaml

2022-09-19 Thread Dhananjay Badaya (Jira)
Dhananjay Badaya created FLINK-29333: Summary: Flink SQL Planner Module doesn't read config from flink-conf.yaml Key: FLINK-29333 URL: https://issues.apache.org/jira/browse/FLINK-29333 Project:

[jira] [Created] (FLINK-29332) Flink SQL Planner Module doesn't read config from flink-conf.yaml

2022-09-19 Thread Dhananjay Badaya (Jira)
Dhananjay Badaya created FLINK-29332: Summary: Flink SQL Planner Module doesn't read config from flink-conf.yaml Key: FLINK-29332 URL: https://issues.apache.org/jira/browse/FLINK-29332 Project:

Re: [DISCUSS] FLIP-260: Expose Finish Method For UserDefinedFunction

2022-09-19 Thread Lincoln Lee
Hi Jingsong, Thank you for participating this discussion! For the method name, I think we should follow the new finish() method in `StreamOperator`, the BoundedOneInput might be removed in the future as discussed [1] before [1] https://lists.apache.org/thread/3ozw653ql8jso9w55p4pw8p4909trvkb

[jira] [Created] (FLINK-29331) pre-aggregated merge supports changelog inputs

2022-09-19 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29331: Summary: pre-aggregated merge supports changelog inputs Key: FLINK-29331 URL: https://issues.apache.org/jira/browse/FLINK-29331 Project: Flink Issue Type:

[jira] [Created] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

2022-09-19 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29330: Summary: Provide better logs of MiniCluster shutdown procedure Key: FLINK-29330 URL: https://issues.apache.org/jira/browse/FLINK-29330 Project: Flink

Re: [VOTE] FLIP-254 Redis Streams connector

2022-09-19 Thread Jingsong Li
+1 (binding) Best, Jingsong On Mon, Sep 19, 2022 at 2:20 PM Yu Li wrote: > > +1 (binding) > > Thanks for the clarification Martijn. I'd suggest considering adding a note > in the FLIP document (since the proposed repository name for this connector > is "flink-connector-redis") or changing the

Re: [DISCUSS] Restructure FLIP pages with page properties

2022-09-19 Thread Chesnay Schepler
I've finished the restructuring over the weekend. @Ryan: I haven't organized FLIPs by topic, but it's possible to do that, either via labels or by adding a sort of "Topic/Component" field to the page properties and filtering on that. If someone wants to do that go ahead, I don't wanna see

Re: [VOTE] FLIP-254 Redis Streams connector

2022-09-19 Thread Yu Li
+1 (binding) Thanks for the clarification Martijn. I'd suggest considering adding a note in the FLIP document (since the proposed repository name for this connector is "flink-connector-redis") or changing the repository name to "flink-connector-redis-streams". Best Regards, Yu On Thu, 15 Sept