[jira] [Created] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

Sergio Sainz created FLINK-31974: Summary: JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler Key: FLINK-31974 URL: https://issues.apache.org/jira/browse/FLINK-31974

Re: [DISCUSS] Planning Flink 2.0

Hi all, Great discussion! For what it's worth, my experience has been that Semantic Versioning is really the best way to think about major releases. It can occasionally be nice to have a big "marketing release" to celebrate a major improvement, but coupling the concept of big improvements to m

Re: [DISCUSS] EncodingFormat and DecondingFormat provide copy API

Hi Tanjialiang, Like we discussed in another thread, please feel free to create a FLIP and start further discussion. In case you need any access right to the wiki page, please let me know, thanks. Best regards, Jing On Sun, Apr 23, 2023 at 4:23 AM tanjialiang wrote: > Hi, devs. > Do anyone ha

[jira] [Created] (FLINK-31973) Introduce Managed table support in glue catalog

Samrat Deb created FLINK-31973: -- Summary: Introduce Managed table support in glue catalog Key: FLINK-31973 URL: https://issues.apache.org/jira/browse/FLINK-31973 Project: Flink Issue Type: Sub-t

Re: [Discussion] - Release major Flink version to support JDK 17 (LTS)

If breaking savepoint compatibility will be eventually an option, I would recommend to try to upgrade Flink's Scala even to *2.13* Best regards, Alexey On Fri, Apr 28, 2023 at 10:22 AM Chesnay Schepler wrote: > We don't know yet. I wanted to run some more experiments to see if I cant > get Scal

[jira] [Created] (FLINK-31972) Remove powermock whitebox usages

Chesnay Schepler created FLINK-31972: Summary: Remove powermock whitebox usages Key: FLINK-31972 URL: https://issues.apache.org/jira/browse/FLINK-31972 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31971) Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest

Chesnay Schepler created FLINK-31971: Summary: Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest Key: FLINK-31971 URL: https://issues.apache.org/jira/browse/FLINK-31971 Project: Flink

Re: Re: Re: [DISCUSS] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

Hi Mang, Boundedness and execution modes are two orthogonal concepts. Since atomic CTAS will be only supported for bounded data, which means it does not depend on the execution modes. I was wondering if it is possible to only provide (or call) twoPhaseCreateTable for bounded data (in both streamin

[jira] [Created] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

Yordan Pavlov created FLINK-31970: - Summary: "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction Key: FLINK-31970 URL: https://issues.apache.org/jira/browse/FLINK-31970 Project: Flin

[DISCUSS] SqlClient gateway mode: support for URLs

I would like to discuss the current implementation of the SQL Gateway support in SQL Cli Client and how it can be improved. 1) *hosname:port/v1 vs https://hostname:port/flink-clusters/session-cluster-1/v1 * Currently, the *--endpoint* parameter needs to be specified in the *InetSocketAddress* for

Re: [DISCUSS] Planning Flink 2.0

Hi, As far as I am concerned, it would be great to build two top level categories for Flink 2.0 release. 1. Future - mainly new big features or architecture improvements to achieve visions like streamhouse. This makes the 2.0 release be the 2.0 instead of 1.x release, i.e. the real intention of 2

[jira] [Created] (FLINK-31969) Remove all local recovery files immediately when local recovery fail

Yanfei Lei created FLINK-31969: -- Summary: Remove all local recovery files immediately when local recovery fail Key: FLINK-31969 URL: https://issues.apache.org/jira/browse/FLINK-31969 Project: Flink

[jira] [Created] (FLINK-31968) [PyFlink] 1.17.0 version on M1 processor

Yury Smirnov created FLINK-31968: Summary: [PyFlink] 1.17.0 version on M1 processor Key: FLINK-31968 URL: https://issues.apache.org/jira/browse/FLINK-31968 Project: Flink Issue Type: Bug

Re: [Discussion] - Release major Flink version to support JDK 17 (LTS)

We don't know yet. I wanted to run some more experiments to see if I cant get Scala 2.12.7 working on Java 17. If that doesn't work, then it would also be an option to bump Scala in the Java 17 builds (breaking savepoint compatibility), and users should just only use the Java APIs. The alter

[jira] [Created] (FLINK-31967) SQL with LAG function NullPointerException

padavan created FLINK-31967: --- Summary: SQL with LAG function NullPointerException Key: FLINK-31967 URL: https://issues.apache.org/jira/browse/FLINK-31967 Project: Flink Issue Type: Bug Co

Re: [DISCUSS] Planning Flink 2.0

Thanks all for the positive feedback. So far, it seems to me that the differences of opinions are mainly focused on whether we should include non-breaking features in the 2.0 release. There seems to be no objections to: 1. Starting to plan for the 2.0 release, with a rough timeline towards mid ne

Re: [DISCUSS] Planning Flink 2.0

@Weike, Thanks for the suggestion. I think it makes sense to provide a longer supporting period for the last 1.x release. @David, I can see the benefit of focusing on breaking changes and API clean-ups only, so the community can be more focused and possibly deliver the 2.0 release earlier. Howev

[jira] [Created] (FLINK-31966) Flink Kubernetes operator lacks TLS support

Adrian Vasiliu created FLINK-31966: -- Summary: Flink Kubernetes operator lacks TLS support Key: FLINK-31966 URL: https://issues.apache.org/jira/browse/FLINK-31966 Project: Flink Issue Type: