[jira] [Comment Edited] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294981#comment-17294981 ] Andy edited comment on FLINK-21553 at 3/4/21, 4:23 AM: --- [~jark] [~dwysakowicz]

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21553: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] beyond1920 opened a new pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
beyond1920 opened a new pull request #15081: URL: https://github.com/apache/flink/pull/15081 ## What is the purpose of the change This pull request aims to fix a minor bug in WTF which may cause unstable output. ## Brief change log - Update CombineRecordsFunction to

[GitHub] [flink] flinkbot edited a comment on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest and AbstractFineGrainedSlotManagerITCase

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790241029 ## CI report: * ac7a34047e2ffe43d2b6c42f233ac6e908e0ba84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15067: URL: https://github.com/apache/flink/pull/15067#issuecomment-789445509 ## CI report: * 2748160748dcde3538202320ec4b87e5d07b775f Azure:

[jira] [Commented] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294981#comment-17294981 ] Andy commented on FLINK-21553: -- [~jark] [~dwysakowicz] [~guoweima] Now when flush buffer to state,

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21553: - Attachment: image-2021-03-04-12-08-07-097.png > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21553: - Attachment: image-2021-03-04-12-07-53-566.png > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21553: - Attachment: image-2021-03-04-12-05-59-802.png > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[GitHub] [flink] flinkbot edited a comment on pull request #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15067: URL: https://github.com/apache/flink/pull/15067#issuecomment-789445509 ## CI report: * 2748160748dcde3538202320ec4b87e5d07b775f Azure:

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

2021-03-03 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294977#comment-17294977 ] Kezhu Wang commented on FLINK-21581: [~roman_khachatryan] [~chesnay] Sorry for boring and 

[jira] [Commented] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

2021-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294967#comment-17294967 ] Dian Fu commented on FLINK-21559: - cc [~hxbks2ks] [~csq] Could you help to take a look at this issue? >

[GitHub] [flink] becketqin commented on pull request #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-03 Thread GitBox
becketqin commented on pull request #15067: URL: https://github.com/apache/flink/pull/15067#issuecomment-790263763 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Description: version: flink 1.12.0 environment: Native Kubernetes mode: Application Mode

[GitHub] [flink] flinkbot edited a comment on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest and AbstractFineGrainedSlotManagerITCase

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790241029 ## CI report: * ac7a34047e2ffe43d2b6c42f233ac6e908e0ba84 Azure:

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Description: Flink run on Native Kubernetes Application Mode Using OSS as the backend. When the

[GitHub] [flink] flinkbot edited a comment on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-787621304 ## CI report: * a1687a0edd159a5b8be339a59c08a79ddfee5069 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 3c6faab2158753198d35dafaeb8d857b88e94f75 Azure:

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Description: Flink run on Native Kubernetes Application Mode Using OSS as the backend. When the

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Description: Flink run on Native Kubernetes Application Mode Using OSS as the backend. When the

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Priority: Blocker (was: Major) > Flink using OSS Backend on Native K8S found some errors >

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Description: Flink run on Native Kubernetes Application Mode Using OSS as the backend. When the

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

2021-03-03 Thread yufan wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yufan wang updated FLINK-21591: --- Description: Flink run on Native Kubernetes Application Mode Using OSS as the backend. When the

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

2021-03-03 Thread yufan wang (Jira)
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

[GitHub] [flink] flinkbot edited a comment on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-787621304 ## CI report: * a1687a0edd159a5b8be339a59c08a79ddfee5069 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest and AbstractFineGrainedSlotManagerITCase

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790241029 ## CI report: * ac7a34047e2ffe43d2b6c42f233ac6e908e0ba84 Azure:

[GitHub] [flink] dianfu merged pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

2021-03-03 Thread GitBox
dianfu merged pull request #14741: URL: https://github.com/apache/flink/pull/14741 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

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

2021-03-03 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21590: --- Description: In {{log4j-cli.properties}} we configure all logs from {{org.apache.hadoop}} to the console.

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

2021-03-03 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21590: --- Fix Version/s: 1.13.0 > Avoid hive logs in the SQL client console >

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

2021-03-03 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21590: --- Description: In {{log4j-cli.properties}} we configure all logs from {{org.apache.hadoop}} to the console.

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

2021-03-03 Thread Rui Li (Jira)
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

[GitHub] [flink] ruanhang1993 commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-03-03 Thread GitBox
ruanhang1993 commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-790247456 > @ruanhang1993 Many thanks for finding issues of this PR. > I tried to solve two issues you raised. > > 1. Regarding the first issue, I relocate protobuf package

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294959#comment-17294959 ] Kezhu Wang commented on FLINK-21564: [~nicholasjiang] I guess the procedure you draw will fail in

[GitHub] [flink] wangyang0918 commented on pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

2021-03-03 Thread GitBox
wangyang0918 commented on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-790244744 @zentol so could you help with the merging? This is an automated message from the Apache Git Service. To

[GitHub] [flink] TsReaper commented on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

2021-03-03 Thread GitBox
TsReaper commented on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-790241807 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest#testNot…

2021-03-03 Thread GitBox
flinkbot commented on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790241029 ## CI report: * ac7a34047e2ffe43d2b6c42f233ac6e908e0ba84 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * d71b3928ea04131827c25a5b62d1ed7b954616ce Azure:

[GitHub] [flink] flinkbot commented on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest#testNot…

2021-03-03 Thread GitBox
flinkbot commented on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790235280 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

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

2021-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21587: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] KarmaGYZ opened a new pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest#testNot…

2021-03-03 Thread GitBox
KarmaGYZ opened a new pull request #15080: URL: https://github.com/apache/flink/pull/15080 …ificationAboutNotEnoughResources ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * d71b3928ea04131827c25a5b62d1ed7b954616ce Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource an

2021-03-03 Thread GitBox
godfreyhe commented on a change in pull request #15062: URL: https://github.com/apache/flink/pull/15062#discussion_r586983114 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/RexNodeExtractor.scala ## @@ -108,18

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

2021-03-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21587: Assignee: Yangze Guo >

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

2021-03-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294935#comment-17294935 ] Yangze Guo commented on FLINK-21587: Thanks for the report [~rmetzger]. I think this issue might

[GitHub] [flink] flinkbot edited a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * 91cd7acb32af72a0f4d1aba2735fb9e7c4130eff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * 91cd7acb32af72a0f4d1aba2735fb9e7c4130eff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] zhuzhurk removed a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
zhuzhurk removed a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789985723 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

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

2021-03-03 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294915#comment-17294915 ] tim yu commented on FLINK-21579: +1 > Support "SHOW USER FUNCTIONS" statement >

[GitHub] [flink] zhuzhurk removed a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
zhuzhurk removed a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789590074 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[jira] [Issue Comment Deleted] (FLINK-21579) Support "SHOW USER FUNCTIONS" statement

2021-03-03 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tim yu updated FLINK-21579: --- Comment: was deleted (was: [~jark] Could you assign this issue to me?) > Support "SHOW USER FUNCTIONS"

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 67dc4c992e8d8ab9e0185475cbed0244a66e3d8a Azure:

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

2021-03-03 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294912#comment-17294912 ] tim yu commented on FLINK-21579: [~jark] Could you assign this issue to me? > Support "SHOW USER

[GitHub] [flink] becketqin commented on pull request #15051: [FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSch

2021-03-03 Thread GitBox
becketqin commented on pull request #15051: URL: https://github.com/apache/flink/pull/15051#issuecomment-790188517 @lindong28 Thanks for the patch. LGTM. Since the patch is mostly based on my original PR, it would be good to see if @StephanEwen also wants to take a look.

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * ecdc2416f67f8cf580a65b30374c1a0bc08b1c0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15066: [FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15066: URL: https://github.com/apache/flink/pull/15066#issuecomment-789284217 ## CI report: * 8e15f3bd752fe7d7074199e0f7a73ce8f2a55032 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15066: [FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15066: URL: https://github.com/apache/flink/pull/15066#issuecomment-789284217 ## CI report: * 8e15f3bd752fe7d7074199e0f7a73ce8f2a55032 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * Unknown: [CANCELED](TBD) * 3c6faab2158753198d35dafaeb8d857b88e94f75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

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

2021-03-03 Thread Chesnay Schepler (Jira)
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

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * Unknown: [CANCELED](TBD) * 3c6faab2158753198d35dafaeb8d857b88e94f75 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * Unknown: [CANCELED](TBD) * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 0bdf39c89c435be70d1e71e86cfe37b068172b8d Azure:

[GitHub] [flink] afedulov commented on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

2021-03-03 Thread GitBox
afedulov commented on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-790112482 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-772060196 ## CI report: * 0bdf39c89c435be70d1e71e86cfe37b068172b8d Azure:

[jira] [Commented] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

2021-03-03 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294844#comment-17294844 ] Roman Khachatryan commented on FLINK-21351: --- No, I don't plan to backport the fix to 1.11 

[jira] [Updated] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

2021-03-03 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21351: -- Fix Version/s: (was: 1.11.4) > Incremental checkpoint data would be lost once a

[GitHub] [flink] rkhachatryan commented on pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on pull request #14839: URL: https://github.com/apache/flink/pull/14839#issuecomment-790083287 Thanks for the review @pnowojski. I've addressed your comments. This is an automated message from the

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586804898 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,230 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586800116 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,230 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586798054 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,230 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586793689 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,230 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586770926 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,230 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586770926 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,230 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586768213 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeSet.java ## @@ -0,0 +1,235 @@ +/* + * Licensed to

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586762491 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeStore.java ## @@ -0,0 +1,153 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586761361 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeStore.java ## @@ -0,0 +1,153 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * d71b3928ea04131827c25a5b62d1ed7b954616ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * 062b00b1d7630ebec00e4892195a0ac94824884b Azure:

[jira] [Commented] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

2021-03-03 Thread Ufuk Celebi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294788#comment-17294788 ] Ufuk Celebi commented on FLINK-21351: - [~roman_khachatryan] The ticket includes fixVersion 1.11.4.

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586670165 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeStore.java ## @@ -0,0 +1,153 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * 91cd7acb32af72a0f4d1aba2735fb9e7c4130eff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15066: [FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15066: URL: https://github.com/apache/flink/pull/15066#issuecomment-789284217 ## CI report: * 8e15f3bd752fe7d7074199e0f7a73ce8f2a55032 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * 062b00b1d7630ebec00e4892195a0ac94824884b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * 91cd7acb32af72a0f4d1aba2735fb9e7c4130eff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14950: URL: https://github.com/apache/flink/pull/14950#issuecomment-780431068 ## CI report: * 1b43a411d22af19f12f14a79c1094c8dc5cfeb42 UNKNOWN * 44ee00afbd5ab0c81c53ed5787e7c0701b711e41 UNKNOWN *

[GitHub] [flink] zhuzhurk commented on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
zhuzhurk commented on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789985723 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586693462 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeStore.java ## @@ -0,0 +1,153 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586670165 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeStore.java ## @@ -0,0 +1,153 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586657095 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeStore.java ## @@ -0,0 +1,153 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
rkhachatryan commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586654458 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeSet.java ## @@ -0,0 +1,235 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #15051: [FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializat

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15051: URL: https://github.com/apache/flink/pull/15051#issuecomment-787785303 ## CI report: * 07fd78a374e504f5d0d931a3582d12c08370cbc8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 60e427103cca73ac1fc29fb18893e3996edb1c7a UNKNOWN * cbaf10a07272ce5b3019e98a51cb0ef7f1cdd86b Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

2021-03-03 Thread GitBox
tillrohrmann commented on a change in pull request #15071: URL: https://github.com/apache/flink/pull/15071#discussion_r586627040 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java ## @@ -248,9 +250,24 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15076: [FLINK-21580] Remove ScheduleMode

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15076: URL: https://github.com/apache/flink/pull/15076#issuecomment-789638861 ## CI report: * 91cd97d31c016875a0cbbbc0b21b5fd74cb9af08 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15006: URL: https://github.com/apache/flink/pull/15006#issuecomment-785114095 ## CI report: * 4cd5563d44a62aec2b8db80cfe8da650fddf4ffa UNKNOWN * f13e54215fb6fbf668f8a51ccbec7f62d835a542 Azure:

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

2021-03-03 Thread Bhagi (Jira)
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

[GitHub] [flink] pnowojski commented on a change in pull request #14839: [FLINK-21353][state] Add DFS-based StateChangelog

2021-03-03 Thread GitBox
pnowojski commented on a change in pull request #14839: URL: https://github.com/apache/flink/pull/14839#discussion_r586375585 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeSet.java ## @@ -0,0 +1,235 @@ +/* + * Licensed to the

<    1   2   3   4   5   >