[jira] [Created] (FLINK-23029) Extend PluginLoader to allow closing of backing ClassLoader

2021-06-17 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23029: Summary: Extend PluginLoader to allow closing of backing ClassLoader Key: FLINK-23029 URL: https://issues.apache.org/jira/browse/FLINK-23029 Project: Flink

[jira] [Created] (FLINK-23028) Improve documentation for pages of SQL.

2021-06-17 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-23028: --- Summary: Improve documentation for pages of SQL. Key: FLINK-23028 URL: https://issues.apache.org/jira/browse/FLINK-23028 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23027) Move chill dependency to flink-scala

2021-06-17 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23027: Summary: Move chill dependency to flink-scala Key: FLINK-23027 URL: https://issues.apache.org/jira/browse/FLINK-23027 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-23026) OVER WINDOWS function lost data

2021-06-17 Thread MOBIN (Jira)
MOBIN created FLINK-23026: - Summary: OVER WINDOWS function lost data Key: FLINK-23026 URL: https://issues.apache.org/jira/browse/FLINK-23026 Project: Flink Issue Type: Bug Components: Table

Re: Re: [ANNOUNCE] New PMC member: Xintong Song

2021-06-17 Thread Yu Li
Congratulations, Xintong! Best Regards, Yu On Thu, 17 Jun 2021 at 15:23, Yuan Mei wrote: > Congratulations, Xintong :-) > > On Thu, Jun 17, 2021 at 11:57 AM Xingbo Huang wrote: > > > Congratulations, Xintong! > > > > Best, > > Xingbo > > > > Yun Gao 于2021年6月17日周四 上午10:46写道: > > > > > Congrat

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-17 Thread Austin Cawley-Edwards
Hi all, Sorry to be joining the conversation late. I'm also on the side of Konstantin, generally, in that this seems to not be a core goal of Flink as a project and adds a maintenance burden. Would another con of Kerberos be that is likely a fading project in terms of network security? (serious q

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-17 Thread Till Rohrmann
I left some comments in the Google document. It would be great if someone from the community with security experience could also take a look at it. Maybe Eron you have an opinion on the topic. Cheers, Till On Thu, Jun 17, 2021 at 6:57 PM Till Rohrmann wrote: > Hi Gabor, > > I haven't found time

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-17 Thread Till Rohrmann
Hi Gabor, I haven't found time to look into the updated FLIP yet. I'll try to do it asap. Cheers, Till On Wed, Jun 16, 2021 at 9:35 PM Konstantin Knauf wrote: > Hi Gabor, > > > However representing Kerberos as completely new feature is not true > because > it's already in since Flink makes aut

[jira] [Created] (FLINK-23025) sink-buffer-max-rows and sink-buffer-flush-interval options produce a lot of duplicates

2021-06-17 Thread Johannes Moser (Jira)
Johannes Moser created FLINK-23025: -- Summary: sink-buffer-max-rows and sink-buffer-flush-interval options produce a lot of duplicates Key: FLINK-23025 URL: https://issues.apache.org/jira/browse/FLINK-23025

[jira] [Created] (FLINK-23024) RPC result TaskManagerInfoWithSlots not serializable

2021-06-17 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-23024: --- Summary: RPC result TaskManagerInfoWithSlots not serializable Key: FLINK-23024 URL: https://issues.apache.org/jira/browse/FLINK-23024 Project: Flink Issue Type

Re: Output from RichAsyncFunction on failure

2021-06-17 Thread Arvid Heise
Hi Satish, usually you would side-outputs [1] for that but afaik asyncIO doesn't support that (yet). So your option works well to use some union type. You can then chain a map function that uses side-outputs. [1] https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/side_outp

Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

2021-06-17 Thread 徐小龙
Hi, all: When we consume multiplue topic in one flinkKafkaConsumer, each topic partition count is less than the parallelism of the consumer, there is a problem we encounted is that, currently the partitionAssigner can evenly assign partition of one topic to subtask, but the assignment

join example in batch mode using DataStream API

2021-06-17 Thread Etienne Chauchot
Hi all, In case it is useful to people: I was testing new DataStream convergent batch/streaming API and join did not work in batch mode : https://issues.apache.org/jira/browse/FLINK-22587 I had to manually code an inner join using *KeyedCoProcessFunction* and *states*. Here is an example of

[jira] [Created] (FLINK-23023) Support offset in window TVF

2021-06-17 Thread JING ZHANG (Jira)
JING ZHANG created FLINK-23023: -- Summary: Support offset in window TVF Key: FLINK-23023 URL: https://issues.apache.org/jira/browse/FLINK-23023 Project: Flink Issue Type: Sub-task Compo

Re: [DISCUSS] Feedback Collection Jira Bot

2021-06-17 Thread Piotr Nowojski
Hi, I also think that the bot is a bit too aggressive/too quick with assigning stale issues/deprioritizing them, but that's not that big of a deal for me. What bothers me much more is that it's closing minor issues automatically. Depriotising issues makes sense to me. If a wish for improvement or

[jira] [Created] (FLINK-23022) Plugin classloader settings do not work as described

2021-06-17 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23022: Summary: Plugin classloader settings do not work as described Key: FLINK-23022 URL: https://issues.apache.org/jira/browse/FLINK-23022 Project: Flink

[jira] [Created] (FLINK-23021) Check if the restarted job topology is consistent on restart

2021-06-17 Thread Yun Gao (Jira)
Yun Gao created FLINK-23021: --- Summary: Check if the restarted job topology is consistent on restart Key: FLINK-23021 URL: https://issues.apache.org/jira/browse/FLINK-23021 Project: Flink Issue Typ

[jira] [Created] (FLINK-23020) NullPointerException when running collect from Python API

2021-06-17 Thread Jira
Maciej Bryński created FLINK-23020: -- Summary: NullPointerException when running collect from Python API Key: FLINK-23020 URL: https://issues.apache.org/jira/browse/FLINK-23020 Project: Flink

[jira] [Created] (FLINK-23019) Avoid errors when identifiers use reserved keywords

2021-06-17 Thread Timo Walther (Jira)
Timo Walther created FLINK-23019: Summary: Avoid errors when identifiers use reserved keywords Key: FLINK-23019 URL: https://issues.apache.org/jira/browse/FLINK-23019 Project: Flink Issue Typ

[jira] [Created] (FLINK-23018) TTL state factory should handle extended state descriptors

2021-06-17 Thread Yun Tang (Jira)
Yun Tang created FLINK-23018: Summary: TTL state factory should handle extended state descriptors Key: FLINK-23018 URL: https://issues.apache.org/jira/browse/FLINK-23018 Project: Flink Issue Type

来自chenxuying的邮件

2021-06-17 Thread chenxuying

[jira] [Created] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

2021-06-17 Thread Daniel Lenz (Jira)
Daniel Lenz created FLINK-23017: --- Summary: HELP in sql-client still shows the removed SOURCE functionality Key: FLINK-23017 URL: https://issues.apache.org/jira/browse/FLINK-23017 Project: Flink

Re: Re: [ANNOUNCE] New PMC member: Xintong Song

2021-06-17 Thread Yuan Mei
Congratulations, Xintong :-) On Thu, Jun 17, 2021 at 11:57 AM Xingbo Huang wrote: > Congratulations, Xintong! > > Best, > Xingbo > > Yun Gao 于2021年6月17日周四 上午10:46写道: > > > Congratulations, Xintong! > > > > Best, > > Yun > > > > > > ---

Re: Re: [ANNOUNCE] New PMC member: Arvid Heise

2021-06-17 Thread Arvid Heise
Thank you for your trust and support. Arvid On Thu, Jun 17, 2021 at 8:39 AM Roman Khachatryan wrote: > Congratulations! > > Regards, > Roman > > On Thu, Jun 17, 2021 at 5:56 AM Xingbo Huang wrote: > > > > Congratulations, Arvid! > > > > Best, > > Xingbo > > > > Yun Tang 于2021年6月17日周四 上午10:49写