flinkbot edited a comment on pull request #14434:
URL: https://github.com/apache/flink/pull/14434#issuecomment-748424188
## CI report:
* c842f89ec6dc499aae7892af964db77f595d547f Azure:
flinkbot edited a comment on pull request #14434:
URL: https://github.com/apache/flink/pull/14434#issuecomment-748424188
## CI report:
* c842f89ec6dc499aae7892af964db77f595d547f Azure:
flinkbot commented on pull request #14434:
URL: https://github.com/apache/flink/pull/14434#issuecomment-748424188
## CI report:
* c842f89ec6dc499aae7892af964db77f595d547f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14433:
URL: https://github.com/apache/flink/pull/14433#issuecomment-748371062
## CI report:
* 7511cbed092a30ac95caf96f2205bc5f299fb3b7 Azure:
flinkbot commented on pull request #14434:
URL: https://github.com/apache/flink/pull/14434#issuecomment-748423025
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
hehuiyuan opened a new pull request #14434:
URL: https://github.com/apache/flink/pull/14434
## What is the purpose of the change
There are some documents error.
![image](https://user-images.githubusercontent.com/18002496/102681692-97d8d280-41fe-11eb-98c0-487cf6b4d765.png)
[
https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252096#comment-17252096
]
Huang Xingbo commented on FLINK-20662:
--
[
https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252095#comment-17252095
]
Yun Gao commented on FLINK-20476:
-
It also seems there is always one TaskManager keep iterating on the
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252094#comment-17252094
]
Huang Xingbo commented on FLINK-20329:
--
Huang Xingbo created FLINK-20679:
Summary: JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering
test failed
Key: FLINK-20679
URL: https://issues.apache.org/jira/browse/FLINK-20679
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252093#comment-17252093
]
Yun Gao commented on FLINK-20476:
-
Hi [~hxbks2ks], very thanks for reporting the issues! But the new
[
https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252090#comment-17252090
]
Huang Xingbo commented on FLINK-20662:
--
[
https://issues.apache.org/jira/browse/FLINK-20666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20666.
---
Fix Version/s: 1.12.1
1.11.4
1.13.0
Resolution: Fixed
Fixed in
dianfu closed pull request #14422:
URL: https://github.com/apache/flink/pull/14422
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-20666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-20666:
---
Assignee: Huang Xingbo
> Fix the deserialized Row losing the field_name information in PyFlink
>
dianfu merged pull request #14426:
URL: https://github.com/apache/flink/pull/14426
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-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252083#comment-17252083
]
Huang Xingbo commented on FLINK-20476:
--
[
https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252082#comment-17252082
]
Huang Xingbo commented on FLINK-20662:
--
[
https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252081#comment-17252081
]
Huang Xingbo commented on FLINK-20662:
--
Hi [~AHeise] It seems that this issue occurs quite
[
https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252080#comment-17252080
]
Huang Xingbo commented on FLINK-20662:
--
[
https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252078#comment-17252078
]
Huang Xingbo commented on FLINK-20662:
--
[
https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252076#comment-17252076
]
Huang Xingbo commented on FLINK-20254:
--
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252075#comment-17252075
]
Huang Xingbo commented on FLINK-20389:
--
flinkbot edited a comment on pull request #14433:
URL: https://github.com/apache/flink/pull/14433#issuecomment-748371062
## CI report:
* 7511cbed092a30ac95caf96f2205bc5f299fb3b7 Azure:
flinkbot commented on pull request #14433:
URL: https://github.com/apache/flink/pull/14433#issuecomment-748371062
## CI report:
* 7511cbed092a30ac95caf96f2205bc5f299fb3b7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14433:
URL: https://github.com/apache/flink/pull/14433#issuecomment-748368610
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
casidiablo opened a new pull request #14433:
URL: https://github.com/apache/flink/pull/14433
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
tianon commented on pull request #49:
URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748346905
`docker run flink run bash` just to get a shell that has useful environment
variables is a bit convoluted/awkward -- are these variables harmful for normal
commands? Given
flinkbot edited a comment on pull request #14432:
URL: https://github.com/apache/flink/pull/14432#issuecomment-748196526
## CI report:
* d2192e5c0d882ef4d475b2f55b0623673026fb7d Azure:
flinkbot edited a comment on pull request #14431:
URL: https://github.com/apache/flink/pull/14431#issuecomment-748196435
## CI report:
* aec1ac97effc6607d3fb4f94fe323c86c20759a8 Azure:
flinkbot edited a comment on pull request #14377:
URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277
## CI report:
* ba3f9a13b98b5ddaee1dcf142ee3cf00322fe5c0 Azure:
flinkbot edited a comment on pull request #14430:
URL: https://github.com/apache/flink/pull/14430#issuecomment-748196338
## CI report:
* 2996e3ffa70a4caa7437c9699e1cbc93ebfe488a Azure:
flinkbot edited a comment on pull request #14423:
URL: https://github.com/apache/flink/pull/14423#issuecomment-748013167
## CI report:
* feca8bda1976f237787ea3219b567bff442e4568 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251965#comment-17251965
]
Arvid Heise commented on FLINK-20433:
-
Stabilized test in master as
AHeise merged pull request #14421:
URL: https://github.com/apache/flink/pull/14421
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 #14429:
URL: https://github.com/apache/flink/pull/14429#issuecomment-748082234
## CI report:
* 2480c4158f646cef362efb050fe60356c80bcd0c Azure:
flinkbot edited a comment on pull request #14312:
URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739
## CI report:
* 091ba28c2182acfbb79b8cf0c0d6b0b2d40784ed Azure:
flinkbot edited a comment on pull request #14427:
URL: https://github.com/apache/flink/pull/14427#issuecomment-748081998
## CI report:
* ac114d186758867e905eb1cd891a9a52279ed375 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251928#comment-17251928
]
Roman Khachatryan commented on FLINK-20672:
---
Thanks for the confirmation [~yunta].
>
[
https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-20672:
--
Fix Version/s: 1.13.0
> CheckpointAborted RPC failure can fail JM
>
flinkbot edited a comment on pull request #14402:
URL: https://github.com/apache/flink/pull/14402#issuecomment-74600
## CI report:
* 64e05a309f50760e1f821402892b36b3c8e58133 Azure:
flinkbot edited a comment on pull request #14400:
URL: https://github.com/apache/flink/pull/14400#issuecomment-745936223
## CI report:
* d37a896391cd2b590044d3ec1074798cb01bdbed Azure:
flinkbot edited a comment on pull request #14426:
URL: https://github.com/apache/flink/pull/14426#issuecomment-748081897
## CI report:
* acccd3653ec2ae872671b5289ca4082e2ab9107b Azure:
flinkbot edited a comment on pull request #14398:
URL: https://github.com/apache/flink/pull/14398#issuecomment-745762402
## CI report:
* ebca7dda6bb09c98710b8f34a4e5b3cd2b156f0a Azure:
flinkbot edited a comment on pull request #14387:
URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624
## CI report:
* 4333cc2789d8eccf1ddc58a3c79ab0880169fab6 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251912#comment-17251912
]
mei jie commented on FLINK-20552:
-
Hi, [~jark]
Too busy these days, I will fix this at this weekend.
flinkbot edited a comment on pull request #14425:
URL: https://github.com/apache/flink/pull/14425#issuecomment-748063383
## CI report:
* 0b24ca071bed9d436d66a2362c5a93efdb049e11 Azure:
flinkbot edited a comment on pull request #14387:
URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624
## CI report:
* 3556926bfe3d10e73d4700f295c7343e7b42509e Azure:
flinkbot edited a comment on pull request #14377:
URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277
## CI report:
* ffcb3c699eb099caccb20aa38f372557e8a59306 Azure:
flinkbot edited a comment on pull request #14423:
URL: https://github.com/apache/flink/pull/14423#issuecomment-748013167
## CI report:
* c1507f5fd4747da2a8d3434b2cdbc883a1d332f2 Azure:
flinkbot edited a comment on pull request #14432:
URL: https://github.com/apache/flink/pull/14432#issuecomment-748196526
## CI report:
* d2192e5c0d882ef4d475b2f55b0623673026fb7d Azure:
flinkbot edited a comment on pull request #14431:
URL: https://github.com/apache/flink/pull/14431#issuecomment-748196435
## CI report:
* aec1ac97effc6607d3fb4f94fe323c86c20759a8 Azure:
flinkbot edited a comment on pull request #14430:
URL: https://github.com/apache/flink/pull/14430#issuecomment-748196338
## CI report:
* 2996e3ffa70a4caa7437c9699e1cbc93ebfe488a Azure:
flinkbot edited a comment on pull request #14422:
URL: https://github.com/apache/flink/pull/14422#issuecomment-747979046
## CI report:
* 6496e62d787b56d01e9053fa4f59e2ec5ac9077e Azure:
flinkbot edited a comment on pull request #14377:
URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277
## CI report:
* ffcb3c699eb099caccb20aa38f372557e8a59306 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251864#comment-17251864
]
Arvid Heise commented on FLINK-20654:
-
For my investigation, I added a bunch of info statements to
[
https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251863#comment-17251863
]
Boris Lublinsky commented on FLINK-20664:
-
I think so. This gives me the flexibility. I can
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-20654:
Description:
Fix of FLINK-20433 shows potential corruption after recovery for all variations
of
flinkbot commented on pull request #14432:
URL: https://github.com/apache/flink/pull/14432#issuecomment-748196526
## CI report:
* d2192e5c0d882ef4d475b2f55b0623673026fb7d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14431:
URL: https://github.com/apache/flink/pull/14431#issuecomment-748196435
## CI report:
* aec1ac97effc6607d3fb4f94fe323c86c20759a8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14430:
URL: https://github.com/apache/flink/pull/14430#issuecomment-748196338
## CI report:
* 2996e3ffa70a4caa7437c9699e1cbc93ebfe488a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-20648:
--
Comment: was deleted
(was: Hmm. Maybe we could build the rpc endpoint id for JobMaster outside and
kl0u commented on a change in pull request #14312:
URL: https://github.com/apache/flink/pull/14312#discussion_r545953329
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java
##
@@ -143,7 +150,20 @@
flinkbot edited a comment on pull request #14387:
URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624
## CI report:
* 3556926bfe3d10e73d4700f295c7343e7b42509e Azure:
[
https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251850#comment-17251850
]
Yang Wang commented on FLINK-20648:
---
Yes. We are justing using the {{leaderContenderDescription}}(aka
flinkbot commented on pull request #14432:
URL: https://github.com/apache/flink/pull/14432#issuecomment-748187284
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-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-19369:
-
Assignee: Till Rohrmann
>
[
https://issues.apache.org/jira/browse/FLINK-20678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20678:
---
Labels: pull-request-available (was: )
> JobManagerRunnerImpl does not notice unexpected
[
https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251848#comment-17251848
]
Yang Wang commented on FLINK-20664:
---
[~lublinsky] Do you think adding a new config option
tillrohrmann opened a new pull request #14432:
URL: https://github.com/apache/flink/pull/14432
## What is the purpose of the change
This is a safety net which ensures that the JobManagerRunnerImpl will fail
if the
JobMasterService fails unexpectedly.
## Verifying this
flinkbot edited a comment on pull request #14387:
URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624
## CI report:
* d1afe2b80aee567e824eee4c8654798e7163a01b Azure:
flinkbot commented on pull request #14431:
URL: https://github.com/apache/flink/pull/14431#issuecomment-748184472
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
Till Rohrmann created FLINK-20678:
-
Summary: JobManagerRunnerImpl does not notice unexpected
JobMasterService termination
Key: FLINK-20678
URL: https://issues.apache.org/jira/browse/FLINK-20678
[
https://issues.apache.org/jira/browse/FLINK-11719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11719:
---
Labels: pull-request-available (was: )
> Remove JobMaster#start(JobMasterId) and #suspend
tillrohrmann opened a new pull request #14431:
URL: https://github.com/apache/flink/pull/14431
## What is the purpose of the change
This PR changes how the `JobMaster` is used by the `JobManagerRunnerImpl`.
Instead of reusing the `JobMaster` across different leader sessions, the
flinkbot commented on pull request #14430:
URL: https://github.com/apache/flink/pull/14430#issuecomment-748182634
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-20677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20677:
---
Labels: pull-request-available (was: )
> Let JobManagerRunner return
tillrohrmann opened a new pull request #14430:
URL: https://github.com/apache/flink/pull/14430
## What is the purpose of the change
The JobManagerRunnerResult allows to express different termination
conditions for the JobManagerRunner:
1) Job finished successfully
2) Job
Till Rohrmann created FLINK-20677:
-
Summary: Let JobManagerRunner return JobManagerRunnerResult to
better distinguish result cases
Key: FLINK-20677
URL: https://issues.apache.org/jira/browse/FLINK-20677
wangyang0918 edited a comment on pull request #49:
URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748171203
@tillrohrmann I have updated this PR. Once this PR is merged, we could ping
the docker guys for merging the docker publishing PR for 1.12.0.
I also created a
Yang Wang created FLINK-20676:
-
Summary: Remove deprecated command "native-k8s" in
docker-entrypoint.sh
Key: FLINK-20676
URL: https://issues.apache.org/jira/browse/FLINK-20676
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-20650:
--
Summary: Add new general command "run" and mark "native-k8s" as deprecated
in docker-entrypoint.sh
[
https://issues.apache.org/jira/browse/FLINK-20650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-20650:
--
Summary: [FLINK-20650] Add new general command "run" and mark "native-k8s"
as deprecated in
flinkbot edited a comment on pull request #14424:
URL: https://github.com/apache/flink/pull/14424#issuecomment-748039662
## CI report:
* a281ac1645846dce585e8b377c4f48a7e03e8cf6 Azure:
flinkbot edited a comment on pull request #14387:
URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624
## CI report:
* 47dcb9670fdea6129692d27b33dc13b620248600 Azure:
flinkbot edited a comment on pull request #14361:
URL: https://github.com/apache/flink/pull/14361#issuecomment-742899629
## CI report:
* 0aa90c60d5e038daeb11b9ed90ef1226a4410613 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251835#comment-17251835
]
Yang Wang commented on FLINK-17598:
---
cc [~boris.lublin...@cna.com], do you think we still need to
wangyang0918 commented on pull request #49:
URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748171203
@tillrohrmann I have updated this PR. Once this PR is merged, we could ping
the docker guys for merging the docker publishing PR for 1.12.0.
[
https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-20675:
-
Description:
After FLINK-12364, no mater how many times of asynchronous part of checkpoint
on task
[
https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251834#comment-17251834
]
Yun Tang commented on FLINK-20675:
--
cc [~pnowojski]
> Asynchronous checkpoint failure would not fail
Yun Tang created FLINK-20675:
Summary: Asynchronous checkpoint failure would not fail the job
anymore
Key: FLINK-20675
URL: https://issues.apache.org/jira/browse/FLINK-20675
Project: Flink
flinkbot edited a comment on pull request #14312:
URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739
## CI report:
* 1e4d45934795e74502b7871d1cbad7380727ad22 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251825#comment-17251825
]
Piotr Nowojski commented on FLINK-20674:
Ideally we would have both bytes/records produced and
flinkbot edited a comment on pull request #14428:
URL: https://github.com/apache/flink/pull/14428#issuecomment-748082099
## CI report:
* c8d5bac964a6dd973db3e643118f4af50c82f7a5 Azure:
flinkbot edited a comment on pull request #14387:
URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624
## CI report:
* 47dcb9670fdea6129692d27b33dc13b620248600 Azure:
tillrohrmann commented on pull request #49:
URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748153256
Yes, this would be my suggestion in order to not break things within the
`1.12.x` release line.
This is
[
https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251821#comment-17251821
]
Till Rohrmann commented on FLINK-20648:
---
The address of the contender does not need to be known
xiaoHoly commented on a change in pull request #14387:
URL: https://github.com/apache/flink/pull/14387#discussion_r545900554
##
File path:
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcOptions.java
##
@@ -150,7 +168,7
[
https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19880.
---
Resolution: Fixed
Fixed in
- master: fc660274a5c7b4cdea00335cac87bdf5d421db92
- release-1.12:
flinkbot edited a comment on pull request #14423:
URL: https://github.com/apache/flink/pull/14423#issuecomment-748013167
## CI report:
* 0cd0435254c0858f52ad5bd5f7d998ce2b9797e1 Azure:
1 - 100 of 371 matches
Mail list logo