carp84 commented on pull request #12736:
URL: https://github.com/apache/flink/pull/12736#issuecomment-648026402
@Myasuka Since Robert is on vacation, please help do the manual check and
post the result here. Thanks.
This is
[
https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-17800:
--
Priority: Critical (was: Blocker)
Downgrade to Critical after some offline discussion, will try best to make
rkhachatryan commented on pull request #12686:
URL: https://github.com/apache/flink/pull/12686#issuecomment-648024815
Breaking this PR into smaller pieces (1st - #12751)
This is an automated message from the Apache Git
rkhachatryan closed pull request #12686:
URL: https://github.com/apache/flink/pull/12686
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
rkhachatryan opened a new pull request #12751:
URL: https://github.com/apache/flink/pull/12751
## What is the purpose of the change
Currently, if failureManager is notified about a failure that it has already
seen after a successful checkpoint, it will count it again.
This PR
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444089370
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java
##
@@ -145,28 +168,55 @@ public void
godfreyhe edited a comment on pull request #12728:
URL: https://github.com/apache/flink/pull/12728#issuecomment-648020411
> They are rather confused about having no output by default.
agree with you, for 1.11, we throw an exception if checkpoint is not enabled
for streaming query.
[
https://issues.apache.org/jira/browse/FLINK-18313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18313.
---
Resolution: Fixed
- master (1.12.0): da6867347cd243479de558eed0d8949b5d2e2e48
- 1.11.0:
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444047393
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##
@@ -705,7 +705,7 @@
wuchong merged pull request #12666:
URL: https://github.com/apache/flink/pull/12666
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
godfreyhe commented on pull request #12728:
URL: https://github.com/apache/flink/pull/12728#issuecomment-648020411
> They are rather confused about having no output by default.
agree with you, for 1.11, we throw an exception if checkpoint is not enabled
for streaming query.
[
https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142784#comment-17142784
]
Leonard Xu commented on FLINK-18371:
Hi, [~caoshaokan]
The release-1.11.0-rc1 has been canceled,
godfreyhe commented on a change in pull request #12750:
URL: https://github.com/apache/flink/pull/12750#discussion_r444081509
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
##
@@ -71,9 +75,23 @@ class
[
https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142776#comment-17142776
]
Echo Lee commented on FLINK-18211:
--
We can see the BlobLibraryCacheManager#createUserCodeClassLoader
[
https://issues.apache.org/jira/browse/FLINK-18380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-18380.
Fix Version/s: 1.12.0
Resolution: Fixed
Fixed in 1.12.0:
[
https://issues.apache.org/jira/browse/FLINK-18360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-18360:
Assignee: Jindrich Vimr
> Flink History Server doesn't show correctly table of
[
https://issues.apache.org/jira/browse/FLINK-18360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18360:
-
Fix Version/s: 1.12.0
> Flink History Server doesn't show correctly table of Completed
[
https://issues.apache.org/jira/browse/FLINK-18066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142773#comment-17142773
]
Timo Walther commented on FLINK-18066:
--
[~wangsong] feel free to open an issue for translating the
[
https://issues.apache.org/jira/browse/FLINK-18360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-18360.
Resolution: Fixed
master: efcc5434dd744ad547999e970c00142a9b20e914
> Flink History
zentol merged pull request #12704:
URL: https://github.com/apache/flink/pull/12704
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-18066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-18066.
Fix Version/s: 1.11.0
Resolution: Fixed
Fixed in 1.12.0:
[
https://issues.apache.org/jira/browse/FLINK-18360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18360:
-
Component/s: (was: Runtime / Web Frontend)
Runtime / REST
> Flink
flinkbot edited a comment on pull request #12737:
URL: https://github.com/apache/flink/pull/12737#issuecomment-647407770
## CI report:
* cccbc2294423fce32765002c73acbb06b5ed40a4 UNKNOWN
* f009270ba46fafe795a77626ed0acbb50389d4c2 Azure:
flinkbot edited a comment on pull request #12727:
URL: https://github.com/apache/flink/pull/12727#issuecomment-647010602
## CI report:
* fa86190a4d00a4fab6bc9ed0fe9d592b0aa56745 Azure:
flinkbot edited a comment on pull request #12728:
URL: https://github.com/apache/flink/pull/12728#issuecomment-647015309
## CI report:
* 70dd97ae9379c3de39d32abdbd7bda496f214d53 Azure:
wuchong commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444075896
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java
##
@@ -145,28 +168,55 @@ public void
wuchong commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444075896
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java
##
@@ -145,28 +168,55 @@ public void
wuchong commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444075896
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java
##
@@ -145,28 +168,55 @@ public void
flinkbot edited a comment on pull request #11245:
URL: https://github.com/apache/flink/pull/11245#issuecomment-592002512
## CI report:
* f1d4f9163a2cd60daa02fe6b7af5a459cee9660c UNKNOWN
* df986b59c3a09633325d042b41de679c846bdc0d Azure:
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444047393
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##
@@ -705,7 +705,7 @@
godfreyhe commented on pull request #12728:
URL: https://github.com/apache/flink/pull/12728#issuecomment-648005788
@wuchong @twalthr Thanks for the suggestions, I have updated the pr based on
comments, please take another look
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444066174
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java
##
@@ -145,28 +168,55 @@ public void
flinkbot edited a comment on pull request #12746:
URL: https://github.com/apache/flink/pull/12746#issuecomment-647660048
## CI report:
* 66a9dfae43e2a1f30799e72978ce392a53448ab8 Azure:
flinkbot edited a comment on pull request #12747:
URL: https://github.com/apache/flink/pull/12747#issuecomment-647739041
## CI report:
* be402f7f12b23c919db336b6a519a95ebd8c8b3d Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/172618855)
Bot
flinkbot edited a comment on pull request #12666:
URL: https://github.com/apache/flink/pull/12666#issuecomment-644563760
## CI report:
* 551400b669fcaca487d7e25f33fccd09e2d0fca0 Azure:
flinkbot edited a comment on pull request #11245:
URL: https://github.com/apache/flink/pull/11245#issuecomment-592002512
## CI report:
* f1d4f9163a2cd60daa02fe6b7af5a459cee9660c UNKNOWN
* df986b59c3a09633325d042b41de679c846bdc0d Azure:
[
https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142738#comment-17142738
]
shaokan cao commented on FLINK-18371:
-
[~Leonard Xu] i compile release-1.11.0-rc1,and when i run sql
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444052314
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java
##
@@ -131,14 +131,27 @@
*
[
https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142724#comment-17142724
]
Echo Lee commented on FLINK-18211:
--
[~fly_in_gis]
I just verified it in standalone mode, It seems that
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444047821
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java
##
@@ -131,14 +131,27 @@
*
godfreyhe commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444047393
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##
@@ -705,7 +705,7 @@
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-5601:
--
Affects Version/s: 1.11.0
1.10.0
> Window operator does not checkpoint
flinkbot edited a comment on pull request #12746:
URL: https://github.com/apache/flink/pull/12746#issuecomment-647660048
## CI report:
* 66a9dfae43e2a1f30799e72978ce392a53448ab8 Azure:
flinkbot edited a comment on pull request #12666:
URL: https://github.com/apache/flink/pull/12666#issuecomment-644563760
## CI report:
* 551400b669fcaca487d7e25f33fccd09e2d0fca0 Azure:
flinkbot edited a comment on pull request #12054:
URL: https://github.com/apache/flink/pull/12054#issuecomment-626143079
## CI report:
* 311c21707305392d6bde18038bb1d8413867419b UNKNOWN
* e6338bad0847a8842e66a928e48f98083b63cff9 Azure:
flinkbot edited a comment on pull request #11245:
URL: https://github.com/apache/flink/pull/11245#issuecomment-592002512
## CI report:
* f1d4f9163a2cd60daa02fe6b7af5a459cee9660c UNKNOWN
* df986b59c3a09633325d042b41de679c846bdc0d Azure:
flinkbot edited a comment on pull request #9648:
URL: https://github.com/apache/flink/pull/9648#issuecomment-529346361
## CI report:
* 11e3046934f53154f23d229d7418493570afda97 Azure:
nielsbasjes commented on a change in pull request #11245:
URL: https://github.com/apache/flink/pull/11245#discussion_r444033798
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java
##
@@ -137,11 +138,17 @@
aljoscha commented on pull request #12589:
URL: https://github.com/apache/flink/pull/12589#issuecomment-647974387
This was fixed, yes: https://issues.apache.org/jira/browse/FLINK-18311. I
don't know how it happened, I had green builds on my private Azure before I
merged. Something must
twalthr closed pull request #12724:
URL: https://github.com/apache/flink/pull/12724
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-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-16835:
--
Description:
In order to allow reading and writing of configuration from a file or
[
https://issues.apache.org/jira/browse/FLINK-18373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142701#comment-17142701
]
MinWang commented on FLINK-18373:
-
Great! I will pick another issue to work on. Thank you for the reply.
[
https://issues.apache.org/jira/browse/FLINK-15693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142700#comment-17142700
]
MinWang commented on FLINK-15693:
-
[~trohrmann] Thanks for the quick reply. I think it only needs to
flinkbot edited a comment on pull request #12747:
URL: https://github.com/apache/flink/pull/12747#issuecomment-647739041
## CI report:
* b2916ff151653f8d2a952ab8acd52e8fce031055 Travis:
[CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/172554306)
*
flinkbot edited a comment on pull request #12748:
URL: https://github.com/apache/flink/pull/12748#issuecomment-647889022
## CI report:
* 2a146962687424a20b253ed3fcc42700e416375d Azure:
[
https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-16835:
--
Description:
In order to allow reading and writing of configuration from a file or
[
https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-16835:
--
Description:
In order to allow reading and writing of configuration from a file or
twalthr commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444016557
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java
##
@@ -66,70 +77,102 @@ public static void
[
https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142699#comment-17142699
]
Fabian Hueske commented on FLINK-16835:
---
I think we have consensus.
I'll copy the result of our
[
https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142696#comment-17142696
]
Jark Wu commented on FLINK-16835:
-
+1
> Replace TableConfig with Configuration
>
RocMarshal commented on a change in pull request #12727:
URL: https://github.com/apache/flink/pull/12727#discussion_r444019317
##
File path: docs/learn-flink/fault_tolerance.zh.md
##
@@ -29,180 +29,156 @@ under the License.
## State Backends
-The keyed state managed by
[
https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142693#comment-17142693
]
Fabian Hueske commented on FLINK-16835:
---
Thanks for the feedback [~twalthr].
So the options are
RocMarshal commented on a change in pull request #12727:
URL: https://github.com/apache/flink/pull/12727#discussion_r444017808
##
File path: docs/learn-flink/fault_tolerance.zh.md
##
@@ -29,180 +29,156 @@ under the License.
## State Backends
-The keyed state managed by
wuchong commented on a change in pull request #12728:
URL: https://github.com/apache/flink/pull/12728#discussion_r444005803
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java
##
@@ -131,14 +131,27 @@
* it...
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142686#comment-17142686
]
Congxian Qiu(klion26) commented on FLINK-5601:
--
Seems another affected user(user-zh mail
[
https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142684#comment-17142684
]
Yang Wang commented on FLINK-18211:
---
[~Echo Lee] Do you have verified that {{flink run
[
https://issues.apache.org/jira/browse/FLINK-18353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-18353.
-
Fix Version/s: 1.11.0
Resolution: Fixed
Fixed via
master:
flinkbot edited a comment on pull request #12747:
URL: https://github.com/apache/flink/pull/12747#issuecomment-647739041
## CI report:
* b2916ff151653f8d2a952ab8acd52e8fce031055 Travis:
[PENDING](https://travis-ci.com/github/flink-ci/flink/builds/172554306)
*
flinkbot edited a comment on pull request #12742:
URL: https://github.com/apache/flink/pull/12742#issuecomment-647480026
## CI report:
* 62e7974d623dbda1cdff2def52324973f4ec22fb Azure:
flinkbot edited a comment on pull request #12054:
URL: https://github.com/apache/flink/pull/12054#issuecomment-626143079
## CI report:
* 311c21707305392d6bde18038bb1d8413867419b UNKNOWN
* e85a3c626720f035ff0379e849e36ea6e8db7249 Azure:
[
https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142678#comment-17142678
]
Ryo Okubo commented on FLINK-11401:
---
Any progress on this issue? The pullreq seems to be mostly done.
[
https://issues.apache.org/jira/browse/FLINK-18409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142673#comment-17142673
]
Yuhao Zhao commented on FLINK-18409:
cc [~jark]。Hi, Jark Wu What do you think about the problem?
>
[
https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142672#comment-17142672
]
Leonard Xu edited comment on FLINK-18371 at 6/23/20, 6:59 AM:
--
I test this
[
https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142672#comment-17142672
]
Leonard Xu commented on FLINK-18371:
I test this case use filesystem connector in latest
Dian Fu created FLINK-18415:
---
Summary: Support TableResult#collect in the Python Table API to
align with the Java Table API
Key: FLINK-18415
URL: https://issues.apache.org/jira/browse/FLINK-18415
Project:
flinkbot edited a comment on pull request #12742:
URL: https://github.com/apache/flink/pull/12742#issuecomment-647480026
## CI report:
* 62e7974d623dbda1cdff2def52324973f4ec22fb Azure:
flinkbot edited a comment on pull request #12747:
URL: https://github.com/apache/flink/pull/12747#issuecomment-647739041
## CI report:
* b2916ff151653f8d2a952ab8acd52e8fce031055 Travis:
[PENDING](https://travis-ci.com/github/flink-ci/flink/builds/172554306)
Bot
[
https://issues.apache.org/jira/browse/FLINK-18411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18411.
---
Resolution: Fixed
Fixed in 1.11.0: 83d78134d2497266f8d864b2667c10a955384b94
This problem not exists in
wuchong commented on pull request #12749:
URL: https://github.com/apache/flink/pull/12749#issuecomment-647943193
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
wuchong merged pull request #12749:
URL: https://github.com/apache/flink/pull/12749
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
aljoscha commented on pull request #12747:
URL: https://github.com/apache/flink/pull/12747#issuecomment-647939692
@flinkbot run travis
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-18352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142656#comment-17142656
]
Piotr Nowojski commented on FLINK-18352:
This caused
flinkbot edited a comment on pull request #12728:
URL: https://github.com/apache/flink/pull/12728#issuecomment-647015309
## CI report:
* 70dd97ae9379c3de39d32abdbd7bda496f214d53 Azure:
[
https://issues.apache.org/jira/browse/FLINK-18406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142651#comment-17142651
]
Zhu Zhu commented on FLINK-18406:
-
Well I see that @Nullable annotations are still good to have,
[
https://issues.apache.org/jira/browse/FLINK-18187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-18187:
---
Priority: Critical (was: Major)
> CheckPubSubEmulatorTest failed on azure
>
[
https://issues.apache.org/jira/browse/FLINK-18187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142650#comment-17142650
]
Piotr Nowojski commented on FLINK-18187:
another instance on 1.11 branch:
[
https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-18371:
---
Environment:
I use the sql-gateway to run this sql.
The environment is streaming.
*The sql is:*
[
https://issues.apache.org/jira/browse/FLINK-18406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142644#comment-17142644
]
Zhu Zhu commented on FLINK-18406:
-
Would it make sense to forbid null keys in DualKeyLinkedMap?
Or even
tillrohrmann closed pull request #12745:
URL: https://github.com/apache/flink/pull/12745
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
klion26 commented on a change in pull request #12727:
URL: https://github.com/apache/flink/pull/12727#discussion_r443971994
##
File path: docs/learn-flink/fault_tolerance.zh.md
##
@@ -29,180 +29,156 @@ under the License.
## State Backends
-The keyed state managed by Flink
301 - 390 of 390 matches
Mail list logo