[GitHub] [flink] zhuzhurk commented on a change in pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-14 Thread GitBox
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

[GitHub] [flink] zhuzhurk commented on a change in pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-14 Thread GitBox
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

[GitHub] [flink] zhuzhurk commented on a change in pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-14 Thread GitBox
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

[jira] [Updated] (FLINK-23299) Bump flink-shaded-zookeeper 3.5 to 3.5.9

2021-07-14 Thread Chesnay Schepler (Jira)
[ 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

[jira] [Updated] (FLINK-23326) Bump flink-shaded-guava to 30.1.1

2021-07-14 Thread Chesnay Schepler (Jira)
[ 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

[jira] [Updated] (FLINK-23325) Bump flink-shaded-netty to 4.1.65

2021-07-14 Thread Chesnay Schepler (Jira)
[ 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

[jira] [Updated] (FLINK-23291) Bump flink-shaded-jackson to 2.12.4

2021-07-14 Thread Chesnay Schepler (Jira)
[ 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

[GitHub] [flink] zhuzhurk commented on a change in pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-14 Thread GitBox
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

[jira] [Updated] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-07-14 Thread Piotr Nowojski (Jira)
[ 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

[GitHub] [flink] pnowojski commented on a change in pull request #16494: [FLINK-22452][Connectors/Kafka] Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-07-14 Thread GitBox
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

[jira] [Commented] (FLINK-23379) interval left join null value result out of order

2021-07-14 Thread waywtdcc (Jira)
[ 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

[jira] [Updated] (FLINK-23214) Make ShuffleMaster a cluster level shared service

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Updated] (FLINK-23214) Make ShuffleMaster a cluster level shared service

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Updated] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Updated] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Updated] (FLINK-23249) Introduce ShuffleMasterContext to ShuffleMaster

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Updated] (FLINK-23249) Introduce ShuffleMasterContext to ShuffleMaster

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on pull request #16482: [FLINK-23369][docs][connector-hive][connector-kafka] Improve config options by using enums

2021-07-14 Thread GitBox
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

[jira] [Updated] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Comment Edited] (FLINK-23379) interval left join null value result out of order

2021-07-14 Thread Jingsong Lee (Jira)
[ 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: --

[jira] [Updated] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[jira] [Commented] (FLINK-23379) interval left join null value result out of order

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Updated] (FLINK-22910) Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-07-14 Thread Yingjie Cao (Jira)
[ 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

[GitHub] [flink] jinxing64 edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-07-14 Thread GitBox
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

[jira] [Commented] (FLINK-23379) interval left join null value result out of order

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Closed] (FLINK-23107) Separate deduplicate rank from rank functions

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[GitHub] [flink] JingsongLi merged pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-14 Thread GitBox
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

[jira] [Comment Edited] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

2021-07-14 Thread Piotr Nowojski (Jira)
[ 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:

[jira] [Commented] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

2021-07-14 Thread Piotr Nowojski (Jira)
[ 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

[jira] [Assigned] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

2021-07-14 Thread Piotr Nowojski (Jira)
[ 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 >

[GitHub] [flink] dmvk commented on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

2021-07-14 Thread GitBox
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

[jira] [Commented] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

2021-07-14 Thread Robert Metzger (Jira)
[ 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

[GitHub] [flink] rmetzger commented on a change in pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

2021-07-14 Thread GitBox
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

[jira] [Updated] (FLINK-23385) Fix nullability of COALESCE

2021-07-14 Thread Timo Walther (Jira)
[ 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

[jira] [Updated] (FLINK-23392) Benchmarks should exclude startup/shutdown time

2021-07-14 Thread Chesnay Schepler (Jira)
[ 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

[jira] [Commented] (FLINK-23385) Fix nullability of COALESCE

2021-07-14 Thread Timo Walther (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on pull request #16482: [FLINK-23369][docs][connector-hive][connector-kafka] Improve config options by using enums

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[jira] [Created] (FLINK-23392) Benchmarks should exclude startup/shutdown time

2021-07-14 Thread Chesnay Schepler (Jira)
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

[GitHub] [flink] flinkbot edited a comment on pull request #15899: [FLINK-22627][runtime] Remove SlotManagerImpl

2021-07-14 Thread GitBox
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

[jira] [Closed] (FLINK-16093) Translate "System Functions" page of "Functions" into Chinese

2021-07-14 Thread Jark Wu (Jira)
[ 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 >

[GitHub] [flink] wuchong merged pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

2021-07-14 Thread GitBox
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

[jira] [Assigned] (FLINK-12415) Translate "History Server" page into Chinese

2021-07-14 Thread Jark Wu (Jira)
[ 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 > ---

[jira] [Assigned] (FLINK-12415) Translate "History Server" page into Chinese

2021-07-14 Thread Jark Wu (Jira)
[ 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 > --

[jira] [Commented] (FLINK-22871) Support to execute PyFlink jobs in YARN application mode

2021-07-14 Thread Dian Fu (Jira)
[ 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

[GitHub] [flink] jinxing64 commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-07-14 Thread GitBox
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

[GitHub] [flink] jinxing64 commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-07-14 Thread GitBox
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

[jira] [Commented] (FLINK-23379) interval left join null value result out of order

2021-07-14 Thread waywtdcc (Jira)
[ 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,

[GitHub] [flink] flinkbot edited a comment on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16184: [FLINK-21089] Skip the execution of the fully finished operators after recovery

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16184: [FLINK-21089] Skip the execution of the fully finished operators after recovery

2021-07-14 Thread GitBox
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

[jira] [Commented] (FLINK-23379) interval left join null value result out of order

2021-07-14 Thread JING ZHANG (Jira)
[ 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

[GitHub] [flink] ZhijieYang commented on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] pltbkd commented on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

2021-07-14 Thread GitBox
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

[GitHub] [flink] leonardBang commented on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #15899: [FLINK-22627][runtime] Remove SlotManagerImpl

2021-07-14 Thread GitBox
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

[jira] [Assigned] (FLINK-22893) ResumeCheckpointManuallyITCase hangs on azure

2021-07-14 Thread Yuan Mei (Jira)
[ 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 > ---

[GitHub] [flink] ranqiqiang commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

2021-07-14 Thread GitBox
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?

[GitHub] [flink] ranqiqiang commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

2021-07-14 Thread GitBox
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?

[GitHub] [flink] Jesuitry commented on pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

2021-07-14 Thread GitBox
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

[GitHub] [flink] ranqiqiang commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

2021-07-14 Thread GitBox
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?

[jira] [Created] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-07-14 Thread Xintong Song (Jira)
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

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-07-14 Thread Xintong Song (Jira)
[ 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

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-07-14 Thread Xintong Song (Jira)
[ 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

[jira] [Created] (FLINK-23390) FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed

2021-07-14 Thread Xintong Song (Jira)
Xintong Song created FLINK-23390: Summary: FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed Key: FLINK-23390 URL: https://issues.apache.org/jira/browse/FLINK-23390 Project: Flink

[GitHub] [flink] ZhijieYang commented on pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

2021-07-14 Thread GitBox
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

[GitHub] [flink] ZhijieYang commented on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[GitHub] [flink] ZhijieYang commented on pull request #16337: [FLINK-22843][docs-zh]Document and code are inconsistent.

2021-07-14 Thread GitBox
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

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-07-14 Thread Xintong Song (Jira)
[ 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

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-07-14 Thread Xintong Song (Jira)
[ 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

[jira] [Commented] (FLINK-21751) Improve handling of freed slots if final requirement message is in flight

2021-07-14 Thread Xintong Song (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on pull request #16434: [FLINK-23107][table-runtime] Separate implementation of deduplicate r…

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #15899: [FLINK-22627][runtime] Remove SlotManagerImpl

2021-07-14 Thread GitBox
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

[GitHub] [flink] ZhijieYang commented on a change in pull request #16355: [hotfix] [docs] Fix document address does not match the actual web page.

2021-07-14 Thread GitBox
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:

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-07-14 Thread Xintong Song (Jira)
[ 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

[jira] [Commented] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

2021-07-14 Thread Jiayi Liao (Jira)
[ 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

[GitHub] [flink] zuoniduimian commented on a change in pull request #16490: [FLINK-23241][docs-zh] Translate the page of "Working with State " in…

2021-07-14 Thread GitBox
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

[GitHub] [flink] yljee commented on pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16495: [hotfix][docs][deployment]: update broken download url

2021-07-14 Thread GitBox
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

[GitHub] [flink] RollsBean commented on a change in pull request #16490: [FLINK-23241][docs-zh] Translate the page of "Working with State " in…

2021-07-14 Thread GitBox
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

[jira] [Updated] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Updated] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[GitHub] [flink] KarmaGYZ commented on pull request #15899: [FLINK-22627][runtime] Remove SlotManagerImpl

2021-07-14 Thread GitBox
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

[jira] [Updated] (FLINK-23182) Connection leak in RMQSource

2021-07-14 Thread Jingsong Lee (Jira)
[ 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 > ---

[jira] [Updated] (FLINK-23184) CompileException Assignment conversion not possible from type "int" to type "short"

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Updated] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Updated] (FLINK-23248) SinkWriter is not closed when failing

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Closed] (FLINK-23374) Clean up logs produced by code splitter

2021-07-14 Thread Jingsong Lee (Jira)
[ 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

[jira] [Commented] (FLINK-12415) Translate "History Server" page into Chinese

2021-07-14 Thread wangzhao (Jira)
[ 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

[GitHub] [flink] JingsongLi merged pull request #16489: [FLINK-23374][table-code-splitter] Clean up logs produced by code splitter

2021-07-14 Thread GitBox
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

[GitHub] [flink] RocMarshal edited a comment on pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

2021-07-14 Thread GitBox
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

[GitHub] [flink] RocMarshal commented on pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

2021-07-14 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on pull request #16495: [hotfix][docs][deployment]: update broken download url

2021-07-14 Thread GitBox
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   2   3   4   >