[
https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-18785:
-
Environment:
flink on yarn
flink-1.10.x
jdk8
yarn.application-attempts: 2
was:
flink on yarn
flink
Caizhi Weng created FLINK-18821:
---
Summary: Netty client retry mechanism may cause
PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely
Key: FLINK-18821
URL: https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171297#comment-17171297
]
Marta Paes Moreira edited comment on FLINK-18758 at 8/5/20, 6:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171297#comment-17171297
]
Marta Paes Moreira edited comment on FLINK-18758 at 8/5/20, 6:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171297#comment-17171297
]
Marta Paes Moreira edited comment on FLINK-18758 at 8/5/20, 6:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171297#comment-17171297
]
Marta Paes Moreira edited comment on FLINK-18758 at 8/5/20, 6:56 AM:
-
zhuzhurk commented on a change in pull request #12917:
URL: https://github.com/apache/flink/pull/12917#discussion_r465505958
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolBatchSlotRequestTest.java
##
@@ -233,16 +239,23 @@ public
zhuzhurk commented on a change in pull request #12917:
URL: https://github.com/apache/flink/pull/12917#discussion_r465509662
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolUtils.java
##
@@ -45,19 +50,108 @@
*/
public class Slot
[
https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171297#comment-17171297
]
Marta Paes Moreira commented on FLINK-18758:
+1, thanks for documenting this
hequn8128 commented on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-669009510
@shuiqiangchen Thanks a lot for the update. LGTM, will merge this pr after
test passed.
This is an automated
flinkbot edited a comment on pull request #13063:
URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742
## CI report:
* c0c3cc811dba6b3ef30730c79ea1e12cd7c8c0a9 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
dawidwys commented on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-669008809
To emphasize it again though, personally if we don't want to upgrade
calcite, personally I am fine with that change.
--
flinkbot edited a comment on pull request #12917:
URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433
## CI report:
* da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN
* 217c88f0f382bf45143dcce82a089568528dad34 Azure:
[FAILURE](https://dev.azure.com/apache-fl
dawidwys commented on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-669007993
> If we have a simple workaround for a quick fix(log an issue there and
remove the code when upgrade), it is better than just wait for the upgrade.
I mostly agree. I am a
flinkbot edited a comment on pull request #13063:
URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742
## CI report:
* c0c3cc811dba6b3ef30730c79ea1e12cd7c8c0a9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853
## CI report:
* 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853
## CI report:
* 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
klion26 commented on pull request #13056:
URL: https://github.com/apache/flink/pull/13056#issuecomment-668987047
@RocMarshal thanks for your contribution. the pr is under my radar now, will
review it soon.
This is an automat
flinkbot edited a comment on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853
## CI report:
* 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
klion26 commented on a change in pull request #9008:
URL: https://github.com/apache/flink/pull/9008#discussion_r465473496
##
File path: docs/dev/connectors/elasticsearch.zh.md
##
@@ -58,23 +56,19 @@ of the Elasticsearch installation:
-Note that the streaming connectors
shuiqiangchen commented on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668982834
Hi @hequn8128 , thank you for your comments, I have updated the pr according
to your suggestions, please have a look at it.
--
[
https://issues.apache.org/jira/browse/FLINK-18769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18769.
---
Resolution: Fixed
Fixed in
- master (1.12.0): 94b23885ca34927e37334fce51b930933cfd79dd
- 1.11.2: ec5a4d3b54
wuchong commented on pull request #13038:
URL: https://github.com/apache/flink/pull/13038#issuecomment-668973384
Merging... The failed case is caused by FLINK-18819 which is not related to
this PR.
This is an automated mess
wuchong merged pull request #13038:
URL: https://github.com/apache/flink/pull/13038
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
flinkbot edited a comment on pull request #13064:
URL: https://github.com/apache/flink/pull/13064#issuecomment-668968561
## CI report:
* bfa4fc0154d4bf5c86efff15f6141424ac1ba8e9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #13064:
URL: https://github.com/apache/flink/pull/13064#issuecomment-668968561
## CI report:
* bfa4fc0154d4bf5c86efff15f6141424ac1ba8e9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
danny0405 edited a comment on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645
> Could you name a few of these breaking changes? I know about the dropped
windows but what else?
I listed some features i though important (very probably breakin
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171254#comment-17171254
]
Jark Wu commented on FLINK-18819:
-
Another instance:
https://dev.azure.com/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-18785:
-
Component/s: Runtime / Coordination
> flink goes into dead lock leader election when restoring from a do
[
https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-18811:
-
Component/s: (was: Table SQL / Runtime)
Runtime / Network
> if a disk is damaged, t
flinkbot commented on pull request #13064:
URL: https://github.com/apache/flink/pull/13064#issuecomment-668964293
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
Jiezhi opened a new pull request #13064:
URL: https://github.com/apache/flink/pull/13064
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
shuiqiangchen commented on a change in pull request #13061:
URL: https://github.com/apache/flink/pull/13061#discussion_r465444604
##
File path:
flink-python/pyflink/datastream/tests/test_stream_execution_environment.py
##
@@ -22,9 +22,12 @@
import unittest
+
Review comme
[
https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171247#comment-17171247
]
andrew commented on FLINK-10658:
hi, chauncy. The same exception happened in my applicat
[
https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
andrew updated FLINK-10658:
---
Attachment: 3.png
1.png
> org.apache.flink.util.FlinkException: Releasing shared slot parent
flinkbot edited a comment on pull request #13063:
URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742
## CI report:
* c0c3cc811dba6b3ef30730c79ea1e12cd7c8c0a9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Xuannan Su created FLINK-18820:
--
Summary: SourceOperator should send MAX_WATERMARK to downstream
operator when closed
Key: FLINK-18820
URL: https://issues.apache.org/jira/browse/FLINK-18820
Project: Flin
dianfu commented on pull request #13034:
URL: https://github.com/apache/flink/pull/13034#issuecomment-668951790
cc @StephanEwen
This is an automated message from the Apache Git Service.
To respond to the message, please log
hequn8128 commented on a change in pull request #13061:
URL: https://github.com/apache/flink/pull/13061#discussion_r465435385
##
File path: flink-python/pyflink/datastream/tests/test_util.py
##
@@ -0,0 +1,45 @@
+##
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-18816.
---
Fix Version/s: 1.11.2
1.12.0
Resolution: Fixed
Fixed in Master: 456d5ba561
flinkbot commented on pull request #13063:
URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742
## CI report:
* c0c3cc811dba6b3ef30730c79ea1e12cd7c8c0a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171240#comment-17171240
]
sunjincheng commented on FLINK-18816:
-
Thanks for the PR [~huaouo]
> Correct API u
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-18816:
---
Assignee: Zhenhua Yang
> Correct API usage in Pyflink Dependency Management page
>
zhuzhurk commented on a change in pull request #13028:
URL: https://github.com/apache/flink/pull/13028#discussion_r465441978
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/MergingSharedSlotProfileRetrieverTest.java
##
@@ -0,0 +1,182 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171237#comment-17171237
]
Dian Fu edited comment on FLINK-18819 at 8/5/20, 2:49 AM:
--
It's
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171238#comment-17171238
]
Dian Fu commented on FLINK-18819:
-
Instance on 1.11:
https://dev.azure.com/apache-flink/
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18819:
Affects Version/s: 1.11.2
> All the PubSub tests are failing
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18819:
Fix Version/s: 1.11.2
> All the PubSub tests are failing
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171237#comment-17171237
]
Dian Fu commented on FLINK-18819:
-
It's probably caused by the upgrade of the docker ima
[
https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-18690.
---
Fix Version/s: 1.12.0
Resolution: Fixed
Done via:
2542d86861cd5dd94feb9fcc92ef8e06398c8241
cfda0e0bb7
sunjincheng121 merged pull request #13062:
URL: https://github.com/apache/flink/pull/13062
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
sunjincheng121 commented on pull request #13062:
URL: https://github.com/apache/flink/pull/13062#issuecomment-668944112
Thanks for the PR @huaouo
Merging...
This is an automated message from the Apache Git Service.
To res
zhuzhurk merged pull request #13009:
URL: https://github.com/apache/flink/pull/13009
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-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18819:
Component/s: Tests
> All the PubSub tests are failing
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18819:
Labels: test-stability (was: )
> All the PubSub tests are failing
>
>
>
Dian Fu created FLINK-18819:
---
Summary: All the PubSub tests are failing
Key: FLINK-18819
URL: https://issues.apache.org/jira/browse/FLINK-18819
Project: Flink
Issue Type: Bug
Components:
flinkbot commented on pull request #13063:
URL: https://github.com/apache/flink/pull/13063#issuecomment-668942816
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
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Jiang updated FLINK-18816:
---
Comment: was deleted
(was: [~sunjincheng121]Could you please assign this to me?)
> Correct
KarmaGYZ opened a new pull request #13063:
URL: https://github.com/apache/flink/pull/13063
…in Yarn
## What is the purpose of the change
Add Node information to the ResourceId of TaskExecutor in Yarn
## Brief change log
Add Node information to the Reso
flinkbot commented on pull request #13062:
URL: https://github.com/apache/flink/pull/13062#issuecomment-668940997
## CI report:
* 37fd035148d09bc22640aa912ea172b96e6dbba4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853
## CI report:
* 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171231#comment-17171231
]
Nicholas Jiang commented on FLINK-18816:
[~sunjincheng121]Could you please assig
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171224#comment-17171224
]
Zhenhua Yang edited comment on FLINK-18816 at 8/5/20, 2:21 AM:
---
flinkbot commented on pull request #13062:
URL: https://github.com/apache/flink/pull/13062#issuecomment-668936862
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
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171224#comment-17171224
]
Zhenhua Yang edited comment on FLINK-18816 at 8/5/20, 2:20 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171224#comment-17171224
]
Zhenhua Yang commented on FLINK-18816:
--
I created a [pull request|[https://github.c
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18816:
---
Labels: beginner pull-request-available (was: beginner)
> Correct API usage in Pyflink Depe
huaouo opened a new pull request #13062:
URL: https://github.com/apache/flink/pull/13062
## What is the purpose of the change
This pull request corrects API change in pyflink dependency management page.
## Brief change log
- *Update `dependency_management.md` and `depe
[
https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171223#comment-17171223
]
Yang Wang commented on FLINK-18749:
---
Hi [~trohrmann], I notice that you have changed t
flinkbot commented on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853
## CI report:
* 8ccc4bad17d568058446ad6816a6d181f090ecf0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #13061:
URL: https://github.com/apache/flink/pull/13061#issuecomment-668930657
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
[
https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18764:
---
Labels: pull-request-available (was: )
> Support from_collection for Python DataStream API
shuiqiangchen opened a new pull request #13061:
URL: https://github.com/apache/flink/pull/13061
## What is the purpose of the change
Introduced a new class named DataStream including its common interfaces. And
support to get a DataStream through
StreamExecutionEnvironment.fr
danny0405 edited a comment on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645
> Could you name a few of these breaking changes? I know about the dropped
windows but what else?
I listed some features i though important (very probably breakin
danny0405 commented on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645
> Could you name a few of these breaking changes? I know about the dropped
windows but what else?
I listed some features i though important (very probably breaking) here
[
https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18818:
Labels: test-stability (was: )
> HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed
[
https://issues.apache.org/jira/browse/FLINK-18817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171216#comment-17171216
]
Yangze Guo commented on FLINK-18817:
It seems the same issue with FLINK-18771.
> 'K
[
https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18818:
Component/s: Tests
> HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with
> "java
Dian Fu created FLINK-18818:
---
Summary: HadoopRenameCommitterHDFSTest.testCommitOneFile[Override:
false] failed with "java.io.IOException: The stream is closed"
Key: FLINK-18818
URL: https://issues.apache.org/jira/browse
Hequn Cheng created FLINK-18817:
---
Summary: 'Kerberized YARN per-job on Docker test' failed
Key: FLINK-18817
URL: https://issues.apache.org/jira/browse/FLINK-18817
Project: Flink
Issue Type: Tes
hequn8128 merged pull request #13029:
URL: https://github.com/apache/flink/pull/13029
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 t
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-18816:
---
Assignee: (was: sunjincheng)
> Correct API usage in Pyflink Dependency Management page
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-18816:
---
Assignee: sunjincheng
> Correct API usage in Pyflink Dependency Management page
> -
[
https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-18816:
Labels: beginner (was: )
> Correct API usage in Pyflink Dependency Management page
>
sunjincheng created FLINK-18816:
---
Summary: Correct API usage in Pyflink Dependency Management page
Key: FLINK-18816
URL: https://issues.apache.org/jira/browse/FLINK-18816
Project: Flink
Issue T
tweise commented on a change in pull request #13042:
URL: https://github.com/apache/flink/pull/13042#discussion_r465360429
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
##
@@ -470,4 +479,30 @@ static String getTaskManage
flinkbot edited a comment on pull request #13060:
URL: https://github.com/apache/flink/pull/13060#issuecomment-668656762
## CI report:
* fcfa6ca7e8aaa669c1df0e7650bc04a68d8c6f4c Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13055:
URL: https://github.com/apache/flink/pull/13055#issuecomment-668083003
## CI report:
* 6acb8dae3e8cefea998c5ec78683a4dab16a1f78 UNKNOWN
* f5df4b17aae9f1abda5c07430bf24c38f08de3e6 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
Robert Metzger created FLINK-18815:
--
Summary: AbstractCloseableRegistryTest.testClose unstable
Key: FLINK-18815
URL: https://issues.apache.org/jira/browse/FLINK-18815
Project: Flink
Issue Ty
flinkbot edited a comment on pull request #13038:
URL: https://github.com/apache/flink/pull/13038#issuecomment-667062198
## CI report:
* de3fdd7aeba276a5d66d6d759b126597443c1371 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170974#comment-17170974
]
Seth Wiesman commented on FLINK-18810:
--
[~slinkydeveloper] I've pushed the code her
sjwiesman commented on pull request #128:
URL: https://github.com/apache/flink-statefun/pull/128#issuecomment-668710123
Thanks. Merged into master and 2.1 to fix the stable docs.
This is an automated message from the Apache
sjwiesman closed pull request #128:
URL: https://github.com/apache/flink-statefun/pull/128
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
sjwiesman commented on a change in pull request #128:
URL: https://github.com/apache/flink-statefun/pull/128#discussion_r465191925
##
File path: docs/sdk/python.md
##
@@ -132,23 +132,23 @@ The delayed message is non-blocking so functions will
continue to process record
The de
sjwiesman commented on a change in pull request #129:
URL: https://github.com/apache/flink-statefun/pull/129#discussion_r465189718
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java
##
@@ -113,9 +111
flinkbot edited a comment on pull request #13038:
URL: https://github.com/apache/flink/pull/13038#issuecomment-667062198
## CI report:
* 4d42c1496efbb3644557382033d931c0239ecd28 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170950#comment-17170950
]
Satyam Shekhar commented on FLINK-18095:
For testing purposes, I create a mini-c
sjwiesman commented on a change in pull request #129:
URL: https://github.com/apache/flink-statefun/pull/129#discussion_r465186356
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java
##
@@ -74,7 +75,9 @@
[
https://issues.apache.org/jira/browse/FLINK-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18812:
---
Labels: pull-request-available (was: )
> Upgrade StateFun to Flink 1.11.1
> ---
sjwiesman commented on pull request #129:
URL: https://github.com/apache/flink-statefun/pull/129#issuecomment-668704149
cc @igalshilman
This is an automated message from the Apache Git Service.
To respond to the message, ple
1 - 100 of 249 matches
Mail list logo
