[GitHub] [flink] flinkbot edited a comment on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14834: URL: https://github.com/apache/flink/pull/14834#issuecomment-771607546 ## CI report: * 3c55d1b87076148f095c08a55319f1b898dc932d UNKNOWN * 5c8ac11faf9d6fbcad7550bec8abf6a6343347c3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 019646dd12750ec211a543f858836637a164d845 UNKNOWN * 32b4aa620e79c8aee446756a801d68814ddf7b31 UNKNOWN *

[jira] [Commented] (FLINK-20847) Update CompletedCheckpointStore.shutdown() signature

2021-02-09 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282286#comment-17282286 ] Arvid Heise commented on FLINK-20847: - Merged into master as

[jira] [Created] (FLINK-21346) Tasks on AZP should timeout more gracefully

2021-02-09 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-21346: --- Summary: Tasks on AZP should timeout more gracefully Key: FLINK-21346 URL: https://issues.apache.org/jira/browse/FLINK-21346 Project: Flink Issue Type:

[jira] [Commented] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

2021-02-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282282#comment-17282282 ] Jark Wu commented on FLINK-21345: - cc [~Leonard Xu] > NullPointerException >

[GitHub] [flink] LadyForest commented on a change in pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-09 Thread GitBox
LadyForest commented on a change in pull request #14895: URL: https://github.com/apache/flink/pull/14895#discussion_r573502745 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java ## @@ -718,12 +727,20 @@ void

[jira] [Commented] (FLINK-18243) Flink SQL (1.10.0) From Kafkasource can not get data

2021-02-09 Thread victor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282265#comment-17282265 ] victor commented on FLINK-18243: Hi,[~Leonard Xu] I also encountered this problem, when the log

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-09 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282263#comment-17282263 ] Kezhu Wang commented on FLINK-21133: [~becket_qin] Sorry for not aware of your comment, I am writing

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-09 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282253#comment-17282253 ] Kezhu Wang commented on FLINK-21133: Hi all, there are actually two cases for FLIP-27 sources not

[jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

2021-02-09 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-21345: Description: First Step: Create 2 Source Tables as below: {code:java} CREATE TABLE

[jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

2021-02-09 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-21345: Description: First Step: Create 2 Source Tables as below: {code:java} CREATE TABLE

[jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

2021-02-09 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-21345: Description: First Step: Create 2 Source Tables as below: {code:java} CREATE TABLE

[jira] [Created] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

2021-02-09 Thread lynn1.zhang (Jira)
lynn1.zhang created FLINK-21345: --- Summary: NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157 Key: FLINK-21345 URL: https://issues.apache.org/jira/browse/FLINK-21345

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282226#comment-17282226 ] Jiangjie Qin commented on FLINK-21133: -- [~mapohl] [~kezhuw], thanks for digging into the issue. The

[jira] [Closed] (FLINK-21225) OverConvertRule does not consider distinct

2021-02-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21225. --- Fix Version/s: (was: 1.12.3) Resolution: Fixed > OverConvertRule does not consider distinct >

[GitHub] [flink] LadyForest commented on pull request #14877: [FLINK-21225][table] Support OVER window distinct aggregates in Table API

2021-02-09 Thread GitBox
LadyForest commented on pull request #14877: URL: https://github.com/apache/flink/pull/14877#issuecomment-776422330 Sure :) This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-21225) OverConvertRule does not consider distinct

2021-02-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282209#comment-17282209 ] Jark Wu commented on FLINK-21225: - Fixed in - master: 31346e8cdf225bec0ea4745a504c765a1fcc0edf -

[GitHub] [flink] wuchong merged pull request #14877: [FLINK-21225][table] Support OVER window distinct aggregates in Table API

2021-02-09 Thread GitBox
wuchong merged pull request #14877: URL: https://github.com/apache/flink/pull/14877 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

[GitHub] [flink] wuchong commented on pull request #14877: [FLINK-21225][table] Support OVER window distinct aggregates in Table API

2021-02-09 Thread GitBox
wuchong commented on pull request #14877: URL: https://github.com/apache/flink/pull/14877#issuecomment-776421393 Could you also open a pull request for 1.12 branch? This is an automated message from the Apache Git Service.

[GitHub] [flink] LadyForest commented on a change in pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-09 Thread GitBox
LadyForest commented on a change in pull request #14895: URL: https://github.com/apache/flink/pull/14895#discussion_r573428324 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/module/ModuleManagerTest.java ## @@ -0,0 +1,239 @@ +/* + *

[jira] [Updated] (FLINK-21225) OverConvertRule does not consider distinct

2021-02-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21225: Fix Version/s: 1.12.3 1.13.0 > OverConvertRule does not consider distinct >

[GitHub] [flink] wuchong commented on pull request #14896: [FLINK-21176][docs] translate the updates of 'avro-confluent.zh.md' to Chinese

2021-02-09 Thread GitBox
wuchong commented on pull request #14896: URL: https://github.com/apache/flink/pull/14896#issuecomment-776415905 @fsk119 could you help to review this? This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 8add398106b70be6b836c96101bd5cd67ffc5c05 Azure:

[jira] [Comment Edited] (FLINK-20014) Resolve CVE-2020-11022 and CVE-2020-11023 in scala-compiler

2021-02-09 Thread Alan Leong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282202#comment-17282202 ] Alan Leong edited comment on FLINK-20014 at 2/10/21, 3:33 AM: -- This issue

[jira] [Commented] (FLINK-20014) Resolve CVE-2020-11022 and CVE-2020-11023 in scala-compiler

2021-02-09 Thread Alan Leong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282202#comment-17282202 ] Alan Leong commented on FLINK-20014: This issue only affects developers who are building Flink and

[GitHub] [flink] wuchong commented on a change in pull request #14895: [FLINK-21295][table] Support 'useModules' and 'listFullModules' in ModuleManager and TableEnvironment

2021-02-09 Thread GitBox
wuchong commented on a change in pull request #14895: URL: https://github.com/apache/flink/pull/14895#discussion_r573404988 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java ## @@ -718,12 +727,20 @@ void

[GitHub] [flink] zentol commented on a change in pull request #14879: [FLINK-21256][FLINK-21257] Add Restarting and Executing state for declarative scheduler

2021-02-09 Thread GitBox
zentol commented on a change in pull request #14879: URL: https://github.com/apache/flink/pull/14879#discussion_r573420346 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java ## @@ -0,0 +1,415 @@ +/* + *

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

2021-02-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282195#comment-17282195 ] Xintong Song commented on FLINK-11838: -- Well, I guess I see the divergence here. So switching to

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

2021-02-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282191#comment-17282191 ] Xintong Song commented on FLINK-11838: -- Thanks [~galenwarren], h4. Java Serialization According

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

2021-02-09 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282188#comment-17282188 ] Kezhu Wang commented on FLINK-21028: [~trohrmann] [~pnowojski] Thanks for renew, I used to think it

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

2021-02-09 Thread GitBox
KarmaGYZ commented on a change in pull request #14897: URL: https://github.com/apache/flink/pull/14897#discussion_r573402886 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ResourceCounter.java ## @@ -35,11 +37,12 @@ * associated counts. The counts

[jira] [Comment Edited] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2021-02-09 Thread Blake Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282128#comment-17282128 ] Blake Wilson edited comment on FLINK-20060 at 2/10/21, 2:29 AM: Voicing

[jira] [Comment Edited] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2021-02-09 Thread Blake Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282128#comment-17282128 ] Blake Wilson edited comment on FLINK-20060 at 2/10/21, 2:29 AM: Voicing

[jira] [Comment Edited] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2021-02-09 Thread Blake Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282128#comment-17282128 ] Blake Wilson edited comment on FLINK-20060 at 2/10/21, 2:28 AM: Voicing

[jira] [Comment Edited] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2021-02-09 Thread Blake Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282128#comment-17282128 ] Blake Wilson edited comment on FLINK-20060 at 2/10/21, 2:28 AM: Voicing

[jira] [Comment Edited] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2021-02-09 Thread Blake Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282128#comment-17282128 ] Blake Wilson edited comment on FLINK-20060 at 2/10/21, 2:28 AM: Voicing

[jira] [Commented] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

2021-02-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282167#comment-17282167 ] Jark Wu commented on FLINK-20995: - I downgrade the priority to Critical, as this is a known limitation

[jira] [Updated] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

2021-02-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20995: Priority: Critical (was: Blocker) > Calling execute() on org.apache.flink.table.api.Table Throws

[GitHub] [flink] xintongsong edited a comment on pull request #14904: [FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

2021-02-09 Thread GitBox
xintongsong edited a comment on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-775776799 cc @tillrohrmann Could you please take a look at this PR? One thing I'm not entirely sure is that, do we still need a configuration option to fallback to

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

2021-02-09 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] [Commented] (FLINK-10740) FLIP-27: Refactor Source Interface

2021-02-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282147#comment-17282147 ] Jiangjie Qin commented on FLINK-10740: -- [~trohrmann] There are still two things left.  # Add

[GitHub] [flink-web] morsapaes edited a comment on pull request #417: Add blogpost "How to natively deploy Flink on Kubernetes with HA"

2021-02-09 Thread GitBox
morsapaes edited a comment on pull request #417: URL: https://github.com/apache/flink-web/pull/417#issuecomment-776134323 @wangyang0918 , pushed some changes after building to make the blogpost more organized. Also addressed @XComp 's suggestions. The "Rebuild Page" commit should

[jira] [Commented] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2021-02-09 Thread Blake Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282128#comment-17282128 ] Blake Wilson commented on FLINK-20060: -- Voicing support for addressing this. Deserialization with a

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

2021-02-09 Thread Theo Diefenthal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282124#comment-17282124 ] Theo Diefenthal commented on FLINK-21028: - Hi [~pnowojski] , there really isn't anything else in

[jira] [Comment Edited] (FLINK-21028) Streaming application didn't stop properly

2021-02-09 Thread Theo Diefenthal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282124#comment-17282124 ] Theo Diefenthal edited comment on FLINK-21028 at 2/10/21, 12:08 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 8690a60e82f9f67a1c24c6813150d7b15ee7a286 Azure:

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

2021-02-09 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 #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 19d1c1fef8726a2d69bdb9308a8fe7fb7ef3b9fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 6dce6c521bc43eb131fa31226b3d77cffe7377e6 Azure:

[jira] [Commented] (FLINK-17804) Follow the spec when decoding Parquet logical DECIMAL type

2021-02-09 Thread Jeffrey Charles (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282062#comment-17282062 ] Jeffrey Charles commented on FLINK-17804: - Is there any chance that the RowConverter subset of

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 19d1c1fef8726a2d69bdb9308a8fe7fb7ef3b9fc Azure:

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

2021-02-09 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] zentol commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
zentol commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-776259290 If CI passes then I'm OK with merging things as is. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 6dce6c521bc43eb131fa31226b3d77cffe7377e6 Azure:

[GitHub] [flink] sjwiesman commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
sjwiesman commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-776248944 I've rebased and squashed my fixup commits. I will keep monitoring CI to ensure everything passes but if there are not any other issues people view as absolute blockers I

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 6dce6c521bc43eb131fa31226b3d77cffe7377e6 Azure:

[GitHub] [flink] alpinegizmo commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
alpinegizmo commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-776229159 I recommend making this change: ``` diff --git a/docs/assets/_custom.scss b/docs/assets/_custom.scss index f9641bdff3..dfacac7a9b 100644 ---

[GitHub] [flink] flinkbot commented on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
flinkbot commented on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 6dce6c521bc43eb131fa31226b3d77cffe7377e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 19d1c1fef8726a2d69bdb9308a8fe7fb7ef3b9fc Azure:

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

2021-02-09 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] sjwiesman commented on a change in pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
sjwiesman commented on a change in pull request #14903: URL: https://github.com/apache/flink/pull/14903#discussion_r573213182 ## File path: tools/ci/docs.sh ## @@ -17,34 +17,20 @@ # limitations under the License.

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

2021-02-09 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 commented on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
flinkbot commented on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776205983 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-21344) Support switching from/to rocks db with heap timers

2021-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21344: --- Labels: pull-request-available (was: ) > Support switching from/to rocks db with heap

[GitHub] [flink] dawidwys opened a new pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

2021-02-09 Thread GitBox
dawidwys opened a new pull request #14913: URL: https://github.com/apache/flink/pull/14913 ## What is the purpose of the change Does not raw operator state for heap timers in savepoints ## Brief change log See commit messages ## Verifying this change This

[GitHub] [flink] zentol commented on a change in pull request #14879: [FLINK-21256][FLINK-21257] Add Restarting and Executing state for declarative scheduler

2021-02-09 Thread GitBox
zentol commented on a change in pull request #14879: URL: https://github.com/apache/flink/pull/14879#discussion_r573195443 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java ## @@ -0,0 +1,415 @@ +/* + *

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

2021-02-09 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] zentol commented on a change in pull request #14879: [FLINK-21256][FLINK-21257] Add Restarting and Executing state for declarative scheduler

2021-02-09 Thread GitBox
zentol commented on a change in pull request #14879: URL: https://github.com/apache/flink/pull/14879#discussion_r573185606 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java ## @@ -0,0 +1,415 @@ +/* + *

[GitHub] [flink] zentol commented on a change in pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
zentol commented on a change in pull request #14903: URL: https://github.com/apache/flink/pull/14903#discussion_r573180388 ## File path: tools/ci/docs.sh ## @@ -17,34 +17,20 @@ # limitations under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * befba3b9719f5b98f41e3f151054effe16d29ff6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14905: URL: https://github.com/apache/flink/pull/14905#issuecomment-775660513 ## CI report: * af21392f5d4a9eb773c8d3e262920623dd94eeb5 Azure:

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

2021-02-09 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 #14912: [FLINK-21260] Add Finished state for DeclarativeScheduler

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14912: URL: https://github.com/apache/flink/pull/14912#issuecomment-776000316 ## CI report: * 0c9564da608925de95a680c9581f28c672466728 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14911: [FLINK-21337] ComparableInputTypeStrategyTests is not running

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14911: URL: https://github.com/apache/flink/pull/14911#issuecomment-775986848 ## CI report: * 8d3cc2d9d755617fd55f67a12937b60140a74eae UNKNOWN * 7884dac1960519cdf1535a21665cf8534bca6bf0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * b1f16438c2faff148a3df697dfca0fcb7899de92 Azure:

[jira] [Commented] (FLINK-21308) Cancel "sendAfter"

2021-02-09 Thread Stephan Pelikan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281960#comment-17281960 ] Stephan Pelikan commented on FLINK-21308: - I added context methods to provide a message builder

[jira] [Resolved] (FLINK-20847) Update CompletedCheckpointStore.shutdown() signature

2021-02-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-20847. --- Resolution: Fixed > Update CompletedCheckpointStore.shutdown() signature >

[GitHub] [flink] rkhachatryan commented on pull request #14886: [FLINK-20847][checkpointing] Remove unused argument from shutdown() in CompletedCheckpointStore

2021-02-09 Thread GitBox
rkhachatryan commented on pull request #14886: URL: https://github.com/apache/flink/pull/14886#issuecomment-776144356 Thanks for reviewing and merging! This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] AHeise merged pull request #14886: [FLINK-20847][checkpointing] Remove unused argument from shutdown() in CompletedCheckpointStore

2021-02-09 Thread GitBox
AHeise merged pull request #14886: URL: https://github.com/apache/flink/pull/14886 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

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * acf4b4bd601127bb8f089a22d8597cf280faeacf Azure:

[GitHub] [flink-web] morsapaes commented on pull request #417: Add blogpost "How to natively deploy Flink on Kubernetes with HA"

2021-02-09 Thread GitBox
morsapaes commented on pull request #417: URL: https://github.com/apache/flink-web/pull/417#issuecomment-776134323 @wangyang0918 , pushed some changes after building to make the blogpost more organized. Also addressed @XComp 's suggestions. The "Rebuild Page" commit should not be

[GitHub] [flink-web] morsapaes commented on a change in pull request #417: Add blogpost "How to natively deploy Flink on Kubernetes with HA"

2021-02-09 Thread GitBox
morsapaes commented on a change in pull request #417: URL: https://github.com/apache/flink-web/pull/417#discussion_r573115924 ## File path: _posts/2021-02-10-native-k8s-with-ha.md ## @@ -0,0 +1,112 @@ +--- +layout: post +title: "How to natively deploy Flink on Kubernetes with

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * acf4b4bd601127bb8f089a22d8597cf280faeacf Azure:

[jira] [Created] (FLINK-21344) Support switching from/to rocks db with heap timers

2021-02-09 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21344: Summary: Support switching from/to rocks db with heap timers Key: FLINK-21344 URL: https://issues.apache.org/jira/browse/FLINK-21344 Project: Flink

[jira] [Created] (FLINK-21343) Update documentation with possible migration strategies

2021-02-09 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21343: Summary: Update documentation with possible migration strategies Key: FLINK-21343 URL: https://issues.apache.org/jira/browse/FLINK-21343 Project: Flink

[jira] [Closed] (FLINK-21206) Write savepoints in unified format from HeapStateBackend

2021-02-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21206. Resolution: Implemented Implemented via:

[GitHub] [flink] sjwiesman commented on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
sjwiesman commented on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-776111829 @rmetzger thanks for the review. I've fixed the anchor tags for the configuration and the tables. I'm finishing up the licensing right now and will then rebase and squash my

[GitHub] [flink] dawidwys closed pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

2021-02-09 Thread GitBox
dawidwys closed pull request #14809: URL: https://github.com/apache/flink/pull/14809 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

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * acf4b4bd601127bb8f089a22d8597cf280faeacf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14906: [FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFut

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14906: URL: https://github.com/apache/flink/pull/14906#issuecomment-775715265 ## CI report: * 6794a768336ea4af3dcd37eba20a638947819ec3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 1dbb3554f596430930a455ec07e075ce09fffc17 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 2083622d00039a68f8f50d9d6b255d16fe5fbc9c Azure:

[jira] [Commented] (FLINK-21028) Streaming application didn't stop properly

2021-02-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281875#comment-17281875 ] Piotr Nowojski commented on FLINK-21028: [~TheoD], could you post full logs, including those

[GitHub] [flink-web] XComp commented on a change in pull request #417: Add blogpost "How to natively deploy Flink on Kubernetes with HA"

2021-02-09 Thread GitBox
XComp commented on a change in pull request #417: URL: https://github.com/apache/flink-web/pull/417#discussion_r573024550 ## File path: _posts/2021-02-10-native-k8s-with-ha.md ## @@ -0,0 +1,112 @@ +--- +layout: post +title: "How to natively deploy Flink on Kubernetes with HA"

[GitHub] [flink] flinkbot edited a comment on pull request #14903: [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14903: URL: https://github.com/apache/flink/pull/14903#issuecomment-775348759 ## CI report: * 10b2499a2a18cd4ccec518d0aeaf719658036659 UNKNOWN * 1dbb3554f596430930a455ec07e075ce09fffc17 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14902: [FLINK-21138][queryableState] - User ClassLoader in KvStateServerHandler

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14902: URL: https://github.com/apache/flink/pull/14902#issuecomment-775312905 ## CI report: * 7739e63ba32156084a9c9f5dc47d681c62a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 403e8611890fcc2a9cf1907d4e6cc0ea655ca01a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14908: [FLINK-21312][checkpointing] Don't endInput() if stopped externally

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14908: URL: https://github.com/apache/flink/pull/14908#issuecomment-775883728 ## CI report: * 0fa4a24a322b9cc58613be713858956f71256d6b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14907: [FLINK-21315][state-processor-api]allow users to set DataSource operator names

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14907: URL: https://github.com/apache/flink/pull/14907#issuecomment-775874762 ## CI report: * f1faafa2e952e5a1f673cb3b90d08a0938f72130 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14906: [FLINK-21274][runtime] Change the ClusterEntrypoint.runClusterEntrypoint to wait on the result of clusterEntrypoint.getTerminationFut

2021-02-09 Thread GitBox
flinkbot edited a comment on pull request #14906: URL: https://github.com/apache/flink/pull/14906#issuecomment-775715265 ## CI report: * 2bc11585193938b8dbf5b72a16a8ba27fc71da6b Azure:

  1   2   3   >