[jira] [Created] (FLINK-30002) Change the alignmentTimeout to alignedCheckpointTimeout

2022-11-11 Thread Rui Fan (Jira)
Rui Fan created FLINK-30002: --- Summary: Change the alignmentTimeout to alignedCheckpointTimeout Key: FLINK-30002 URL: https://issues.apache.org/jira/browse/FLINK-30002 Project: Flink Issue Type:

[jira] [Created] (FLINK-30001) sql-client.sh start failed

2022-11-11 Thread xiaohang.li (Jira)
xiaohang.li created FLINK-30001: --- Summary: sql-client.sh start failed Key: FLINK-30001 URL: https://issues.apache.org/jira/browse/FLINK-30001 Project: Flink Issue Type: Bug

Re: [DISCUSS] Issue tracking workflow

2022-11-11 Thread Martijn Visser
Hi everyone, Unfortunately ASF Infra has already implemented the change and new Jira users can't sign up. I think there is consensus that we shouldn't move from Jira now. My proposal would be to setup a separate mailing list to which users can send their request for an account, which gets sent

Re: [DISCUSS] Allow sharing (RocksDB) memory between slots

2022-11-11 Thread Roman Khachatryan
Hi John, Yun, Thank you for your feedback @John > It seems like operators would either choose isolation for the cluster’s jobs > or they would want to share the memory between jobs. > I’m not sure I see the motivation to reserve only part of the memory for sharing > and allowing jobs to choose

Re: SQL Gateway and SQL Client

2022-11-11 Thread Jim Hughes
Hi Shengkai, I think there is an additional case where a proxy is between the client and gateway. In that case, being able to pass headers would allow for additional options / features. I see several PRs from Yu Zelin. Is there a first one to review? Cheers, Jim On Thu, Nov 10, 2022 at 9:42

[jira] [Created] (FLINK-30000) Introduce FileSystemFactory to create FileSystem from custom configuration

2022-11-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-3: Summary: Introduce FileSystemFactory to create FileSystem from custom configuration Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project:

Re: [DISCUSS] Remove FlinkKafkaConsumer and FlinkKafkaProducer in the master for 1.17 release

2022-11-11 Thread Jing Ge
Hi all, Thank you all for the informative feedback. I figure there is a requirement to improve the documentation wrt the migration from FlinkKafkaConsumer to KafkaSource. I've fired a ticket[1] and connected it with [2]. This shouldn't be the blocker for removing FlinkKafkaConsumer. Given there

[jira] [Created] (FLINK-29999) Improve documentation on how a user should migrate from FlinkKafkaConsumer to KafkaSource

2022-11-11 Thread Jing Ge (Jira)
Jing Ge created FLINK-2: --- Summary: Improve documentation on how a user should migrate from FlinkKafkaConsumer to KafkaSource Key: FLINK-2 URL: https://issues.apache.org/jira/browse/FLINK-2

Re: [DISCUSS] FLIP-268: Rack Awareness for Kafka Sources

2022-11-11 Thread Jeremy DeGroot
Yanfei, You caught a mistake on my part. I referenced the wrong KIP. That one is for Kafka Streams, KIP-36 is the one for the regular client. I'll update the referenced FLIP and its JIRA. This feature is already available in our client, my team at work implemented it against the old Kafka

[jira] [Created] (FLINK-29998) Make the backpressure tab could be sort by the busy percent

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29998: Summary: Make the backpressure tab could be sort by the busy percent Key: FLINK-29998 URL: https://issues.apache.org/jira/browse/FLINK-29998 Project: Flink Issue

[jira] [Created] (FLINK-29997) Link to the taskmanager page in the expired sub-task of checkpoint tab

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29997: Summary: Link to the taskmanager page in the expired sub-task of checkpoint tab Key: FLINK-29997 URL: https://issues.apache.org/jira/browse/FLINK-29997 Project: Flink

[jira] [Created] (FLINK-29996) Link to the task manager's thread dump page in the backpressure tab

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29996: Summary: Link to the task manager's thread dump page in the backpressure tab Key: FLINK-29996 URL: https://issues.apache.org/jira/browse/FLINK-29996 Project: Flink

[jira] [Created] (FLINK-29995) Improve the usability of job analysis for backpressure, expired checkpoints and exceptions

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29995: Summary: Improve the usability of job analysis for backpressure, expired checkpoints and exceptions Key: FLINK-29995 URL: https://issues.apache.org/jira/browse/FLINK-29995

[jira] [Created] (FLINK-29994) Update official document about Lookup Join.

2022-11-11 Thread Hang HOU (Jira)
Hang HOU created FLINK-29994: Summary: Update official document about Lookup Join. Key: FLINK-29994 URL: https://issues.apache.org/jira/browse/FLINK-29994 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29993) Provide more convenient way to programmatically configure reporters

2022-11-11 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29993: Summary: Provide more convenient way to programmatically configure reporters Key: FLINK-29993 URL: https://issues.apache.org/jira/browse/FLINK-29993 Project:

[jira] [Created] (FLINK-29992) Join execution plan parsing error

2022-11-11 Thread HunterXHunter (Jira)
HunterXHunter created FLINK-29992: - Summary: Join execution plan parsing error Key: FLINK-29992 URL: https://issues.apache.org/jira/browse/FLINK-29992 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29991) KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToRemoteService failed

2022-11-11 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29991: -- Summary: KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToRemoteService failed Key: FLINK-29991 URL: https://issues.apache.org/jira/browse/FLINK-29991