[
https://issues.apache.org/jira/browse/FLINK-21094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21094:
---
Description:
Similar to StreamExecTableSourceScan, if a sink table's ddl is
{code:sql}
CREATE TABLE
flinkbot edited a comment on pull request #14732:
URL: https://github.com/apache/flink/pull/14732#issuecomment-765882051
## CI report:
* b866f88656da7ca5f6b962c234f7c2a07d58fe99 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Description:
If a source table's ddl is
{code:sql}
CREATE TABLE MyTable (
a bigint,
b int,
c
flinkbot edited a comment on pull request #14729:
URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004
## CI report:
* ef724e57e7676c154c8f0d6da93a811e9d411051 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21094:
---
Description:
Similar to StreamExecTableSourceScan, if a sink table's ddl is
{code:sql}
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-21094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21094:
---
Description:
Similar to StreamExecTableSourceScan, if a sink table's ddl is
{code:sql}
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Description:
If a table's ddl is
{code:sql}
CREATE TABLE MyTable (
a bigint,
b int,
c varchar
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Description:
If a table's ddl is
{code:sql}
CREATE TABLE MyTable (
a bigint,
b int,
c varchar
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Description:
An StreamExecTableSource can be serialized to json, and the json
The json for
was:
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Fix Version/s: 1.13.0
> Support StreamExecTableSource json serialization/deserialization
> -
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Description: StreamExecTableSource w (was: Stream )
> Support StreamExecTableSource json serializat
[
https://issues.apache.org/jira/browse/FLINK-21093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21093:
---
Description: Stream
> Support StreamExecTableSource json serialization/deserialization
> --
[
https://issues.apache.org/jira/browse/FLINK-21092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-21092:
---
Description:
We will introduce the following methods to support json plan operations in
TableEnviro
flinkbot commented on pull request #14732:
URL: https://github.com/apache/flink/pull/14732#issuecomment-765882051
## CI report:
* b866f88656da7ca5f6b962c234f7c2a07d58fe99 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #14732:
URL: https://github.com/apache/flink/pull/14732#issuecomment-765881797
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 pro
bingfeng2004 opened a new pull request #14732:
URL: https://github.com/apache/flink/pull/14732
**Runtime env:**
flink on yarn
my job is mysql to hive
Hadoop3.0.0 on CDH6.3.2
**Log Details:**
2021-01-21 20:01:46,051 INFO
org.apache.flink.runtime.entrypoint.ClusterEntryp
[
https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19687:
Fix Version/s: 1.13.0
> Support to get execution plan in `StatementSet`
>
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 1a6bd7aa98b649bd119479247d34ea029b8ba636 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-21104:
Affects Version/s: (was: 1.12.0)
1.12.2
> UnalignedCheckpointITCase.execute fai
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-21104:
Fix Version/s: 1.12.2
1.13.0
> UnalignedCheckpointITCase.execute failed with "IllegalSt
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270555#comment-17270555
]
Leonard Xu edited comment on FLINK-21104 at 1/23/21, 5:20 AM:
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
* 38e62f33460561736e7a16e930e2d15376b6
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270555#comment-17270555
]
Leonard Xu commented on FLINK-21104:
I think these fail cases are caused by FLINK-29
flinkbot edited a comment on pull request #14729:
URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004
## CI report:
* 6357401af97f8c268fccb433c81c8a80cfe270d3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14729:
URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004
## CI report:
* 6357401af97f8c268fccb433c81c8a80cfe270d3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270540#comment-17270540
]
Huang Xingbo commented on FLINK-21104:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270538#comment-17270538
]
Huang Xingbo commented on FLINK-21104:
--
cc [~AHeise] [~roman_khachatryan] Could you
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270537#comment-17270537
]
Huang Xingbo commented on FLINK-21104:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-21104:
-
Priority: Blocker (was: Critical)
> UnalignedCheckpointITCase.execute failed with "IllegalState
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270536#comment-17270536
]
Huang Xingbo commented on FLINK-21104:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270535#comment-17270535
]
Huang Xingbo commented on FLINK-17274:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270534#comment-17270534
]
Huang Xingbo commented on FLINK-21104:
--
in release-1.12
[https://dev.azure.com/apa
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-21104:
-
Affects Version/s: 1.12.0
> UnalignedCheckpointITCase.execute failed with "IllegalStateException
Huang Xingbo created FLINK-21104:
Summary: UnalignedCheckpointITCase.execute failed with
"IllegalStateException"
Key: FLINK-21104
URL: https://issues.apache.org/jira/browse/FLINK-21104
Project: Flink
flinkbot edited a comment on pull request #14731:
URL: https://github.com/apache/flink/pull/14731#issuecomment-765816188
## CI report:
* 55181914aaa14c21c84092a79b9acc257d961331 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14731:
URL: https://github.com/apache/flink/pull/14731#issuecomment-765816188
## CI report:
* 55181914aaa14c21c84092a79b9acc257d961331 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-20904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohit Paliwal updated FLINK-20904:
--
Comment: was deleted
(was: * *mvn clean package -DskipTests validate -Dcheck-convergence*
* *
flinkbot commented on pull request #14731:
URL: https://github.com/apache/flink/pull/14731#issuecomment-765812528
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 pro
nicygan opened a new pull request #14731:
URL: https://github.com/apache/flink/pull/14731
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* a4c68763883ef4f3c411fa606d0907ef334a6e76 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* a4c68763883ef4f3c411fa606d0907ef334a6e76 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
* 9bf7f665540235030e0c428a7fd11cf68220
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
* 9bf7f665540235030e0c428a7fd11cf68220
flinkbot edited a comment on pull request #14635:
URL: https://github.com/apache/flink/pull/14635#issuecomment-759750009
## CI report:
* 3618093d3ed7359710c9f73ced3031ff2ab8def8 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-21070.
Fix Version/s: 1.12.2
1.11.4
1.13.0
Resolution: Fixed
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
* 9bf7f665540235030e0c428a7fd11cf68220
[
https://issues.apache.org/jira/browse/FLINK-20904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270401#comment-17270401
]
Mohit Paliwal commented on FLINK-20904:
---
* *mvn clean package -DskipTests validate
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
* e22fbccc6b2b9f0df0d5308974eabc5c30d2
twalthr closed pull request #14720:
URL: https://github.com/apache/flink/pull/14720
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
[
https://issues.apache.org/jira/browse/FLINK-21050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-21050.
Fix Version/s: 1.13.0
Resolution: Fixed
Fixed in 1.13.0: c696f0361c8196e4015922ae5228aeb93e
twalthr closed pull request #14714:
URL: https://github.com/apache/flink/pull/14714
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
sjwiesman commented on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-765647307
@rkhachatryan appreciate the speedy review. I hope I've addressed all your
comments. Please take a look and let me know if you have any other concerns.
-
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562866385
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java
##
@@ -79,6 +81,9 @@
@JsonP
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562860032
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java
##
@@ -79,6 +81,9 @@
@JsonP
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562862511
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
##
@@ -328,6 +329,7 @@ private void
se
twalthr commented on pull request #14714:
URL: https://github.com/apache/flink/pull/14714#issuecomment-765637047
Thanks for the review @sjwiesman. I agree general UDF blog post would be
nice. Better examples are just the beginning ;)
---
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562860032
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java
##
@@ -79,6 +81,9 @@
@JsonP
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562856816
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLoader.java
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed to the Apac
AHeise opened a new pull request #414:
URL: https://github.com/apache/flink-web/pull/414
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 g
flinkbot edited a comment on pull request #14591:
URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239
## CI report:
* 80ea1fb2b7987d406c153526f420e2c73834bea6 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562848702
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
##
@@ -46
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562845447
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/state/CheckpointStorageLoadingTest.java
##
@@ -0,0 +1,228 @@
+/*
+ * Licensed to the
flinkbot edited a comment on pull request #14719:
URL: https://github.com/apache/flink/pull/14719#issuecomment-764631410
## CI report:
* 4197ba5c2e6681045851248a784f79b8ebf9ffdd UNKNOWN
* cc6c13e40d5b3a60ad6c2df1a3a09049f1cded44 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562842079
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLoader.java
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed to the Apac
sjwiesman commented on a change in pull request #13797:
URL: https://github.com/apache/flink/pull/13797#discussion_r562841036
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLoader.java
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-20654:
Release Note:
Using unaligned checkpoints in Flink 1.12.0 combined with two/multiple inputs
tasks
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-20654:
Release Note:
Using UnalignedCheckpoints in Flink 1.12.0 combined with two/multiple inputs
tasks
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-20654.
-
Resolution: Fixed
> Unaligned checkpoint recovery may lead to corrupted data stream
> --
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270361#comment-17270361
]
Arvid Heise commented on FLINK-20654:
-
Merged a fix into master as 5d1c1b145fe2f5d34
AHeise merged pull request #14730:
URL: https://github.com/apache/flink/pull/14730
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 t
flinkbot edited a comment on pull request #14730:
URL: https://github.com/apache/flink/pull/14730#issuecomment-765430097
## CI report:
* 2e0834c84ae2d3bd5597f8f2699f597184fda9bf Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14722:
URL: https://github.com/apache/flink/pull/14722#issuecomment-764831307
## CI report:
* 4979927cd36c67a1a88f8f119a2dd9361b42d452 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
pnowojski commented on pull request #7:
URL: https://github.com/apache/flink-benchmarks/pull/7#issuecomment-76797
Thanks for the changes @Thesharing. I haven't looked at the code at
benchmarks, so it would be great if for example @zhuzhurk could review this.
Besides that, the remaining
flinkbot edited a comment on pull request #14635:
URL: https://github.com/apache/flink/pull/14635#issuecomment-759750009
## CI report:
* 89004265ced3fe4c638a46d58dba64157fa06d08 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270268#comment-17270268
]
Chesnay Schepler edited comment on FLINK-21036 at 1/22/21, 4:50 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270268#comment-17270268
]
Chesnay Schepler commented on FLINK-21036:
--
hmm...for plain docker that certain
[
https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-21103:
-
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1237
Dawid Wysakowicz created FLINK-21103:
Summary: E2e tests time out on azure
Key: FLINK-21103
URL: https://issues.apache.org/jira/browse/FLINK-21103
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #14635:
URL: https://github.com/apache/flink/pull/14635#issuecomment-759750009
## CI report:
* 89004265ced3fe4c638a46d58dba64157fa06d08 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270262#comment-17270262
]
Till Rohrmann commented on FLINK-21036:
---
This is a bit off-topic but I have to adm
[
https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270260#comment-17270260
]
Till Rohrmann commented on FLINK-21008:
---
Wouldn't it work if {{ClusterEntrypoint.c
NicoK commented on pull request #14635:
URL: https://github.com/apache/flink/pull/14635#issuecomment-765514464
So, as soon as we are through the sync phase, we will get stats (if the CP
is aborted during the sync phase, that won't interrupt the sync part anyway and
will wait for it to comp
[
https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270249#comment-17270249
]
Chesnay Schepler commented on FLINK-21036:
--
I'd say so as well.
Users can curr
[
https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-21036:
Assignee: Chesnay Schepler
> Consider removing automatic configuration fo number
[
https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270240#comment-17270240
]
Yang Wang commented on FLINK-21036:
---
So maybe the existing configuration option {{task
[
https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21045:
Fix Version/s: 1.13.0
> Support 'load module' and 'unload module' SQL syntax
> ---
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270227#comment-17270227
]
Jark Wu commented on FLINK-20947:
-
Hi [~weijiaxu], we have fixed this problem in master
[
https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270226#comment-17270226
]
Jark Wu commented on FLINK-20947:
-
Fixed in
- master: 90e680c9c579b2ffa1ca93ad7dfbaa55
wuchong merged pull request #14679:
URL: https://github.com/apache/flink/pull/14679
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
[
https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270224#comment-17270224
]
Yang Wang commented on FLINK-21008:
---
After more consideration, I think it might be wro
flinkbot edited a comment on pull request #14635:
URL: https://github.com/apache/flink/pull/14635#issuecomment-759750009
## CI report:
* 89004265ced3fe4c638a46d58dba64157fa06d08 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10407:
--
Summary: FLIP-159: Reactive mode (was: Reactive mode)
> FLIP-159: Reactive mode
> ---
[
https://issues.apache.org/jira/browse/FLINK-20589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-20589.
-
Resolution: Fixed
All sub tasks have been completed. Closing this ticket. New issues should go
[
https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270216#comment-17270216
]
Till Rohrmann commented on FLINK-15626:
---
[~zhuzh] do we want to remove other parts
Till Rohrmann created FLINK-21102:
-
Summary: Add ScaleUpController
Key: FLINK-21102
URL: https://issues.apache.org/jira/browse/FLINK-21102
Project: Flink
Issue Type: Sub-task
Compon
blublinsky edited a comment on pull request #14629:
URL: https://github.com/apache/flink/pull/14629#issuecomment-765482738
Thanks @wangyang0918,
I did fix owner reference PR
As for this one, its still up to the user to decide how he wants to set
certain parameters - via template or vi
Till Rohrmann created FLINK-21101:
-
Summary: Set up cron job to run CI with declarative scheduler
Key: FLINK-21101
URL: https://issues.apache.org/jira/browse/FLINK-21101
Project: Flink
Issue
blublinsky commented on pull request #14629:
URL: https://github.com/apache/flink/pull/14629#issuecomment-765482738
Thanks @wangyang0918,
I did fix owner reference PR
As for this one, its still up to the user to decide how he wants to set
certain parameters - via template or via addit
Till Rohrmann created FLINK-21100:
-
Summary: Add DeclarativeScheduler skeleton
Key: FLINK-21100
URL: https://issues.apache.org/jira/browse/FLINK-21100
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-21099:
-
Summary: Introduce JobType to distinguish between batch and
streaming jobs
Key: FLINK-21099
URL: https://issues.apache.org/jira/browse/FLINK-21099
Project: Flink
1 - 100 of 199 matches
Mail list logo
