[jira] [Created] (FLINK-18415) Support TableResult#collect in the Python Table API to align with the Java Table API

Dian Fu created FLINK-18415: --- Summary: Support TableResult#collect in the Python Table API to align with the Java Table API Key: FLINK-18415 URL: https://issues.apache.org/jira/browse/FLINK-18415 Project: F

Re: Could someone help me to review PR[12727]?

Hi Roc Thanks for your contribution. I've reviewed it and gave some comments. please take a look. thanks Best, Congxian Leonard Xu 于2020年6月23日周二 上午10:23写道： > Hi, Roc > > Thanks for the contribution, I’d like to help review this PR. > > Best, > Leonard Xu

[jira] [Created] (FLINK-18414) Kafka Json connector in Table API support more option

DuBin created FLINK-18414: - Summary: Kafka Json connector in Table API support more option Key: FLINK-18414 URL: https://issues.apache.org/jira/browse/FLINK-18414 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-18413) TableResult.collect should throw exception if user does not enable checkpointing in streaming mode

Caizhi Weng created FLINK-18413: --- Summary: TableResult.collect should throw exception if user does not enable checkpointing in streaming mode Key: FLINK-18413 URL: https://issues.apache.org/jira/browse/FLINK-18413

Re: Could someone help me to review PR[12727]?

Hi, Roc Thanks for the contribution, I’d like to help review this PR. Best, Leonard Xu

[jira] [Created] (FLINK-18412) JdbcFullTest failed to compile on 1.11

Dian Fu created FLINK-18412: --- Summary: JdbcFullTest failed to compile on 1.11 Key: FLINK-18412 URL: https://issues.apache.org/jira/browse/FLINK-18412 Project: Flink Issue Type: Bug Compon

Could someone help me to review PR[12727]?

Hi, all. I have finished the first draft of this translation(https://github.com/apache/flink/pull/12727). Could someone please review it for me? Thank you. Best Roc.

[jira] [Created] (FLINK-18411) release-1.11 compile failed

xiaojin.wy created FLINK-18411: -- Summary: release-1.11 compile failed Key: FLINK-18411 URL: https://issues.apache.org/jira/browse/FLINK-18411 Project: Flink Issue Type: Bug Components:

Re: [DISCUSS] SQL Syntax for Table API StatementSet

+1 to "BEGIN STATEMENT SET; ... END;" syntax. I also think sync/async execution is orthogonal to statement set syntax. This problem still stand there for individual statements. We can discuss this in a separate thread. Best, Jark On Mon, 22 Jun 2020 at 23:23, Fabian Hueske wrote: > Thanks for

Re: [DISCUSS] SQL Syntax for Table API StatementSet

Thanks for the discussion Godfrey and Timo, I like the syntax proposed by Jark and Timo: BEGIN STATEMENT SET; INSERT INTO ...; INSERT INTO ...; END; (I didn't pay attention and didn't mean to propose START over BEGIN. I just wanted to make the point that the syntax should make it clear tha

[DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hello everyone, This is a discussion thread for the FLIP I have recently created: * FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers * https://issues.apache.org/jira/browse/FLINK

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

I'm also +1 for not adding the TEMPORAL keyword. +1 to make the PRIMARY KEY semantic clear for sources. >From my point of view: 1) PRIMARY KEY on changelog souruce: It means that when the changelogs (INSERT/UPDATE/DELETE) are materialized, the materialized table should be unique on the primary ke

Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

Hi all, The previous link [1] for all artifacts in Maven Central Repository missed many artifacts, so we deploy them again by the new link [2]. Sorry for the inconvenience and happy testing again! [1] https://repository.apache.org/content/repositories/orgapacheflink-1374 [2] https://repository.

[jira] [Created] (FLINK-18410) Flink SQL filesystem connector class name correct

dalongliu created FLINK-18410: - Summary: Flink SQL filesystem connector class name correct Key: FLINK-18410 URL: https://issues.apache.org/jira/browse/FLINK-18410 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-18409) The FilterJoinRule.FILTER_ON_JOIN optimizer rule cause 'Join With a Temporal Table' not working properly

Yuhao Zhao created FLINK-18409: -- Summary: The FilterJoinRule.FILTER_ON_JOIN optimizer rule cause 'Join With a Temporal Table' not working properly Key: FLINK-18409 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

Hi Fabian, Thanks for this finding and let us know. I will double check it and update the missing jars afterwards if needed. Best, Zhijiang -- From:Fabian Paul Send Time:2020年6月22日(星期一) 16:55 To:dev Cc:zhijiang ; pnowojski Subj

[jira] [Created] (FLINK-18408) BinaryRowData should use de-/serialization method of MemorySegment with explicit endianness

Yingjie Cao created FLINK-18408: --- Summary: BinaryRowData should use de-/serialization method of MemorySegment with explicit endianness Key: FLINK-18408 URL: https://issues.apache.org/jira/browse/FLINK-18408

[jira] [Created] (FLINK-18407) NPE in SlotPoolImpl.maybeRemapOrphanedAllocation if no pending request is registered

Till Rohrmann created FLINK-18407: - Summary: NPE in SlotPoolImpl.maybeRemapOrphanedAllocation if no pending request is registered Key: FLINK-18407 URL: https://issues.apache.org/jira/browse/FLINK-18407

[DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hello everyone, This is a discussion thread for the FLIP [1] regarding Enhanced Fan Out for AWS Kinesis Consumers. Enhanced Fan Out (EFO) allows AWS Kinesis Data Stream (KDS) consumers to utilise a dedicated read throughput, rather than a shared quota. HTTP/2 reduces latency and typically gives

[jira] [Created] (FLINK-18406) Annotate DualKeyLinkedMap with @Nullable annotation

Till Rohrmann created FLINK-18406: - Summary: Annotate DualKeyLinkedMap with @Nullable annotation Key: FLINK-18406 URL: https://issues.apache.org/jira/browse/FLINK-18406 Project: Flink Issue T

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

Hi everyone, I also agree with Leonard/Kurt's proposal for CREATE TEMPORAL TABLE. Best, Konstantin On Mon, Jun 22, 2020 at 10:53 AM Kurt Young wrote: > I agree with Timo, semantic about primary key needs more thought and > discussion, especially after FLIP-95 and FLIP-105. > > Best, > Kurt >

Re: [DISCUSS] SQL Syntax for Table API StatementSet

Hi Godfrey, 1) Of course we should have unified behavior for API and SQL file. However, this doesn't mean that `executeSql` needs to become blocking or support multi-statements. In a programmatic API, async is more useful as a user can control long running jobs (regardless of batch or streamin

Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

Hi, Thanks for the great efforts in preparing the second rc. I was just going through the published artifacts and it seems that some are missing in the latest release. In comparison you can look at https://repository.apache.org/content/repositories/orgapacheflink-1370/org/apache/flink/

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

I agree with Timo, semantic about primary key needs more thought and discussion, especially after FLIP-95 and FLIP-105. Best, Kurt On Mon, Jun 22, 2020 at 4:45 PM Timo Walther wrote: > Hi Leonard, > > thanks for the summary. > > After reading all of the previous arguments and working on FLIP-9

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

Hi Leonard, thanks for the summary. After reading all of the previous arguments and working on FLIP-95. I would also lean towards the conclusion of not adding the TEMPORAL keyword. After FLIP-95, what we considered as a CREATE TEMPORAL TABLE can be represented as a CREATE TABLE with PRIMARY

[jira] [Created] (FLINK-18405) Add watermark support for unaligned checkpoints

Arvid Heise created FLINK-18405: --- Summary: Add watermark support for unaligned checkpoints Key: FLINK-18405 URL: https://issues.apache.org/jira/browse/FLINK-18405 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-18404) Make unaligned checkpoints rescalable

Arvid Heise created FLINK-18404: --- Summary: Make unaligned checkpoints rescalable Key: FLINK-18404 URL: https://issues.apache.org/jira/browse/FLINK-18404 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18403) Ensure that only exactly once checkpointing can be unaligned

Arvid Heise created FLINK-18403: --- Summary: Ensure that only exactly once checkpointing can be unaligned Key: FLINK-18403 URL: https://issues.apache.org/jira/browse/FLINK-18403 Project: Flink I

[ANNOUNCE] Weekly Community Update 2020/25

Dear community, happy to share this week's community update: release testing for Flink 1.11.0 is slowly converging, and the first feature discussions for the upcoming release cycle are coming up. Flink Development == * [releases] The community has published another non-voting release