[jira] [Created] (FLINK-23935) Flink docs

Yao Zhang created FLINK-23935: - Summary: Flink docs Key: FLINK-23935 URL: https://issues.apache.org/jira/browse/FLINK-23935 Project: Flink Issue Type: Bug Components: Documentation

[jira] [Created] (FLINK-23934) table doc timezone page 'table.local-time-zone' Configuration error

simenliuxing created FLINK-23934: Summary: table doc timezone page 'table.local-time-zone' Configuration error Key: FLINK-23934 URL: https://issues.apache.org/jira/browse/FLINK-23934 Project: Flink

[jira] [Created] (FLINK-23933) flink-json formats support a option to parse nested json as a String

Shengnan YU created FLINK-23933: --- Summary: flink-json formats support a option to parse nested json as a String Key: FLINK-23933 URL: https://issues.apache.org/jira/browse/FLINK-23933 Project: Flink

Enable ssl authentication in kafka client

Hello all, I am looking for some pointers to securely connect to kakfa source from a AWS Kinesis Data Analytics Flink application. I found a workaround here, but I was wondering if there was any alternate approach discussed in the flink co

[jira] [Created] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase

Till Rohrmann created FLINK-23932: - Summary: KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase Key: FLINK-23932 URL: https://issues.apache.org/jira/browse/FLINK-23932

[jira] [Created] (FLINK-23931) Format the exception message shown in PythonDriver

Dian Fu created FLINK-23931: --- Summary: Format the exception message shown in PythonDriver Key: FLINK-23931 URL: https://issues.apache.org/jira/browse/FLINK-23931 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-23930) can not open web ui

钟洋洋 created FLINK-23930: --- Summary: can not open web ui Key: FLINK-23930 URL: https://issues.apache.org/jira/browse/FLINK-23930 Project: Flink Issue Type: Technical Debt Components: Deployment

[jira] [Created] (FLINK-23929) Chaining optimization doesn't handle properly for transformations with multiple inputs

Dian Fu created FLINK-23929: --- Summary: Chaining optimization doesn't handle properly for transformations with multiple inputs Key: FLINK-23929 URL: https://issues.apache.org/jira/browse/FLINK-23929 Project:

Re: Scala 2.12 End to End Tests

Thanks Till! +1 making Scala 2.12 the default. I will raise a Jira tomorrow, not at the laptop today. On Mon, 23 Aug 2021, 09:43 Martijn Visser, wrote: > +1 to switch to 2.12 by default > > On Sat, 21 Aug 2021 at 13:43, Chesnay Schepler wrote: > > > I'm with Till that we should switch to 2.12

[jira] [Created] (FLINK-23928) Test the buffer debloating

Anton Kalashnikov created FLINK-23928: - Summary: Test the buffer debloating Key: FLINK-23928 URL: https://issues.apache.org/jira/browse/FLINK-23928 Project: Flink Issue Type: Sub-task

Re: [VOTE] Apache Flink Stateful Functions 3.1.0, release candidate #1

-1 There is an issue with the `go.mod` file which prevents it from properly being released. I have opened a PR[1] . This should not affect testing, this fix is only required to actually publish the release. [1] https://github.com/apache/flink-statefun/pull/260 On Mon, Aug 23, 2021 at 10:38 AM I

[jira] [Created] (FLINK-23927) Fix go.mod file for SDK release

Seth Wiesman created FLINK-23927: Summary: Fix go.mod file for SDK release Key: FLINK-23927 URL: https://issues.apache.org/jira/browse/FLINK-23927 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-23926) change TaxiRide data model to have a single timestamp

David Anderson created FLINK-23926: -- Summary: change TaxiRide data model to have a single timestamp Key: FLINK-23926 URL: https://issues.apache.org/jira/browse/FLINK-23926 Project: Flink Iss

[VOTE] Apache Flink Stateful Functions 3.1.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 3.1.0 of Apache Flink Stateful Functions, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the projec

[jira] [Created] (FLINK-23925) HistoryServer: Archiving job with more than one attempt fails

Robert Metzger created FLINK-23925: -- Summary: HistoryServer: Archiving job with more than one attempt fails Key: FLINK-23925 URL: https://issues.apache.org/jira/browse/FLINK-23925 Project: Flink

[jira] [Created] (FLINK-23924) Distribution is lacking Python Datastream examples

Chesnay Schepler created FLINK-23924: Summary: Distribution is lacking Python Datastream examples Key: FLINK-23924 URL: https://issues.apache.org/jira/browse/FLINK-23924 Project: Flink Is

[jira] [Created] (FLINK-23923) Log command when starting python processes

Chesnay Schepler created FLINK-23923: Summary: Log command when starting python processes Key: FLINK-23923 URL: https://issues.apache.org/jira/browse/FLINK-23923 Project: Flink Issue Type

[jira] [Created] (FLINK-23922) -pyexec is not working correctly

Chesnay Schepler created FLINK-23922: Summary: -pyexec is not working correctly Key: FLINK-23922 URL: https://issues.apache.org/jira/browse/FLINK-23922 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23921) WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable

Yangze Guo created FLINK-23921: -- Summary: WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable Key: FLINK-23921 URL: https://issues.apache.org/jira/browse/FLINK-23921 Project: Flink

[jira] [Created] (FLINK-23920) SchemaTranslator looses primary key if schema is inferred

Timo Walther created FLINK-23920: Summary: SchemaTranslator looses primary key if schema is inferred Key: FLINK-23920 URL: https://issues.apache.org/jira/browse/FLINK-23920 Project: Flink Iss

[jira] [Created] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

Yuval Itzchakov created FLINK-23919: --- Summary: PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF Key: FLINK-23919 URL: https://issues.apache.org/jira/browse/FLINK-23919

[jira] [Created] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

I config auto-compaction=true in filesystem connector, sometimes it will restart and show me exception like this "Caused by: java.io.FileNotFoundException: File does not exist: hdfs://xx/tmp/x/dt=20210823/.uncompacted-part-ef59d89c-36fb-49c5-9b74-dd6a7882ea9f-0-241". And when

[jira] [Created] (FLINK-23917) Project metadata columns to apply to sources which do not implement projection pushdown

Ingo Bürk created FLINK-23917: - Summary: Project metadata columns to apply to sources which do not implement projection pushdown Key: FLINK-23917 URL: https://issues.apache.org/jira/browse/FLINK-23917 Pro

Re: Projection pushdown for metadata columns

Hi Till, it actually seems to be two issues, one is a bug and one would be an improvement (it never worked before). I'll split the tickets later. I'll raise the bug one to Critical since I want to fix it for 1.14, but it was also broken in 1.13 already, so it shouldn't be a blocker. Best Ingo O

Re: Projection pushdown for metadata columns

Does this also affect Flink 1.14.0? If yes, do we want to fix this issue for the upcoming release? If yes, then please make this issue a blocker or at least critical. Cheers, Till On Mon, Aug 23, 2021 at 8:39 AM Ingo Bürk wrote: > Thanks Timo for the confirmation. I've also raised FLINK-23911[1

[jira] [Created] (FLINK-23916) Add documentation for how to configure the CheckpointFailureManager

Till Rohrmann created FLINK-23916: - Summary: Add documentation for how to configure the CheckpointFailureManager Key: FLINK-23916 URL: https://issues.apache.org/jira/browse/FLINK-23916 Project: Flink

[jira] [Created] (FLINK-23915) Propagate unique keys for temporary tables

Timo Walther created FLINK-23915: Summary: Propagate unique keys for temporary tables Key: FLINK-23915 URL: https://issues.apache.org/jira/browse/FLINK-23915 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML)

Thanks for the comments, Fan. Please see the reply inline. On Thu, Aug 19, 2021 at 10:25 PM Fan Hong wrote: > Hi, Becket, > > Many thanks to your detailed review. I agree that it is easier to involve > more people to discuss if fundamental differences are highlighted. > > > Here are some of my t

[jira] [Created] (FLINK-23914) Make connector testing framework more verbose on test failure

Qingsheng Ren created FLINK-23914: - Summary: Make connector testing framework more verbose on test failure Key: FLINK-23914 URL: https://issues.apache.org/jira/browse/FLINK-23914 Project: Flink

Re: Scala 2.12 End to End Tests

+1 to switch to 2.12 by default On Sat, 21 Aug 2021 at 13:43, Chesnay Schepler wrote: > I'm with Till that we should switch to 2.12 by default . > > On 21/08/2021 11:12, Till Rohrmann wrote: > > Hi Danny, > > > > I think in the nightly builds we do run the e2e with Scala 2.12 [1]. The > > way it

[jira] [Created] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

Robert Metzger created FLINK-23913: -- Summary: UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs Key: FLINK-23913 URL: https://issues.apache.org/jira/browse/FLINK-23913 Proj

[jira] [Created] (FLINK-23912) Remove unnecessary "Clearing resource requirements of job"

Yangze Guo created FLINK-23912: -- Summary: Remove unnecessary "Clearing resource requirements of job" Key: FLINK-23912 URL: https://issues.apache.org/jira/browse/FLINK-23912 Project: Flink Issue

Re: [NOTICE] StateFun docs have been migrated to new ASF Buildbot at ci2.apache.org

I'm already in touch with Infra. I have instructed them to switch us to git because it only has upsides. On 23/08/2021 06:58, Tzu-Li (Gordon) Tai wrote: Hi Chesnay, I didn't have plans to migrate the Flink builders, but I'd be happy to take a look. The StateFun builders were migrated as part