zhuzhurk commented on a change in pull request #16436:
URL: https://github.com/apache/flink/pull/16436#discussion_r670187546
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapter/DefaultResultPartitionTest.java
##
@@ -34,24 +33,18 @@
/** Unit te
zhuzhurk commented on a change in pull request #16436:
URL: https://github.com/apache/flink/pull/16436#discussion_r670186121
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java
##
@@ -88,6 +88,7 @@ private static void con
zhuzhurk commented on a change in pull request #16436:
URL: https://github.com/apache/flink/pull/16436#discussion_r670184762
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java
##
@@ -171,4 +177,30 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-23299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-23299:
-
Fix Version/s: (was: shaded-1.14)
shaded-14.0
> Bump flink-shaded
[
https://issues.apache.org/jira/browse/FLINK-23326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-23326:
-
Fix Version/s: (was: shaded-1.14)
shaded-14.0
> Bump flink-shaded
[
https://issues.apache.org/jira/browse/FLINK-23325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-23325:
-
Fix Version/s: (was: shaded-1.14)
shaded-14.0
> Bump flink-shaded
[
https://issues.apache.org/jira/browse/FLINK-23291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-23291:
-
Fix Version/s: (was: shaded-1.14)
shaded-14.0
> Bump flink-shaded
zhuzhurk commented on a change in pull request #16436:
URL: https://github.com/apache/flink/pull/16436#discussion_r670184762
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java
##
@@ -171,4 +177,30 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-22452:
---
Fix Version/s: 1.14.0
> Support specifying custom transactional.id prefix in FlinkKafkaProdu
pnowojski commented on a change in pull request #16494:
URL: https://github.com/apache/flink/pull/16494#discussion_r670181201
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java
##
@@ -597
[
https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381093#comment-17381093
]
waywtdcc commented on FLINK-23379:
--
Hi,[~lzljs3620320]
Yeah, but what I want is the ap
[
https://issues.apache.org/jira/browse/FLINK-23214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-23214:
Parent: FLINK-22910
Issue Type: Sub-task (was: Improvement)
> Make ShuffleMaster a cluste
[
https://issues.apache.org/jira/browse/FLINK-23214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-23214:
Parent: (was: FLINK-22672)
Issue Type: Improvement (was: Sub-task)
> Make ShuffleMast
[
https://issues.apache.org/jira/browse/FLINK-22674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-22674:
Parent: FLINK-22910
Issue Type: Sub-task (was: Improvement)
> Provide JobID when apply sh
[
https://issues.apache.org/jira/browse/FLINK-22674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-22674:
Parent: (was: FLINK-22672)
Issue Type: Improvement (was: Sub-task)
> Provide JobID wh
[
https://issues.apache.org/jira/browse/FLINK-23249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-23249:
Parent: FLINK-22910
Issue Type: Sub-task (was: Improvement)
> Introduce ShuffleMasterCont
[
https://issues.apache.org/jira/browse/FLINK-23249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-23249:
Parent: (was: FLINK-22672)
Issue Type: Improvement (was: Sub-task)
> Introduce Shuffl
flinkbot edited a comment on pull request #16482:
URL: https://github.com/apache/flink/pull/16482#issuecomment-879006434
## CI report:
* 1558f0294c43ac98d7d9b00973f4952d4c2b2d18 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-22675:
Parent: FLINK-22910
Issue Type: Sub-task (was: Improvement)
> Add lifecycle methods to Sh
[
https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381086#comment-17381086
]
Jingsong Lee edited comment on FLINK-23379 at 7/15/21, 6:42 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-22675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-22675:
Parent: (was: FLINK-22672)
Issue Type: Improvement (was: Sub-task)
> Add lifecycle me
[
https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381086#comment-17381086
]
Jingsong Lee commented on FLINK-23379:
--
There is no definition of primary key in th
[
https://issues.apache.org/jira/browse/FLINK-22910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-22910:
Parent: (was: FLINK-22672)
Issue Type: Improvement (was: Sub-task)
> Refine ShuffleMa
jinxing64 edited a comment on pull request #16118:
URL: https://github.com/apache/flink/pull/16118#issuecomment-880419048
Thanks a lot for the concern @guoweiM ; How do you think? @tillrohrmann and
@zhuzhurk
It will be great to hear comments from you Flink master. I will keep
refining
[
https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381084#comment-17381084
]
Jingsong Lee commented on FLINK-23379:
--
Hi [~waywtdcc], the order in a distributed
[
https://issues.apache.org/jira/browse/FLINK-23107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-23107.
Resolution: Fixed
master: 3abec22c53662e69f82e6bc0d15f28e77b712fe3
> Separate deduplicate rank fr
JingsongLi merged pull request #16434:
URL: https://github.com/apache/flink/pull/16434
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsu
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381076#comment-17381076
]
Piotr Nowojski edited comment on FLINK-23208 at 7/15/21, 6:29 AM:
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381076#comment-17381076
]
Piotr Nowojski commented on FLINK-23208:
Great, thank [~wind_ljy]. Yes flink-ben
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-23208:
--
Assignee: Jiayi Liao
> Late processing timers need to wait 1ms at least to be fired
>
dmvk commented on pull request #16487:
URL: https://github.com/apache/flink/pull/16487#issuecomment-880432234
Hi @edu05, for CI failures, from a quick look, the flaky tests you're
hitting have been fixed super recently (~ tuesday). Can you please try to
rebase this on master?
--
This is
[
https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381072#comment-17381072
]
Robert Metzger commented on FLINK-22483:
It seems like the
{{CheckpointStoreITC
rmetzger commented on a change in pull request #16487:
URL: https://github.com/apache/flink/pull/16487#discussion_r670168083
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerUtilsTest.java
##
@@ -21,17 +21,30 @@
import org.apache.flink.api
[
https://issues.apache.org/jira/browse/FLINK-23385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-23385:
-
Summary: Fix nullability of COALESCE (was:
org.apache.flink.table.api.TableException when using
[
https://issues.apache.org/jira/browse/FLINK-23392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-23392:
-
Description:
The benchmarks currently simply run against a local environment, which mean
[
https://issues.apache.org/jira/browse/FLINK-23385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381070#comment-17381070
]
Timo Walther commented on FLINK-23385:
--
I renamed the issue. There are a couple of
flinkbot edited a comment on pull request #16482:
URL: https://github.com/apache/flink/pull/16482#issuecomment-879006434
## CI report:
* 0a50b6ae5dc78a0a8d03880c9b6e6aca83552219 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16434:
URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346
## CI report:
* 12f7fa66c5185c7a3375bf4cbd19b2df1f82a04a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-871994148
## CI report:
* b7d78128ac4f1d7b8fa086c82748439928a10fee Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Chesnay Schepler created FLINK-23392:
Summary: Benchmarks should exclude startup/shutdown time
Key: FLINK-23392
URL: https://issues.apache.org/jira/browse/FLINK-23392
Project: Flink
Issue
flinkbot edited a comment on pull request #15899:
URL: https://github.com/apache/flink/pull/15899#issuecomment-839417893
## CI report:
* d3d33b6b0e90ea1bb8f4597940598db7f2de5c11 UNKNOWN
* 75dd900bfb5480c29d82cbe68e11dfde3b9a57e9 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-16093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-16093.
---
Fix Version/s: 1.14.0
Resolution: Fixed
Fixed in master: 1a195f5cc597b95c16adb2f4452622769c6480c6
>
wuchong merged pull request #16348:
URL: https://github.com/apache/flink/pull/16348
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubsc
[
https://issues.apache.org/jira/browse/FLINK-12415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-12415:
---
Assignee: wangzhao
> Translate "History Server" page into Chinese
> ---
[
https://issues.apache.org/jira/browse/FLINK-12415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-12415:
---
Assignee: wangzhao (was: wangzhao)
> Translate "History Server" page into Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-22871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381059#comment-17381059
]
Dian Fu commented on FLINK-22871:
-
[~wukong] What's the status of this JIRA? I'm asking
jinxing64 commented on pull request #16118:
URL: https://github.com/apache/flink/pull/16118#issuecomment-880419048
Thanks a lot for the concern @guoweiM ; How do you think? @tillrohrmann and
@zhuzhurk
It will be great to hear comments from you Flink master. I will keep
refining this PR
jinxing64 commented on pull request #16118:
URL: https://github.com/apache/flink/pull/16118#issuecomment-880417258
Thanks for comments @guoweiM .
Currently there are two data structures in JobMasterPartitionTrackerImpl:
1. `partitionTable`, which maintains the mapping from tmId to res
[
https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381048#comment-17381048
]
waywtdcc commented on FLINK-23379:
--
[~qingru zhang] Hello, I understand what you mean,
flinkbot edited a comment on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-871994148
## CI report:
* b7d78128ac4f1d7b8fa086c82748439928a10fee Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #16184:
URL: https://github.com/apache/flink/pull/16184#issuecomment-863123325
## CI report:
* 88b40ab4dc9e1c8d62b8ac0eaf2d87340c1feb8e Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-871994148
## CI report:
* b7d78128ac4f1d7b8fa086c82748439928a10fee Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #16184:
URL: https://github.com/apache/flink/pull/16184#issuecomment-863123325
## CI report:
* 88b40ab4dc9e1c8d62b8ac0eaf2d87340c1feb8e Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381003#comment-17381003
]
JING ZHANG commented on FLINK-23379:
[~waywtdcc] You're right, however you could sol
ZhijieYang commented on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-880365624
> > @leonardBang Hi, This is my first time contribute code, so some of the
processes are not clear to me yet. Wait for the build means I don't need to do
anything else and th
flinkbot edited a comment on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-871994148
## CI report:
* b7d78128ac4f1d7b8fa086c82748439928a10fee Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
pltbkd commented on pull request #16357:
URL: https://github.com/apache/flink/pull/16357#issuecomment-880364616
>This entails that the time until marking someone as dead is threshold *
heartbeat interval. I hope that this definition is easy enough to understand
for our users.
I over
leonardBang commented on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-880363807
> @leonardBang Hi, This is my first time contribute code, so some of the
processes are not clear to me yet. Wait for the build means I don't need to do
anything else and the
flinkbot edited a comment on pull request #16434:
URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346
## CI report:
* 802d88a74c0e754769dd67780fe6599753f66efc Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-871994148
## CI report:
* b7d78128ac4f1d7b8fa086c82748439928a10fee Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15899:
URL: https://github.com/apache/flink/pull/15899#issuecomment-839417893
## CI report:
* d3d33b6b0e90ea1bb8f4597940598db7f2de5c11 UNKNOWN
* a13ae195d672eca62ad24304de6678533d665cb6 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-22893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-22893:
Assignee: Anton Kalashnikov
> ResumeCheckpointManuallyITCase hangs on azure
> ---
ranqiqiang commented on a change in pull request #16478:
URL: https://github.com/apache/flink/pull/16478#discussion_r670099944
##
File path: docs/content.zh/docs/concepts/stateful-stream-processing.md
##
@@ -24,342 +24,227 @@ under the License.
# 有状态流处理
-## What is State?
ranqiqiang commented on a change in pull request #16478:
URL: https://github.com/apache/flink/pull/16478#discussion_r670099338
##
File path: docs/content.zh/docs/concepts/stateful-stream-processing.md
##
@@ -24,342 +24,227 @@ under the License.
# 有状态流处理
-## What is State?
Jesuitry commented on pull request #9336:
URL: https://github.com/apache/flink/pull/9336#issuecomment-880352382
Can this be used in the fair scheduler?I set yarn.application.priority, but
it does not take effect.
--
This is an automated message from the Apache Git Service.
To respond to
ranqiqiang commented on a change in pull request #16478:
URL: https://github.com/apache/flink/pull/16478#discussion_r670097805
##
File path: docs/content.zh/docs/concepts/stateful-stream-processing.md
##
@@ -24,342 +24,227 @@ under the License.
# 有状态流处理
-## What is State?
Xintong Song created FLINK-23391:
Summary: KafkaSourceReaderTest.testKafkaSourceMetrics fails on
azure
Key: FLINK-23391
URL: https://issues.apache.org/jira/browse/FLINK-23391
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380968#comment-17380968
]
Xintong Song commented on FLINK-22198:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380965#comment-17380965
]
Xintong Song commented on FLINK-20329:
--
https://dev.azure.com/apache-flink/apache-f
Xintong Song created FLINK-23390:
Summary:
FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed
Key: FLINK-23390
URL: https://issues.apache.org/jira/browse/FLINK-23390
Project: Flink
ZhijieYang commented on pull request #16348:
URL: https://github.com/apache/flink/pull/16348#issuecomment-880346518
@RocMarshal So could I rebase these two commits to one now to looks clear?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
ZhijieYang commented on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-880345922
@flinkbot run azure
--
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 the specif
ZhijieYang commented on pull request #16337:
URL: https://github.com/apache/flink/pull/16337#issuecomment-880345578
@leonardBang Hi, This is my first time contribute code, so some of the
processes are not clear to me yet. Wait for the build means I don't need to do
anything else and the fl
[
https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380959#comment-17380959
]
Xintong Song commented on FLINK-22889:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380957#comment-17380957
]
Xintong Song commented on FLINK-22889:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-21751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380955#comment-17380955
]
Xintong Song commented on FLINK-21751:
--
https://dev.azure.com/apache-flink/apache-f
flinkbot edited a comment on pull request #16434:
URL: https://github.com/apache/flink/pull/16434#issuecomment-876881346
## CI report:
* 802d88a74c0e754769dd67780fe6599753f66efc Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15899:
URL: https://github.com/apache/flink/pull/15899#issuecomment-839417893
## CI report:
* d3d33b6b0e90ea1bb8f4597940598db7f2de5c11 UNKNOWN
* a13ae195d672eca62ad24304de6678533d665cb6 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
ZhijieYang commented on a change in pull request #16355:
URL: https://github.com/apache/flink/pull/16355#discussion_r670078863
##
File path:
docs/content.zh/docs/dev/datastream/fault-tolerance/serialization/third_party_serializers.md
##
@@ -3,8 +3,8 @@ title: 自定义序列化器
weight:
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380952#comment-17380952
]
Xintong Song commented on FLINK-22198:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380948#comment-17380948
]
Jiayi Liao commented on FLINK-23208:
[~pnowojski] I can work on this.
Should the b
zuoniduimian commented on a change in pull request #16490:
URL: https://github.com/apache/flink/pull/16490#discussion_r670074353
##
File path: docs/content.zh/docs/dev/datastream/application_parameters.md
##
@@ -24,28 +24,23 @@ specific language governing permissions and limita
yljee commented on pull request #16316:
URL: https://github.com/apache/flink/pull/16316#issuecomment-880335533
@RocMarshal Could you review my PR when you're free plz? Thx.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot edited a comment on pull request #16495:
URL: https://github.com/apache/flink/pull/16495#issuecomment-880293387
## CI report:
* 55715c7c78725b933ce751cb48d6a2275cf6f880 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
RollsBean commented on a change in pull request #16490:
URL: https://github.com/apache/flink/pull/16490#discussion_r670059732
##
File path: docs/content.zh/docs/dev/datastream/application_parameters.md
##
@@ -24,28 +24,23 @@ specific language governing permissions and limitatio
[
https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-20321:
-
Fix Version/s: (was: 1.12.6)
> Get NPE when using AvroDeserializationSchema to deserialize n
[
https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-21445:
-
Fix Version/s: (was: 1.12.6)
1.12.5
> Application mode does not set the c
[
https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-20321:
-
Fix Version/s: (was: 1.13.0)
1.12.5
> Get NPE when using AvroDeserializat
KarmaGYZ commented on pull request #15899:
URL: https://github.com/apache/flink/pull/15899#issuecomment-880330331
Thanks for the review and the awesome clean up in #16485, @tillrohrmann ! PR
rebased onto the latest master.
--
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-23182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-23182:
-
Fix Version/s: (was: 1.12.6)
1.12.5
> Connection leak in RMQSource
> ---
[
https://issues.apache.org/jira/browse/FLINK-23184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-23184:
-
Fix Version/s: (was: 1.12.6)
1.12.5
> CompileException Assignment convers
[
https://issues.apache.org/jira/browse/FLINK-23223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-23223:
-
Fix Version/s: (was: 1.12.6)
1.12.5
> When flushAlways is enabled the sub
[
https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-22443:
-
Fix Version/s: (was: 1.12.6)
1.12.5
> can not be execute an extreme long
[
https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-23248:
-
Fix Version/s: (was: 1.12.6)
1.12.5
> SinkWriter is not closed when faili
[
https://issues.apache.org/jira/browse/FLINK-23374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-23374.
Resolution: Fixed
master: f4afbf3e7de19ebcc5cb9324a22ba99fcd354dce
> Clean up logs produced by co
[
https://issues.apache.org/jira/browse/FLINK-12415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380940#comment-17380940
]
wangzhao commented on FLINK-12415:
--
Hi,[~jark] , can you assign this issue to me?
I'd l
JingsongLi merged pull request #16489:
URL: https://github.com/apache/flink/pull/16489
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsu
RocMarshal edited a comment on pull request #16348:
URL: https://github.com/apache/flink/pull/16348#issuecomment-880319744
@ZhijieYang Thanks for the update.
LGTM +1 in the mass.
Hi, please let us know what do you @wuchong think of this state .
--
This is an automated message from
RocMarshal commented on pull request #16348:
URL: https://github.com/apache/flink/pull/16348#issuecomment-880319744
@ZhijieYang Thanks for the update.
LGTM +1 in the mess.
Hi, please let us know what do you @wuchong think of this state .
--
This is an automated message from the Apa
flinkbot edited a comment on pull request #16495:
URL: https://github.com/apache/flink/pull/16495#issuecomment-880293387
## CI report:
* 55715c7c78725b933ce751cb48d6a2275cf6f880 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
1 - 100 of 366 matches
Mail list logo