[jira] [Created] (FLINK-32738) PROTOBUF format supports projection push down

xiaogang zhou created FLINK-32738: - Summary: PROTOBUF format supports projection push down Key: FLINK-32738 URL: https://issues.apache.org/jira/browse/FLINK-32738 Project: Flink Issue Type: S

Re: Heartbeat of TaskManager with id container

Hi ynagireddy4u, We have met this exception before. Usually it is caused by following reasons: 1), TaskManager is too busy with other works to send the heartbeat to JobMaster or TaskManager process might already exited; 2), There might be a network issues between this TaskManager and JobMaster; 3

Re: FLINK-20767 - Support for nested fields filter push down

Hi Jark, If the FieldReferenceExpression contains an int[] to support a nested field reference, List (or FieldReferenceExpression[]) and int[][] are actually equivalent. If we are designing this from scratch, personally I prefer using List for consistency, i.e. always resolving everything to expre

[jira] [Created] (FLINK-32737) Add support for Snowflake sink connector

Mohsen Rezaei created FLINK-32737: - Summary: Add support for Snowflake sink connector Key: FLINK-32737 URL: https://issues.apache.org/jira/browse/FLINK-32737 Project: Flink Issue Type: New Fe

[VOTE] FLIP-333: Redesign Apache Flink website

Hi, Thank you all for your feedback on FLIP-333. I’d like to start a vote. Discussion thread: https://lists.apache.org/thread/z9j0rqt61ftgbkr37gzwbjg0n4fl1hsf FLIP: https://cwiki.apache.org/confluence/display/FLINK/FLIP-333%3A+Redesign+Apache+Flink+website Thanks, Deepthi

[jira] [Created] (FLINK-32736) Add a post to announce new connectors and connector externalisation

Elphas Toringepi created FLINK-32736: Summary: Add a post to announce new connectors and connector externalisation Key: FLINK-32736 URL: https://issues.apache.org/jira/browse/FLINK-32736 Project:

[RESULT][VOTE] FLIP-347: Remove IOReadableWritable serialization in Path

Hi all, Thanks everyone for your review and the votes! I am happy to announce that FLIP-347: Remove IOReadableWritable serialization in Path [1] has been accepted. There are 4 binding votes and 2 non-binding vote [2]: - Weijie Guo (binding) - Xintong Song (binding) - Matthias Pohl (binding) - Ji

[RESULT][VOTE] FLIP-344: Remove parameter in RichFunction#open

Hi all, Thanks everyone for your review and the votes! I am happy to announce that FLIP-344: Remove parameter in RichFunction#open [1] has been accepted. There are 4 binding votes and 2 non-binding vote [2]: - Weijie Guo (binding) - Xintong Song (binding) - Jing Ge (binding) - Yuxin Tan - Ron L

[RESULT][VOTE] FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

Hi all, Thanks everyone for your review and the votes! I am happy to announce that FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger() [1] has been accepted. There are 4 binding votes and 2 non-binding vote [2]: - Weijie Guo (binding) - Xintong Song (binding) - Matthias Pohl (bindin

[jira] [Created] (FLINK-32735) Flink SQL Gateway for Native Kubernetes Application Mode

Junyao Huang created FLINK-32735: Summary: Flink SQL Gateway for Native Kubernetes Application Mode Key: FLINK-32735 URL: https://issues.apache.org/jira/browse/FLINK-32735 Project: Flink Iss

[jira] [Created] (FLINK-32734) Add .mvn/maven.config to .gitignore

Matthias Pohl created FLINK-32734: - Summary: Add .mvn/maven.config to .gitignore Key: FLINK-32734 URL: https://issues.apache.org/jira/browse/FLINK-32734 Project: Flink Issue Type: Improvement

Re: FLINK-20767 - Support for nested fields filter push down

Hi, I agree with Becket that we may need to extend FieldReferenceExpression to support nested field access (or maybe a new NestedFieldReferenceExpression). But I have some concerns about evolving the SupportsProjectionPushDown.applyProjection. A projection is much simpler than Filter Expression wh

[jira] [Created] (FLINK-32733) Add Transformer for FpGrowth

Yindi Wang created FLINK-32733: -- Summary: Add Transformer for FpGrowth Key: FLINK-32733 URL: https://issues.apache.org/jira/browse/FLINK-32733 Project: Flink Issue Type: New Feature Co

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.6.0, release candidate #1

+1 (binding) - Verified checksums and signatures, binaries, licenses - Tested release helm chart, docker image - Verified doc build, links - Ran basic stateful example, upgrade, savepoint. Checked logs, no errors Gyula On Mon, Jul 31, 2023 at 2:24 PM Maximilian Michels wrote: > +1 (binding) >

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

Hi Jing, Matt and Jark, Thanks for reviewing this FLIP and sorry for the late reply. I tried to benchmark the POC code of this FLIP on the TPC-DS benchmark, but it seems that the performance improvement is smaller than the benchmark framework's fluctuations, so that the improvement is barely obser

[jira] [Created] (FLINK-32732) auto offset reset should be exposed to user

xiaogang zhou created FLINK-32732: - Summary: auto offset reset should be exposed to user Key: FLINK-32732 URL: https://issues.apache.org/jira/browse/FLINK-32732 Project: Flink Issue Type: Imp

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

Hi Timo, Thanks for starting the discussion! System columns are no doubt a good boost on Flink SQL’s usability, and I see the feedbacks are mainly concerns about the accessibility of system columns. I think most of the concerns could be solved by clarifying the ownership of the system columns. D