Update operation encoding/format

Hi, It's mentioned in the following documentation, https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/formats/canal.html, that "...currently Flink can’t combine UPDATE_BEFORE and UPDATE_AFTER into a single UPDATE message." Can anyone elaborate on this? Was decomposing a

[jira] [Created] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

Chesnay Schepler created FLINK-21589: Summary: Document Table/SQL API limitations regarding upgrades with savepoints Key: FLINK-21589 URL: https://issues.apache.org/jira/browse/FLINK-21589

Re: [VOTE] FLIP-162: Consistent Flink SQL time function behavior

+1 Thanks Leonard for driving this topic. Best, Jingsong On Wed, Mar 3, 2021 at 4:44 PM Kurt Young wrote: > +1 (binding) > > Best, > Kurt > > > On Wed, Mar 3, 2021 at 3:43 PM Timo Walther wrote: > > > +1 (binding) > > > > Regards, > > Timo > > > > On 03.03.21 04:14, Jark Wu wrote: > > > +1

[jira] [Created] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch

Rui Li created FLINK-21592: -- Summary: RemoveSingleAggregateRule fails due to nullability mismatch Key: FLINK-21592 URL: https://issues.apache.org/jira/browse/FLINK-21592 Project: Flink Issue Type:

[jira] [Created] (FLINK-21596) CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail

Guowei Ma created FLINK-21596: - Summary: CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail Key: FLINK-21596 URL: https://issues.apache.org/jira/browse/FLINK-21596 Project:

[jira] [Created] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException"

Guowei Ma created FLINK-21597: - Summary: testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException" Key: FLINK-21597 URL: https://issues.apache.org/jira/browse/FLINK-21597

[jira] [Created] (FLINK-21598) testDetachedModeSecureWithPreInstallKeytab fail

Guowei Ma created FLINK-21598: - Summary: testDetachedModeSecureWithPreInstallKeytab fail Key: FLINK-21598 URL: https://issues.apache.org/jira/browse/FLINK-21598 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21591) Flink using OSS Backend on Native K8S found some errors

yufan wang created FLINK-21591: -- Summary: Flink using OSS Backend on Native K8S found some errors Key: FLINK-21591 URL: https://issues.apache.org/jira/browse/FLINK-21591 Project: Flink Issue

[jira] [Created] (FLINK-21590) Avoid hive logs in the SQL client console

Rui Li created FLINK-21590: -- Summary: Avoid hive logs in the SQL client console Key: FLINK-21590 URL: https://issues.apache.org/jira/browse/FLINK-21590 Project: Flink Issue Type: Improvement

Re: Re: Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished

Hi all, Glad to see convergence here and FLINK-21133: 1. We all prefer single final checkpoint for task not individual checkpoints for each operators. 2. To above goal, if we have to breaking something, we will. 3. Don’t allow recording emitting in `notifyCheckpointComplete`. For “end-flushing”,

[jira] [Created] (FLINK-21593) RocksDBListStatePerformanceTest.testRocksDbListStateAPI fail because of timeout

Guowei Ma created FLINK-21593: - Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPI fail because of timeout Key: FLINK-21593 URL: https://issues.apache.org/jira/browse/FLINK-21593 Project:

Re: [VOTE] FLIP-163: SQL Client Improvements

+1 (non-binding) On Wed, Mar 3, 2021 at 4:44 PM godfrey he wrote: > +1 (binding) > > Best, > Godfrey > > Jark Wu 于2021年3月3日周三 上午10:37写道： > > > +1 to the updated FLIP. > > > > Best, > > Jark > > > > On Wed, 3 Mar 2021 at 10:30, Leonard Xu wrote: > > > > > +1 (non-binding) > > > > > > The

[jira] [Created] (FLINK-21594) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

Bhagi created FLINK-21594: - Summary: Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} Key: FLINK-21594 URL: https://issues.apache.org/jira/browse/FLINK-21594

[jira] [Created] (FLINK-21595) DispatcherResourceManagerComponent.deregisterApplication time-out

Guowei Ma created FLINK-21595: - Summary: DispatcherResourceManagerComponent.deregisterApplication time-out Key: FLINK-21595 URL: https://issues.apache.org/jira/browse/FLINK-21595 Project: Flink

Re: [VOTE] FLIP-163: SQL Client Improvements

Hi, everyone. I'm happy to announce that the FLIP has passed. There are 5 approving votes, 3 of which are binding: * Jark Wu (binding) * Timo Walther (binding) * Rui Li (non-binding) * Leonard Xu (non-binding) * godfrey he (binding) There are no disapproving votes. Thanks everyone's help and

[jira] [Created] (FLINK-21579) Support "SHOW USER FUNCTIONS" statement

Jark Wu created FLINK-21579: --- Summary: Support "SHOW USER FUNCTIONS" statement Key: FLINK-21579 URL: https://issues.apache.org/jira/browse/FLINK-21579 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21580) Remove JobGraph.ScheduleMode

Till Rohrmann created FLINK-21580: - Summary: Remove JobGraph.ScheduleMode Key: FLINK-21580 URL: https://issues.apache.org/jira/browse/FLINK-21580 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21581) Add PublicEvolving to RuntimeContext.jobId

Roman Khachatryan created FLINK-21581: - Summary: Add PublicEvolving to RuntimeContext.jobId Key: FLINK-21581 URL: https://issues.apache.org/jira/browse/FLINK-21581 Project: Flink Issue

[jira] [Created] (FLINK-21582) COALESCE not works when cast a variable return null

Jerry created FLINK-21582: - Summary: COALESCE not works when cast a variable return null Key: FLINK-21582 URL: https://issues.apache.org/jira/browse/FLINK-21582 Project: Flink Issue Type: Bug

Re: [VOTE] FLIP-162: Consistent Flink SQL time function behavior

+1 (binding) Best, Kurt On Wed, Mar 3, 2021 at 3:43 PM Timo Walther wrote: > +1 (binding) > > Regards, > Timo > > On 03.03.21 04:14, Jark Wu wrote: > > +1 (binding) > > > > Best, > > Jark > > > > On Tue, 2 Mar 2021 at 10:42, Leonard Xu wrote: > > > >> Hi all, > >> > >> I would like to start

Re: [VOTE] FLIP-163: SQL Client Improvements

+1 (binding) Best, Godfrey Jark Wu 于2021年3月3日周三 上午10:37写道： > +1 to the updated FLIP. > > Best, > Jark > > On Wed, 3 Mar 2021 at 10:30, Leonard Xu wrote: > > > +1 (non-binding) > > > > The updated FLIP looks well. > > > > Best, > > Leonard > > > > > > > 在 2021年3月2日，22:27，Shengkai Fang 写道： > >

[jira] [Created] (FLINK-21584) Support UNNEST in LEFT JOINs

Nico Kruber created FLINK-21584: --- Summary: Support UNNEST in LEFT JOINs Key: FLINK-21584 URL: https://issues.apache.org/jira/browse/FLINK-21584 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-21585) Provide a configurable way to skip metrics

Ashish Khatkar created FLINK-21585: -- Summary: Provide a configurable way to skip metrics Key: FLINK-21585 URL: https://issues.apache.org/jira/browse/FLINK-21585 Project: Flink Issue Type:

[jira] [Created] (FLINK-21586) Implement ResolvedExpression.asSerializableString for SQL

Timo Walther created FLINK-21586: Summary: Implement ResolvedExpression.asSerializableString for SQL Key: FLINK-21586 URL: https://issues.apache.org/jira/browse/FLINK-21586 Project: Flink

[jira] [Created] (FLINK-21583) Allow comments in CSV format without having to ignore parse errors

Nico Kruber created FLINK-21583: --- Summary: Allow comments in CSV format without having to ignore parse errors Key: FLINK-21583 URL: https://issues.apache.org/jira/browse/FLINK-21583 Project: Flink

退订

退订

Re: [DISCUSS] FLIP-165: Operator's Flame Graphs

This is going to make performance analysis and optimization much more accessible. I can't wait to include this in our training courses. +1 Seth suggested putting the docs for this feature under Operations/Monitoring, but there's already a page in the docs under Operations/Debugging for

Re: [VOTE] FLIP-151: Incremental snapshots for heap-based state backend

+1 (binding) from my side, wish this feature going well! Best, Zhijiang -- From:Piotr Nowojski Send Time:2021年3月2日(星期二) 00:11 To:dev ; roman Subject:Re: [VOTE] FLIP-151: Incremental snapshots for heap-based state backend Thanks

[jira] [Created] (FLINK-21599) execute[Parallel union, p = 10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed because of oom.

Guowei Ma created FLINK-21599: - Summary: execute[Parallel union, p = 10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed because of oom. Key: FLINK-21599 URL:

[jira] [Created] (FLINK-21600) Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test failed

Guowei Ma created FLINK-21600: - Summary: Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test failed Key: FLINK-21600 URL: https://issues.apache.org/jira/browse/FLINK-21600

[jira] [Created] (FLINK-21587) FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources is unstable

Robert Metzger created FLINK-21587: -- Summary: FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources is unstable Key: FLINK-21587 URL: https://issues.apache.org/jira/browse/FLINK-21587

Re: [DISCUSS] FLIP-165: Operator's Flame Graphs

Added docs to the PR. @David, thanks for the tip, it seems like a good place to put them. -- Alexander Fedulov | Solutions Architect Follow us @VervericaData On Wed, Mar 3, 2021 at 12:10 PM David Anderson wrote: > This is going to make performance analysis

[jira] [Created] (FLINK-21588) unable to create catalogs for postgresql

Bhagi created FLINK-21588: - Summary: unable to create catalogs for postgresql Key: FLINK-21588 URL: https://issues.apache.org/jira/browse/FLINK-21588 Project: Flink Issue Type: Bug