[jira] [Created] (FLINK-23886) An exception is thrown out when recover job timers from savepoint file

JING ZHANG created FLINK-23886: -- Summary: An exception is thrown out when recover job timers from savepoint file Key: FLINK-23886 URL: https://issues.apache.org/jira/browse/FLINK-23886 Project: Flink

[jira] [Created] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info

Caizhi Weng created FLINK-23885: --- Summary: DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info Key: FLINK-23885 URL:

[jira] [Created] (FLINK-23884) Fix the concurrent problem between triggering savepoint with drain and finish

Yun Gao created FLINK-23884: --- Summary: Fix the concurrent problem between triggering savepoint with drain and finish Key: FLINK-23884 URL: https://issues.apache.org/jira/browse/FLINK-23884 Project: Flink

[jira] [Created] (FLINK-23883) Following bug fix and code improvement for FLIP-147

Yun Gao created FLINK-23883: --- Summary: Following bug fix and code improvement for FLIP-147 Key: FLINK-23883 URL: https://issues.apache.org/jira/browse/FLINK-23883 Project: Flink Issue Type:

[jira] [Created] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL

Caizhi Weng created FLINK-23882: --- Summary: Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL Key: FLINK-23882 URL:

[jira] [Created] (FLINK-23881) SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result"

Xintong Song created FLINK-23881: Summary: SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result" Key: FLINK-23881 URL: https://issues.apache.org/jira/browse/FLINK-23881 Project:

[jira] [Created] (FLINK-23880) WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure

Xintong Song created FLINK-23880: Summary: WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure Key: FLINK-23880 URL: https://issues.apache.org/jira/browse/FLINK-23880

Re: Were Bundles meant to be internal?

Hi David, According to my understanding, all classes that are not marked are internal classes, and they have no guarantee of compatibility. You'd better copy them for your own use. (Implementing pre-aggregation via the DataStream API using MapBundleFunctions is a good idea) Best, Jingsong On

Re: Re: [DISCUSS] Merge the Last Piece of FLIP-147 After Code Freeze

Very thanks @Xintong and everyone! I'll merge the remaining PRs~ Very sorry for the inconvinient brought. Best, Yun --Original Mail -- Sender:Xintong Song Send Date:Fri Aug 20 09:43:24 2021 Recipients:dev , Yun Gao Subject:Re: [DISCUSS] Merge the Last Piece

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Hi, Leonard Xu Thanks, my mistake. Best, Chuang Li | | Chuang Li | | jasonlee1...@163.com | 签名由网易邮箱大师定制 On 08/20/2021 10:17，Leonard Xu wrote： 在 2021年8月19日，21:42，Chuang Li 写道： The similar document PR[1] you sent me, I found that it is not the same problem. I'm not sure if I

[jira] [Created] (FLINK-23879) Benchmark not compiling

Zhilong Hong created FLINK-23879: Summary: Benchmark not compiling Key: FLINK-23879 URL: https://issues.apache.org/jira/browse/FLINK-23879 Project: Flink Issue Type: Bug

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

> 在 2021年8月19日，21:42，Chuang Li 写道： > > The similar document PR[1] you sent me, I found that it is not the same > problem. I'm not sure if I misunderstood. > I mean the PR fixed the issue you reported and you can take a look when you fix. Best, Leonard

Re: [DISCUSS] Merging FLINK-21867 after feature freeze

I think we are good to go on this, since there's no objections within 48h. Thank you~ Xintong Song On Wed, Aug 18, 2021 at 9:59 AM Xintong Song wrote: > Thanks for the effort, David. > > I think this is indeed isolated and helpful. > > Let's give it 48 hours, and merge it if there's no

Re: [DISCUSS] Merge the Last Piece of FLIP-147 After Code Freeze

I think we are good to go on this, since there's no objections within 48h. Thank you~ Xintong Song On Tue, Aug 17, 2021 at 5:11 PM Xintong Song wrote: > For the record, this has been brought up on the release testing sync > earlier today, without objections from the meeting. Per the

[jira] [Created] (FLINK-23878) Minor improvements to golang sdk

Seth Wiesman created FLINK-23878: Summary: Minor improvements to golang sdk Key: FLINK-23878 URL: https://issues.apache.org/jira/browse/FLINK-23878 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23877) Embedded Pulsar broker backend for testing

Yufan Sheng created FLINK-23877: --- Summary: Embedded Pulsar broker backend for testing Key: FLINK-23877 URL: https://issues.apache.org/jira/browse/FLINK-23877 Project: Flink Issue Type:

Re: [DISCUSS] Backport HybridSource to 1.13.x

PR: https://github.com/apache/flink/pull/16899 On Mon, Aug 16, 2021 at 3:49 PM Thomas Weise wrote: > Hi Arvid, > > I would not recommend to mix minor Flink versions: > > 1. As you said, 1.14 isn't released yet and most users would prefer > to not depend on snapshots > 2. There could be

Re: Were Bundles meant to be internal?

Hi David, Although the original intention of introducing `MapBundleFunction`, `MapBundleOperator`, and `CountBundleTrigger` is to do MiniBatch optimization for Flink SQL, those classes could also be used in DataStream Job. I think it's ok to do local-aggregation optimization based on those classed

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

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 thoughts to help other people to think about these differences. (correct me if those technique details are not right.)

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

Hi, Mingliang and Becket, Thank you for providing a real-world case of heterogeneous topology in the training and inference phase, and Becket has given two options to you to choose. Personally, I think Becket's two options are over-simplified in description, and may be somehow misleading.

Were Bundles meant to be internal?

Most of the table/bundle related classes such as MapBundleFunction, MapBundleOperator, and CountBundleTrigger aren't marked as either @Internal or @Public. What was the intention? I ask because I'm starting to see some interest in using them for implementing pre-aggregation via the DataStream

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Hi, Leonard Xu Thank you for your answers. Maybe I didn’t describe it clearly. I think there is an error here in The following examples show how to run an EXPLAIN statement in TableEnvironment. There is a problem that the')' mabye is missing in the create table statement, for example the

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Hi, Chuang Li Thanks for open the issue, I just reviewed a similar document PR[1] for master branch, maybe you can refer it for branch release-1.13/release-1.12/release-1.11 Best, Leonard [1] https://github.com/apache/flink/pull/16051 > 在 2021年8月19日，18:00，Chuang Li 写道： > > > > Dear all,

[jira] [Created] (FLINK-23876) Remove limitation about JDBC exactly once sink about multiple connections per transaction

Roman Khachatryan created FLINK-23876: - Summary: Remove limitation about JDBC exactly once sink about multiple connections per transaction Key: FLINK-23876 URL:

[jira] [Created] (FLINK-23875) ReducingUpsertSink can loose record during failover

Fabian Paul created FLINK-23875: --- Summary: ReducingUpsertSink can loose record during failover Key: FLINK-23875 URL: https://issues.apache.org/jira/browse/FLINK-23875 Project: Flink Issue

[jira] [Created] (FLINK-23874) JM did not store latest checkpiont id into Zookeeper, silently

Youjun Yuan created FLINK-23874: --- Summary: JM did not store latest checkpiont id into Zookeeper, silently Key: FLINK-23874 URL: https://issues.apache.org/jira/browse/FLINK-23874 Project: Flink

Re:[jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Dear all, I'm very sorry to report twice due to a network issue. Thanks, Chuang Li | | Chuang Li | | jasonlee1...@163.com | 签名由网易邮箱大师定制 On 08/19/2021 17:52，JasonLee (Jira) wrote： JasonLee created FLINK-23872: Summary: The example of EXPLAIN Statements in

[jira] [Created] (FLINK-23873) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

JasonLee created FLINK-23873: Summary: The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing Key: FLINK-23873 URL: https://issues.apache.org/jira/browse/FLINK-23873

[jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

JasonLee created FLINK-23872: Summary: The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing Key: FLINK-23872 URL: https://issues.apache.org/jira/browse/FLINK-23872

[jira] [Created] (FLINK-23871) Dispatcher should handle finishing job exception when recover

Aitozi created FLINK-23871: -- Summary: Dispatcher should handle finishing job exception when recover Key: FLINK-23871 URL: https://issues.apache.org/jira/browse/FLINK-23871 Project: Flink Issue

[jira] [Created] (FLINK-23870) Test the ability for ignoring in-flight data on recovery

Anton Kalashnikov created FLINK-23870: - Summary: Test the ability for ignoring in-flight data on recovery Key: FLINK-23870 URL: https://issues.apache.org/jira/browse/FLINK-23870 Project: Flink

[jira] [Created] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType

Yun Tang created FLINK-23869: Summary: Correct javadoc of ExecutionConfig#registerKryoType Key: FLINK-23869 URL: https://issues.apache.org/jira/browse/FLINK-23869 Project: Flink Issue Type: Bug