[jira] [Created] (FLINK-28748) Translate "SELECT DISTINCT" page into Chinese

2022-07-29 Thread liujingmao (Jira)
liujingmao created FLINK-28748: -- Summary: Translate "SELECT DISTINCT" page into Chinese Key: FLINK-28748 URL: https://issues.apache.org/jira/browse/FLINK-28748 Project: Flink Issue Type:

[RESULT][VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-29 Thread godfrey he
Hi, everyone. FLIP-248: Introduce dynamic partition pruning[1] has been accepted. There are 4 binding votes, 1 non-binding votes[2]. - Jing Ge(non-binging) - Yun Gao(binding) - Jark Wu(binding) - Jingsong Li(binding) - Jing Zhang(binding) None against. Thanks again for every one who concerns

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-29 Thread bo zhaobo
Hi all Thank you very much for all of your kind votes. The voting time for FLIP-250[1] has reached the end of time since we set it up on this Monday(7/25). I'm closing it now. There were 7 votes(+1), 4 of them are binding votes: - Yang Wang (binding) - Martijn Visser (binding) - Kelu Tao

[jira] [Created] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

2022-07-29 Thread Stephan Weinwurm (Jira)
Stephan Weinwurm created FLINK-28747: Summary: "target_id can not be missing" in HTTP statefun request Key: FLINK-28747 URL: https://issues.apache.org/jira/browse/FLINK-28747 Project: Flink

Re: [DISCUSS] FLIP-238: Introduce FLIP-27-based Data Generator Source

2022-07-29 Thread Alexander Fedulov
A quick update: - Since there is currently another initiative ongoing for building rate limiting that potentially covers a wider range of use cases, it was decided not to expose the RateLimiter API publicly in this FLIP. It now has a package private visibility and can later be swapped with a more

[jira] [Created] (FLINK-28746) Add test for sequential read

2022-07-29 Thread Jane Chan (Jira)
Jane Chan created FLINK-28746: - Summary: Add test for sequential read Key: FLINK-28746 URL: https://issues.apache.org/jira/browse/FLINK-28746 Project: Flink Issue Type: Sub-task

[GitHub] [flink-connector-redis] MartijnVisser merged pull request #4: [hotfix] Add CI and label configurator

2022-07-29 Thread GitBox
MartijnVisser merged PR #4: URL: https://github.com/apache/flink-connector-redis/pull/4 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-28745) Support DataStream PythonCoProcessOperator and PythonKeyedCoProcessOperator in Thread Mode

2022-07-29 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28745: Summary: Support DataStream PythonCoProcessOperator and PythonKeyedCoProcessOperator in Thread Mode Key: FLINK-28745 URL: https://issues.apache.org/jira/browse/FLINK-28745

[jira] [Created] (FLINK-28744) Upgrade Calcite version to 1.31

2022-07-29 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28744: -- Summary: Upgrade Calcite version to 1.31 Key: FLINK-28744 URL: https://issues.apache.org/jira/browse/FLINK-28744 Project: Flink Issue Type: Technical

[GitHub] [flink-connector-redis] eskabetxe opened a new pull request, #3: [FLINK-15571] Add Redis sink

2022-07-29 Thread GitBox
eskabetxe opened a new pull request, #3: URL: https://github.com/apache/flink-connector-redis/pull/3 Add basic RedisSink based on AsyncSinkWriter As Jedis dont have a async call, it was implemented. Maybe better choice was to use lettuce or Redisson libs.. Need to be added a

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

2022-07-29 Thread Qingsheng Ren
Hi Mason, Thank you for starting this FLIP! From my first glance this FLIP looks like a collection of many new interfaces, but I can’t stitch them together. It’ll be great to have some brief descriptions about how the source works internally. Here are some questions in my mind and please

[jira] [Created] (FLINK-28743) Support validating the determinism for StreamPhysicalMatchRecognize

2022-07-29 Thread lincoln lee (Jira)
lincoln lee created FLINK-28743: --- Summary: Support validating the determinism for StreamPhysicalMatchRecognize Key: FLINK-28743 URL: https://issues.apache.org/jira/browse/FLINK-28743 Project: Flink

[jira] [Created] (FLINK-28742) Table.to_pandas fails with lit("xxx")

2022-07-29 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-28742: -- Summary: Table.to_pandas fails with lit("xxx") Key: FLINK-28742 URL: https://issues.apache.org/jira/browse/FLINK-28742 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28741) Unexpected result if insert 'false' to boolean column

2022-07-29 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-28741: -- Summary: Unexpected result if insert 'false' to boolean column Key: FLINK-28741 URL: https://issues.apache.org/jira/browse/FLINK-28741 Project: Flink Issue

[jira] [Created] (FLINK-28740) Support CsvBulkWriter in PyFlink

2022-07-29 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28740: - Summary: Support CsvBulkWriter in PyFlink Key: FLINK-28740 URL: https://issues.apache.org/jira/browse/FLINK-28740 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28739) Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data

2022-07-29 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28739: - Summary: Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data Key: FLINK-28739 URL: https://issues.apache.org/jira/browse/FLINK-28739

[jira] [Created] (FLINK-28738) [doc] Add a user doc about the correctness for non-deterministic updates

2022-07-29 Thread lincoln lee (Jira)
lincoln lee created FLINK-28738: --- Summary: [doc] Add a user doc about the correctness for non-deterministic updates Key: FLINK-28738 URL: https://issues.apache.org/jira/browse/FLINK-28738 Project: