[GitHub] [flink] flinkbot edited a comment on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881087694 ## CI report: * e4f43924338b2bc62d3c5b2f4d669401d903e0ad UNKNOWN * 8d866984c1a9fec8a9a50727cd89b92540f30ebe Azure:

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

2021-07-15 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] [Assigned] (FLINK-12415) Translate "History Server" page into Chinese

2021-07-15 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] [Commented] (FLINK-23385) Fix nullability of COALESCE

2021-07-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381070#comment-17381070 ] Timo Walther commented on FLINK-23385: -- I renamed the issue. There are a couple of functions that

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381086#comment-17381086 ] Jingsong Lee commented on FLINK-23379: -- There is no definition of primary key in the SQL. So Flink

[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-15 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 ## @@

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

2021-07-15 Thread GitBox
tillrohrmann commented on pull request #15899: URL: https://github.com/apache/flink/pull/15899#issuecomment-880457015 Great, thanks @KarmaGYZ. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

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

2021-07-15 Thread GitBox
dmvk commented on pull request #16484: URL: https://github.com/apache/flink/pull/16484#issuecomment-880471857 Replaced by https://github.com/apache/flink/pull/16487 @edu05 For a future reference, there is no need to close & re-open the PR. It may take some time for CI to re-run as

[GitHub] [flink] flinkbot edited a comment on pull request #16412: Draft Materialization master

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16412: URL: https://github.com/apache/flink/pull/16412#issuecomment-875532108 ## CI report: * b9a4748edb5b88e370277322d9ad684248cbfed7 Azure:

[GitHub] [flink] dawidwys commented on pull request #16493: [FLINK-21246] Fail fast if a failure occurs when triggering a checkpoint on a Task

2021-07-15 Thread GitBox
dawidwys commented on pull request #16493: URL: https://github.com/apache/flink/pull/16493#issuecomment-880472040 @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

[GitHub] [flink] flinkbot commented on pull request #16497: [FLINK-23371] Disable progressive watermarks for bounded SourceFunctions

2021-07-15 Thread GitBox
flinkbot commented on pull request #16497: URL: https://github.com/apache/flink/pull/16497#issuecomment-880490839 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

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

2021-07-15 Thread GitBox
JingsongLi merged pull request #16337: URL: https://github.com/apache/flink/pull/16337 -- 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:

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-15 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong commented on FLINK-23324: -- This following is Postgres table DDL . {code:sql} create table foo

[jira] [Updated] (FLINK-23395) Bump Okhttp to 3.14.9

2021-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23395: --- Labels: pull-request-available (was: ) > Bump Okhttp to 3.14.9 > - > >

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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-23291) Bump flink-shaded-jackson to 2.12.4

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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] [Commented] (FLINK-22528) Document latency tracking metrics for state accesses

2021-07-15 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381098#comment-17381098 ] Yun Tang commented on FLINK-22528: -- [~alpinegizmo], it seems that I did not fully understand your

[GitHub] [flink-web] zentol opened a new pull request #458: Add flink-shaded 14.0

2021-07-15 Thread GitBox
zentol opened a new pull request #458: URL: https://github.com/apache/flink-web/pull/458 -- 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:

[jira] [Assigned] (FLINK-23204) Provide StateBackends access to MailboxExecutor

2021-07-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-23204: Assignee: Yuan Mei > Provide StateBackends access to MailboxExecutor >

[GitHub] [flink] tsreaper opened a new pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

2021-07-15 Thread GitBox
tsreaper opened a new pull request #16496: URL: https://github.com/apache/flink/pull/16496 ## What is the purpose of the change Currently Java code splitter only supports functions with no return value and no return statements. However generated classes like `GeneratedProjection`

[jira] [Updated] (FLINK-23363) JavaCodeSplitter can not split the code from ProjectionCodeGenerator

2021-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23363: --- Labels: pull-request-available (was: ) > JavaCodeSplitter can not split the code from

[GitHub] [flink] tillrohrmann closed pull request #15899: [FLINK-22627][runtime] Remove SlotManagerImpl

2021-07-15 Thread GitBox
tillrohrmann closed pull request #15899: URL: https://github.com/apache/flink/pull/15899 -- 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:

[jira] [Assigned] (FLINK-21090) Enable Checkpoints after tasks finished

2021-07-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-21090: Assignee: Dawid Wysakowicz > Enable Checkpoints after tasks finished >

[jira] [Closed] (FLINK-21089) Skip the execution of the fully finished operators after recovery

2021-07-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21089. Resolution: Implemented Implemented in

[GitHub] [flink] dawidwys merged pull request #16184: [FLINK-21089] Skip the execution of the fully finished operators after recovery

2021-07-15 Thread GitBox
dawidwys merged pull request #16184: URL: https://github.com/apache/flink/pull/16184 -- 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:

[jira] [Updated] (FLINK-23371) Disable AutoWatermarkInterval for bounded legacy sources

2021-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23371: --- Labels: pull-request-available (was: ) > Disable AutoWatermarkInterval for bounded legacy

[GitHub] [flink] flinkbot commented on pull request #16498: [WIP][FLINK-23354][blob] Limit the size of blob cache on TaskExecutor

2021-07-15 Thread GitBox
flinkbot commented on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880494243 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

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670256039 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeUploader.java ## @@ -0,0 +1,112 @@ +/* + * Licensed

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

2021-07-15 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-23379: - Attachment: image-2021-07-15-16-53-59-228.png > interval left join null value result out of order >

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

2021-07-15 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381187#comment-17381187 ] waywtdcc commented on FLINK-23379: -- Him, [~lzljs3620320]  Ok thanks, let me try > interval left join

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

2021-07-15 Thread GitBox
Thesharing commented on pull request #16436: URL: https://github.com/apache/flink/pull/16436#issuecomment-880521544 @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

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-15 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381189#comment-17381189 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 9:00 AM: If we don't use

[GitHub] [flink-benchmarks] zentol commented on a change in pull request #21: [FLINK-23393] Fix logging setup

2021-07-15 Thread GitBox
zentol commented on a change in pull request #21: URL: https://github.com/apache/flink-benchmarks/pull/21#discussion_r670232172 ## File path: src/main/resources/log4j2-test.properties ## @@ -16,8 +16,13 @@ # limitations under the License.

[jira] [Commented] (FLINK-23396) Exception when restoring SQL job after upgrade from 1.12 to 1.13

2021-07-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381196#comment-17381196 ] Dawid Wysakowicz commented on FLINK-23396: -- SQL does not support Flink version upgrades for

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

2021-07-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381059#comment-17381059 ] Dian Fu commented on FLINK-22871: - [~wukong] What's the status of this JIRA? I'm asking because we're

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381084#comment-17381084 ] Jingsong Lee commented on FLINK-23379: -- Hi [~waywtdcc], the order in a distributed system is not

[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-15 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] [Updated] (FLINK-22675) Add lifecycle methods to ShuffleMaster

2021-07-15 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

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

2021-07-15 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381093#comment-17381093 ] waywtdcc commented on FLINK-23379: -- Hi,[~lzljs3620320] Yeah, but what I want is the append flow, which

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

2021-07-15 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

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

2021-07-15 Thread GitBox
zhuzhurk commented on a change in pull request #16436: URL: https://github.com/apache/flink/pull/16436#discussion_r670189322 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java ## @@ -201,13 +182,11 @@

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

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381103#comment-17381103 ] Jingsong Lee commented on FLINK-23379: -- You can't expect the order of the append stream.

[jira] [Created] (FLINK-23393) Benchmarks do not support logging

2021-07-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23393: Summary: Benchmarks do not support logging Key: FLINK-23393 URL: https://issues.apache.org/jira/browse/FLINK-23393 Project: Flink Issue Type: Bug

[GitHub] [flink] dawidwys commented on a change in pull request #16184: [FLINK-21089] Skip the execution of the fully finished operators after recovery

2021-07-15 Thread GitBox
dawidwys commented on a change in pull request #16184: URL: https://github.com/apache/flink/pull/16184#discussion_r670208431 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java ## @@ -215,6 +224,11 @@ private void

[GitHub] [flink-benchmarks] zentol opened a new pull request #21: [FLINK-23393] Fix logging setup

2021-07-15 Thread GitBox
zentol opened a new pull request #21: URL: https://github.com/apache/flink-benchmarks/pull/21 - remove log4j1 dependencies - rename log4j.properties files - rename the production log4j2.properties file to log4j2-test.properties file, because log4j first searches for test

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

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16184: URL: https://github.com/apache/flink/pull/16184#issuecomment-863123325 ## CI report: * b73f0008d84db9b3eee077204929c65c14950179 Azure:

[jira] [Updated] (FLINK-23393) Benchmarks do not support logging

2021-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23393: --- Labels: pull-request-available (was: ) > Benchmarks do not support logging >

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

2021-07-15 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381132#comment-17381132 ] Anton Kalashnikov commented on FLINK-22893: --- This test fails because the job could not start 

[jira] [Updated] (FLINK-23354) Limit the size of blob cache on TaskExecutor

2021-07-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23354: --- Labels: pull-request-available (was: ) > Limit the size of blob cache on TaskExecutor >

[jira] [Commented] (FLINK-23389) AWS Glue Schema Registry JSON support for Apache Flink

2021-07-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381143#comment-17381143 ] Danny Cranmer commented on FLINK-23389: --- Thanks [~hhkkxxx133], I am happy to review and merge this

[GitHub] [flink] Thesharing opened a new pull request #16498: [WIP][FLINK-23354][blob] Limit the size of blob cache on TaskExecutor

2021-07-15 Thread GitBox
Thesharing opened a new pull request #16498: URL: https://github.com/apache/flink/pull/16498 This is a draft working in progress. ## What is the purpose of the change *This pull request intends to add a limit size for the blob cache on TaskExecutor. If the size limits

[GitHub] [flink] flinkbot edited a comment on pull request #16462: [FLINK-22985][table-runtime] Fix NullPointerException when comparing temporal type with invalid string literal

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16462: URL: https://github.com/apache/flink/pull/16462#issuecomment-878057921 ## CI report: * 9410a67218df14eb2fc114d4c3fba8326ac3ed4e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16496: URL: https://github.com/apache/flink/pull/16496#issuecomment-880472433 ## CI report: * 083d0d352b33c4d6d14edafadab399178a72ae8a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16493: [FLINK-21246] Fail fast if a failure occurs when triggering a checkpoint on a Task

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16493: URL: https://github.com/apache/flink/pull/16493#issuecomment-879898635 ## CI report: * Unknown: [CANCELED](TBD) * 64240375dbf80cd2fe8f8e2194533df8759be05c Azure:

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

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16490: URL: https://github.com/apache/flink/pull/16490#issuecomment-879692551 ## CI report: * d33f91558cbb55cfcd193d39306e493b8c22202d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16436: [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16436: URL: https://github.com/apache/flink/pull/16436#issuecomment-877041347 ## CI report: * e6562614d47f33e078a5b63feb5a4598a9ab66ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16462: [FLINK-22985][table-runtime] Fix NullPointerException when comparing temporal type with invalid string literal

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16462: URL: https://github.com/apache/flink/pull/16462#issuecomment-878057921 ## CI report: * 9410a67218df14eb2fc114d4c3fba8326ac3ed4e Azure:

[jira] [Updated] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

2021-07-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22861: Description: Add the following test case to

[jira] [Updated] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

2021-07-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22861: Description: Add the following test case to

[jira] [Issue Comment Deleted] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

2021-07-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22861: Comment: was deleted (was: I've also tried {code} @Test def myTest2(): Unit = {

[jira] [Comment Edited] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-15 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381186#comment-17381186 ] Ada Wong edited comment on FLINK-23324 at 7/15/21, 8:58 AM: This following

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-07-15 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381190#comment-17381190 ] Leonard Xu commented on FLINK-23324: Thanks [~ana4] for the detail report, it's a bug as we

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

2021-07-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381072#comment-17381072 ] Robert Metzger commented on FLINK-22483: It seems like the

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

2021-07-15 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

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

2021-07-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381076#comment-17381076 ] Piotr Nowojski commented on FLINK-23208: Great, thank [~wind_ljy]. Yes flink-benchmarks. Maybe

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

2021-07-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381076#comment-17381076 ] Piotr Nowojski edited comment on FLINK-23208 at 7/15/21, 6:29 AM: --

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

2021-07-15 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:

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

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

2021-07-15 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

[GitHub] [flink] dawidwys closed pull request #16361: [FLINK-23201][streaming] Calculate the alignment time only for the last checkpoint

2021-07-15 Thread GitBox
dawidwys closed pull request #16361: URL: https://github.com/apache/flink/pull/16361 -- 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:

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

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381116#comment-17381116 ] Jingsong Lee commented on FLINK-23379: -- [~waywtdcc] You can try "SELECT * from result_data_view

[GitHub] [flink] flinkbot edited a comment on pull request #16493: [FLINK-21246] Fail fast if a failure occurs when triggering a checkpoint on a Task

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16493: URL: https://github.com/apache/flink/pull/16493#issuecomment-879898635 ## CI report: * Unknown: [CANCELED](TBD) * 64240375dbf80cd2fe8f8e2194533df8759be05c UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot commented on pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

2021-07-15 Thread GitBox
flinkbot commented on pull request #16496: URL: https://github.com/apache/flink/pull/16496#issuecomment-880472433 ## CI report: * 083d0d352b33c4d6d14edafadab399178a72ae8a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-benchmarks] zentol commented on a change in pull request #21: [FLINK-23393] Fix logging setup

2021-07-15 Thread GitBox
zentol commented on a change in pull request #21: URL: https://github.com/apache/flink-benchmarks/pull/21#discussion_r670232172 ## File path: src/main/resources/log4j2-test.properties ## @@ -16,8 +16,13 @@ # limitations under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #16412: Draft Materialization master

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16412: URL: https://github.com/apache/flink/pull/16412#issuecomment-875532108 ## CI report: * 7d16473ddb835363dd0b4e22aa5760322118e07c Azure:

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

2021-07-15 Thread GitBox
flinkbot edited a comment on pull request #16337: URL: https://github.com/apache/flink/pull/16337#issuecomment-871994148 ## CI report: * b7d78128ac4f1d7b8fa086c82748439928a10fee Azure:

[jira] [Updated] (FLINK-23394) Add the HbaseOptions to the configuration generator

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23394: - Component/s: Table SQL / API > Add the HbaseOptions to the configuration generator >

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670246616 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,380 @@ +/* + *

[jira] [Commented] (FLINK-22843) Document and code are inconsistent.

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381153#comment-17381153 ] Jingsong Lee commented on FLINK-22843: -- Fixed via: master: 

[jira] [Closed] (FLINK-22843) Document and code are inconsistent.

2021-07-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22843. Fix Version/s: 1.14.0 Resolution: Fixed > Document and code are inconsistent. >

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

2021-07-15 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: - Issue Type: Improvement (was: Bug) > Benchmarks should exclude startup/shutdown time >

[GitHub] [flink] flinkbot commented on pull request #16497: [FLINK-23371] Disable progressive watermarks for bounded SourceFunctions

2021-07-15 Thread GitBox
flinkbot commented on pull request #16497: URL: https://github.com/apache/flink/pull/16497#issuecomment-880512409 ## CI report: * 9db47a99a384247b722036c6dc305bf75005a1d4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-23395) Bump Okhttp to 3.14.9

2021-07-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23395: Summary: Bump Okhttp to 3.14.9 Key: FLINK-23395 URL: https://issues.apache.org/jira/browse/FLINK-23395 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-23395) Bump Okhttp to 3.14.9

2021-07-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23395: - Issue Type: Improvement (was: Bug) > Bump Okhttp to 3.14.9 > - > >

[GitHub] [flink] flinkbot commented on pull request #16498: [WIP][FLINK-23354][blob] Limit the size of blob cache on TaskExecutor

2021-07-15 Thread GitBox
flinkbot commented on pull request #16498: URL: https://github.com/apache/flink/pull/16498#issuecomment-880512519 ## CI report: * 51db50340f762127f3c3c83dc86f0ac08f0877d9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

  1   2   3   4   5   6   >