Dongwon Kim created FLINK-21218:
---
Summary: "state.checkpoints.dir" should be required only when
"execution.checkpointing.interval" is specified
Key: FLINK-21218
URL:
[
https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275790#comment-17275790
]
Xintong Song commented on FLINK-21139:
--
[~ZhenqiuHuang],
Maybe we can move {{ThreasholdMeter}} to
flinkbot edited a comment on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* 5043cb6d95f503534b53bac93c451ae367e9 Azure:
flinkbot edited a comment on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* 326d8751ac2aac4255b5e94da8e8f46a424c55c5 Azure:
flinkbot edited a comment on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* 326d8751ac2aac4255b5e94da8e8f46a424c55c5 Azure:
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 11651466eb13c5c05d2cd0eed0ac08b9bf617185 Azure:
flinkbot commented on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* 326d8751ac2aac4255b5e94da8e8f46a424c55c5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 1a6bd7aa98b649bd119479247d34ea029b8ba636 Azure:
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* e7dbab13079f1a1f2350320930cc216c8ed42759 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275780#comment-17275780
]
Zhenqiu Huang commented on FLINK-21139:
---
[~trohrmann] [~xintongsong]
The ManualClock is defined in
flinkbot commented on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770325573
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
HuangZhenQiu commented on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-770324596
@rmetzger
Thanks for these suggestions. Updated accordingly. Please review it again at
your most convenient time.
HuangZhenQiu commented on a change in pull request #14678:
URL: https://github.com/apache/flink/pull/14678#discussion_r567364389
##
File path:
flink-core/src/main/java/org/apache/flink/core/failurelistener/FailureListener.java
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the
HuangZhenQiu commented on a change in pull request #14678:
URL: https://github.com/apache/flink/pull/14678#discussion_r567364347
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurelistener/FailureListenerUtils.java
##
@@ -0,0 +1,55 @@
+/*
+ * Licensed
HuangZhenQiu commented on a change in pull request #14678:
URL: https://github.com/apache/flink/pull/14678#discussion_r567364321
##
File path: docs/deployment/advanced/platform.md
##
@@ -0,0 +1,49 @@
+---
+title: "Customizable Features for Platform Users"
+nav-title: platform
HuangZhenQiu commented on a change in pull request #14678:
URL: https://github.com/apache/flink/pull/14678#discussion_r567364234
##
File path: docs/deployment/advanced/platform.md
##
@@ -0,0 +1,49 @@
+---
+title: "Customizable Features for Platform Users"
+nav-title: platform
[
https://issues.apache.org/jira/browse/FLINK-21085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21085:
---
Labels: pull-request-available (was: )
> Refactor StreamTask hierarchy to support
gaoyunhaii opened a new pull request #14820:
URL: https://github.com/apache/flink/pull/14820
## What is the purpose of the change
This PR enables triggering checkpoint barrier handle for non-source tasks.
To support checkpoints after some tasks finished, non-source tasks
flinkbot edited a comment on pull request #14819:
URL: https://github.com/apache/flink/pull/14819#issuecomment-770318086
## CI report:
* 3b55294a34fea9ba31744e8f7fb7456c3faf46ef Azure:
flinkbot commented on pull request #14819:
URL: https://github.com/apache/flink/pull/14819#issuecomment-770318086
## CI report:
* 3b55294a34fea9ba31744e8f7fb7456c3faf46ef UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275766#comment-17275766
]
Guowei Ma commented on FLINK-20420:
---
flinkbot commented on pull request #14819:
URL: https://github.com/apache/flink/pull/14819#issuecomment-770317299
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
[
https://issues.apache.org/jira/browse/FLINK-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16152:
---
Labels: pull-request-available (was: )
> Translate "Operator/index" into Chinese
>
dijkwxyz opened a new pull request #14819:
URL: https://github.com/apache/flink/pull/14819
Finished previously incomplete translation for index.zh.md
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275765#comment-17275765
]
Guowei Ma commented on FLINK-21216:
---
[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21216:
--
Affects Version/s: 1.12.0
> StreamPandasConversionTests Fails
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-20523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275760#comment-17275760
]
Guowei Ma commented on FLINK-20523:
---
Guowei Ma created FLINK-21217:
-
Summary: Resuming Savepoint (rocks, scale up, rocks timers)
end-to-end test
Key: FLINK-21217
URL: https://issues.apache.org/jira/browse/FLINK-21217
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275757#comment-17275757
]
Guowei Ma commented on FLINK-20661:
---
[
https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275756#comment-17275756
]
Guowei Ma commented on FLINK-21215:
---
Guowei Ma created FLINK-21216:
-
Summary: StreamPandasConversionTests Fails
Key: FLINK-21216
URL: https://issues.apache.org/jira/browse/FLINK-21216
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21215:
--
Summary: UnalignedCheckpointITCase.execute Failed (was:
UnalignedCheckpointITCase.execute)
>
[
https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21215:
--
Description:
Guowei Ma created FLINK-21215:
-
Summary: UnalignedCheckpointITCase.execute
Key: FLINK-21215
URL: https://issues.apache.org/jira/browse/FLINK-21215
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21214:
-
Summary:
FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed
Key: FLINK-21214
URL: https://issues.apache.org/jira/browse/FLINK-21214
Project: Flink
Guowei Ma created FLINK-21213:
-
Summary: Elasticsearch (v5.3.3) sink end-to-end test' failed
Key: FLINK-21213
URL: https://issues.apache.org/jira/browse/FLINK-21213
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21213:
--
Labels: test-stability (was: )
> Elasticsearch (v5.3.3) sink end-to-end test' failed
>
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* 4447d44df71a1bb5b2ac672bfd9736d88dd3183f Azure:
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* 4447d44df71a1bb5b2ac672bfd9736d88dd3183f Azure:
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* 4447d44df71a1bb5b2ac672bfd9736d88dd3183f Azure:
[
https://issues.apache.org/jira/browse/FLINK-9389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275710#comment-17275710
]
DILJIT POOVAKOTIL RAMACHANDRAN edited comment on FLINK-9389 at 1/30/21, 8:50 PM:
[
https://issues.apache.org/jira/browse/FLINK-9389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275710#comment-17275710
]
DILJIT POOVAKOTIL RAMACHANDRAN commented on FLINK-9389:
---
[~uce] I tried reproducing
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* 5bd74e2865ec431f3bf2528f5d85969ca51714fb Azure:
flinkbot edited a comment on pull request #14740:
URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750
## CI report:
* 2ab49d334140ab47d7eb144964fac540e6f98444 Azure:
flinkbot edited a comment on pull request #13912:
URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037
## CI report:
* 5bd74e2865ec431f3bf2528f5d85969ca51714fb Azure:
[
https://issues.apache.org/jira/browse/FLINK-21164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-21164.
Resolution: Fixed
> Jar handlers don't cleanup temporarily extracted jars
>
[
https://issues.apache.org/jira/browse/FLINK-21164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275242#comment-17275242
]
Chesnay Schepler edited comment on FLINK-21164 at 1/30/21, 4:20 PM:
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275661#comment-17275661
]
YufeiLiu edited comment on FLINK-21208 at 1/30/21, 4:01 PM:
I've made some
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275661#comment-17275661
]
YufeiLiu commented on FLINK-21208:
--
I've made some discoveries, I found beam has a config
flinkbot edited a comment on pull request #14818:
URL: https://github.com/apache/flink/pull/14818#issuecomment-770227636
## CI report:
* 127c825b086444687af34685da04e72e9fd6bc2c Azure:
flinkbot commented on pull request #14818:
URL: https://github.com/apache/flink/pull/14818#issuecomment-770227636
## CI report:
* 127c825b086444687af34685da04e72e9fd6bc2c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14818:
URL: https://github.com/apache/flink/pull/14818#issuecomment-770226619
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
[
https://issues.apache.org/jira/browse/FLINK-21081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21081:
---
Labels: pull-request-available (was: )
> Re-compute tasks to trigger when tasks get
gaoyunhaii opened a new pull request #14818:
URL: https://github.com/apache/flink/pull/14818
## What is the purpose of the change
This PR tries to re-trigger the descendent tasks if needed when some tasks
finished before get triggered successfully.
## Brief change log
flinkbot edited a comment on pull request #14754:
URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862
## CI report:
* 7a0a38b9960949cedae60f4574edc8382841c8ac Azure:
flinkbot edited a comment on pull request #14740:
URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750
## CI report:
* 15a1f2beef1ddf95687fb4a53cf8a6f906559836 Azure:
flinkbot edited a comment on pull request #14754:
URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862
## CI report:
* 37484933592e8b5a4f5cf83425ac0b7b612c7480 Azure:
flinkbot edited a comment on pull request #14740:
URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750
## CI report:
* 15a1f2beef1ddf95687fb4a53cf8a6f906559836 Azure:
gaoyunhaii commented on pull request #14740:
URL: https://github.com/apache/flink/pull/14740#issuecomment-770215757
Very thanks @guoweiM for the comments and I have update the algorithm
accordingly
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-21208:
-
Comment: was deleted
(was: I found that have start more than one beam worker, and seems share the
same
flinkbot edited a comment on pull request #14799:
URL: https://github.com/apache/flink/pull/14799#issuecomment-769554549
## CI report:
* 89066112157569ad58908e401696b45a56f48fc3 Azure:
flinkbot edited a comment on pull request #14817:
URL: https://github.com/apache/flink/pull/14817#issuecomment-770195122
## CI report:
* 3da70442b1cd80555f9c6bab5fdf9903cca9892d Azure:
flinkbot edited a comment on pull request #14799:
URL: https://github.com/apache/flink/pull/14799#issuecomment-769554549
## CI report:
* 7ee60d64feb3da9e9fc24e08482260d4b021c65f Azure:
flinkbot edited a comment on pull request #14799:
URL: https://github.com/apache/flink/pull/14799#issuecomment-769554549
## CI report:
* 7ee60d64feb3da9e9fc24e08482260d4b021c65f Azure:
flinkbot edited a comment on pull request #14817:
URL: https://github.com/apache/flink/pull/14817#issuecomment-770195122
## CI report:
* 3da70442b1cd80555f9c6bab5fdf9903cca9892d Azure:
[
https://issues.apache.org/jira/browse/FLINK-16017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-16017.
---
Resolution: Duplicate
> Improve attachJobGraph Performance
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-16017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275554#comment-17275554
]
Zhu Zhu commented on FLINK-16017:
-
[~rmetzger] yes it is already fixed via FLINK-17180. Will close it.
flinkbot commented on pull request #14817:
URL: https://github.com/apache/flink/pull/14817#issuecomment-770195122
## CI report:
* 3da70442b1cd80555f9c6bab5fdf9903cca9892d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275552#comment-17275552
]
Piotr Nowojski commented on FLINK-20654:
yet another fix merged to master as a23744795d9
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275551#comment-17275551
]
Piotr Nowojski commented on FLINK-21104:
fix merged to master as a6b909c3e59..a4ccc6e63ca (this
flinkbot commented on pull request #14817:
URL: https://github.com/apache/flink/pull/14817#issuecomment-770192564
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
pnowojski opened a new pull request #14817:
URL: https://github.com/apache/flink/pull/14817
This is a backport of https://github.com/apache/flink/pull/14797 to
release-1.12 branch
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275546#comment-17275546
]
YufeiLiu edited comment on FLINK-21208 at 1/30/21, 10:25 AM:
-
I found that
flinkbot edited a comment on pull request #14816:
URL: https://github.com/apache/flink/pull/14816#issuecomment-770164177
## CI report:
* daece76bc00e4dd9aab27b59c16fd67d57cc24d6 Azure:
pnowojski merged pull request #14797:
URL: https://github.com/apache/flink/pull/14797
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
flinkbot edited a comment on pull request #14813:
URL: https://github.com/apache/flink/pull/14813#issuecomment-769867480
## CI report:
* e5f633baea6ed961c21635feedab97683c429def Azure:
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275546#comment-17275546
]
YufeiLiu commented on FLINK-21208:
--
I've found that beam worker wasn't exit after job failed. And this
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-21208:
-
Affects Version/s: 1.12.1
> pyarrow exception when using window with pandas udaf
>
[
https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-21208:
-
Issue Type: Bug (was: Improvement)
> pyarrow exception when using window with pandas udaf
>
PatrickRen commented on pull request #14789:
URL: https://github.com/apache/flink/pull/14789#issuecomment-770181843
I noticed a race condition in my modification: the variable
```noMoreNewPartitionSplits``` may not be set when ```addReader``` is invoked
because they are in different
flinkbot edited a comment on pull request #14724:
URL: https://github.com/apache/flink/pull/14724#issuecomment-765052737
## CI report:
* 79d610f87c58b7c392d4a6cd46fb24eb9f7850c8 Azure:
81 matches
Mail list logo
