[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

2020-06-29 Thread Aihua Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148331#comment-17148331 ] Aihua Li commented on FLINK-18433: -- I found the reason: There were three machines in the performance

[GitHub] [flink] klion26 commented on pull request #12778: [FLINK-18422][docs] Update Prefer tag in documentation 'Fault Tolerance training lesson'

2020-06-29 Thread GitBox
klion26 commented on pull request #12778: URL: https://github.com/apache/flink/pull/12778#issuecomment-651556575 @RocMarshal thanks for your contribution, could you please also change the Chinese version? This is an

[GitHub] [flink] pyscala commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-651554556 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] klion26 commented on a change in pull request #9648: [FLINK-13872] [docs-zh] Translate Operations Playground to Chinese

2020-06-29 Thread GitBox
klion26 commented on a change in pull request #9648: URL: https://github.com/apache/flink/pull/9648#discussion_r447418939 ## File path: docs/try-flink/flink-operations-playground.zh.md ## @@ -1,6 +1,6 @@ --- -title: "Flink 运维操场" -nav-title: 'Flink 运维操场' +title: "Flink操作场景"

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148327#comment-17148327 ] franklin DREW commented on FLINK-18446: --- Thank you very much for your help. Thank you. I found

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148324#comment-17148324 ] franklin DREW commented on FLINK-18446: --- Thank you very much for your help. I'm happy to help

[GitHub] [flink] klion26 commented on pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-06-29 Thread GitBox
klion26 commented on pull request #12237: URL: https://github.com/apache/flink/pull/12237#issuecomment-651547853 @twentyworld thanks for your continues contribution, could you please rebase the master to resolve the conflict

[GitHub] [flink] abhijitShandilya closed pull request #12735: [FLINK-18283][API/Core,API/DataStream] Update outdated Javadoc for clear method of ProcessWindowFunction

2020-06-29 Thread GitBox
abhijitShandilya closed pull request #12735: URL: https://github.com/apache/flink/pull/12735 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

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148320#comment-17148320 ] Dian Fu commented on FLINK-18446: - It should be, but I'm not sure if it's the case for your job. It can

[GitHub] [flink] klion26 commented on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

2020-06-29 Thread GitBox
klion26 commented on pull request #12665: URL: https://github.com/apache/flink/pull/12665#issuecomment-651543553 @yangyichao-mango thanks for your contribution. could you please rebase the master to resolve the conflict

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148317#comment-17148317 ] franklin DREW commented on FLINK-18446: --- The view originates from these flow tables and must be

[GitHub] [flink] pyscala commented on a change in pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
pyscala commented on a change in pull request #12566: URL: https://github.com/apache/flink/pull/12566#discussion_r447413574 ## File path:

[GitHub] [flink] pyscala commented on a change in pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
pyscala commented on a change in pull request #12566: URL: https://github.com/apache/flink/pull/12566#discussion_r447413463 ## File path:

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148315#comment-17148315 ] Dian Fu commented on FLINK-18446: - What's the order of the *CREATE VIEW* and *CREATE TABLE* statements?

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148308#comment-17148308 ] franklin DREW commented on FLINK-18446: --- !image-2020-06-30-12-51-24-055.png! > Flink SQL CEP can

[jira] [Updated] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] franklin DREW updated FLINK-18446: -- Attachment: image-2020-06-30-12-51-24-055.png > Flink SQL CEP can no recognize keywords

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148307#comment-17148307 ] franklin DREW commented on FLINK-18446: --- That shouldn't be the problem.I have the statement to

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 37870f3fa1326bc5bb704457bf90b232100b3ad7 Azure:

[GitHub] [flink-web] alpinegizmo commented on a change in pull request #345: [FLINK-17491] Translate Training page on project website

2020-06-29 Thread GitBox
alpinegizmo commented on a change in pull request #345: URL: https://github.com/apache/flink-web/pull/345#discussion_r447403628 ## File path: training.zh.md ## @@ -58,49 +57,49 @@ This training covers the fundamentals of Flink, including: -

[GitHub] [flink] becketqin commented on a change in pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
becketqin commented on a change in pull request #12566: URL: https://github.com/apache/flink/pull/12566#discussion_r447402523 ## File path:

[jira] [Created] (FLINK-18453) Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure

2020-06-29 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-18453: --- Summary: Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure Key: FLINK-18453 URL: https://issues.apache.org/jira/browse/FLINK-18453 Project: Flink

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148296#comment-17148296 ] Dian Fu commented on FLINK-18446: - >From the exception message, it seems that 

[jira] [Updated] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] franklin DREW updated FLINK-18446: -- Attachment: screenshot-1.png > Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148291#comment-17148291 ] franklin DREW commented on FLINK-18446: --- Thank you very much for taking the time out of your busy

[jira] [Comment Edited] (FLINK-18452) Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration

2020-06-29 Thread Weike Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148289#comment-17148289 ] Weike Dong edited comment on FLINK-18452 at 6/30/20, 3:46 AM: -- Hi

[jira] [Commented] (FLINK-18452) Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration

2020-06-29 Thread Weike Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148289#comment-17148289 ] Weike Dong commented on FLINK-18452: Hi [~jinyu.zj], would you please be so kind to look at this

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 61efd298ec52acc85170e8346dab552a4c2374be Azure:

[jira] [Created] (FLINK-18452) Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration

2020-06-29 Thread Weike Dong (Jira)
Weike Dong created FLINK-18452: -- Summary: Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration Key: FLINK-18452 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 61efd298ec52acc85170e8346dab552a4c2374be Azure:

[jira] [Created] (FLINK-18451) Flink HA on yarn may appear TaskManager double running when HA is restored

2020-06-29 Thread ming li (Jira)
ming li created FLINK-18451: --- Summary: Flink HA on yarn may appear TaskManager double running when HA is restored Key: FLINK-18451 URL: https://issues.apache.org/jira/browse/FLINK-18451 Project: Flink

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

2020-06-29 Thread Peidian Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148271#comment-17148271 ] Peidian Li commented on FLINK-10672: I'm sorry for the misinformation. Although I found the same

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

2020-06-29 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148270#comment-17148270 ] liufangliang commented on FLINK-18044: -- [~becket_qin] Thanks for your reply . Let's go through the

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 61efd298ec52acc85170e8346dab552a4c2374be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 40781f4bb00a7b053218bf98836bc57ecd2e0d5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 40781f4bb00a7b053218bf98836bc57ecd2e0d5d Azure:

[jira] [Assigned] (FLINK-18450) Add watermark alignment logic to SourceReaderBase.

2020-06-29 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-18450: Assignee: Qingsheng Ren > Add watermark alignment logic to SourceReaderBase. >

[jira] [Created] (FLINK-18450) Add watermark alignment logic to SourceReaderBase.

2020-06-29 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-18450: Summary: Add watermark alignment logic to SourceReaderBase. Key: FLINK-18450 URL: https://issues.apache.org/jira/browse/FLINK-18450 Project: Flink Issue

[GitHub] [flink] austince commented on a change in pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-06-29 Thread GitBox
austince commented on a change in pull request #12056: URL: https://github.com/apache/flink/pull/12056#discussion_r447326613 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQDeserializationSchema.java ##

[GitHub] [flink] austince commented on a change in pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-06-29 Thread GitBox
austince commented on a change in pull request #12056: URL: https://github.com/apache/flink/pull/12056#discussion_r447322135 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java ## @@ -77,6 +78,7

[GitHub] [flink] austince commented on a change in pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-06-29 Thread GitBox
austince commented on a change in pull request #12729: URL: https://github.com/apache/flink/pull/12729#discussion_r447320484 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java ## @@ -141,6

[jira] [Commented] (FLINK-12501) AvroTypeSerializer does not work with types generated by avrohugger

2020-06-29 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148125#comment-17148125 ] Georg Heiler commented on FLINK-12501: -- I am new to flink, but using 1.10.1 - I would assume this

[GitHub] [flink] tillrohrmann commented on pull request #8466: [FLINK-12336][monitoring] Add HTTPS support to InfluxDB reporter

2020-06-29 Thread GitBox
tillrohrmann commented on pull request #8466: URL: https://github.com/apache/flink/pull/8466#issuecomment-651267898 @jPrest yes you can open a new PR for it and cc me there. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-641701238 ## CI report: * c607aaed98c957173a95039f7da9df99143b21c0 Azure:

[GitHub] [flink] senegalo commented on a change in pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-06-29 Thread GitBox
senegalo commented on a change in pull request #12729: URL: https://github.com/apache/flink/pull/12729#discussion_r447089528 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java ## @@ -141,6

[GitHub] [flink] flinkbot edited a comment on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-641701238 ## CI report: * 887856985088fccc500f51a7ffc00dc8f619aeef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-651128128 ## CI report: * 094574fb81b87847568de465155b1eede8bb8771 Azure:

[jira] [Commented] (FLINK-18448) Update Google Cloud PubSub dependencies

2020-06-29 Thread Niels Basjes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147844#comment-17147844 ] Niels Basjes commented on FLINK-18448: -- This problem is triggered by the removal of the deprecated

[GitHub] [flink] pyscala commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-29 Thread GitBox
pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-651156382 > @pyscala Thanks for the patch. LGTM. Can we add a unit test for this? thanks @becketqin for your reply ,i will add a unit test for this

[GitHub] [flink] flinkbot edited a comment on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-651128128 ## CI report: * 094574fb81b87847568de465155b1eede8bb8771 Azure:

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

2020-06-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147739#comment-17147739 ] Piotr Nowojski edited comment on FLINK-18433 at 6/29/20, 2:16 PM: --

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

2020-06-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147739#comment-17147739 ] Piotr Nowojski edited comment on FLINK-18433 at 6/29/20, 2:16 PM: --

[GitHub] [flink] zhijiangW merged pull request #12787: [FLINK-18064][docs] Added unaligned checkpointing to docs. (1.11)

2020-06-29 Thread GitBox
zhijiangW merged pull request #12787: URL: https://github.com/apache/flink/pull/12787 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

[GitHub] [flink] austince commented on a change in pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-06-29 Thread GitBox
austince commented on a change in pull request #12056: URL: https://github.com/apache/flink/pull/12056#discussion_r446989048 ## File path: flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java ## @@ -382,6

[GitHub] [flink] austince commented on a change in pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-06-29 Thread GitBox
austince commented on a change in pull request #12729: URL: https://github.com/apache/flink/pull/12729#discussion_r446980990 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java ## @@ -141,6

[GitHub] [flink] flinkbot commented on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-06-29 Thread GitBox
flinkbot commented on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-651128128 ## CI report: * 094574fb81b87847568de465155b1eede8bb8771 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] jPrest commented on pull request #8466: [FLINK-12336][monitoring] Add HTTPS support to InfluxDB reporter

2020-06-29 Thread GitBox
jPrest commented on pull request #8466: URL: https://github.com/apache/flink/pull/8466#issuecomment-651123358 > @jPrest could you help updating this PR by rebasing it on the latest master? Then I'll help with finding someone for the review. @tillrohrmann I'd be happy to help.

[jira] [Commented] (FLINK-18362) Shipping jdk by shipping archive

2020-06-29 Thread gramo lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147768#comment-17147768 ] gramo lee commented on FLINK-18362: --- [~fly_in_gis] I just opened 

[GitHub] [flink] flinkbot commented on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-06-29 Thread GitBox
flinkbot commented on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-651116243 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] eogramow opened a new pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-06-29 Thread GitBox
eogramow opened a new pull request #12791: URL: https://github.com/apache/flink/pull/12791 ## What is the purpose of the change This PR makes Flink support shipping archives for Yarn deployment. It is very useful when deploying flink clusters or jobs on with compressed

[jira] [Updated] (FLINK-18362) Shipping jdk by shipping archive

2020-06-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18362: --- Labels: pull-request-available (was: ) > Shipping jdk by shipping archive >

[jira] [Updated] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18449: -- Description: In streaming api, we can use regex to find topic and enable partiton discovery

[jira] [Updated] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18449: -- Description: In streaming api, we can use regex to find topic and enable partiton discovery

[jira] [Closed] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2020-06-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14719. --- Resolution: Duplicate > Making Semantic configurable in Flinkkafkaproducer to support exactly-once >

[jira] [Commented] (FLINK-15221) supporting Exactly-once for kafka table APi

2020-06-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147756#comment-17147756 ] Jark Wu commented on FLINK-15221: - cc [~fsk119] > supporting Exactly-once for kafka table APi >

[jira] [Created] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-06-29 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18449: - Summary: Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API Key: FLINK-18449 URL: https://issues.apache.org/jira/browse/FLINK-18449

[jira] [Reopened] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reopened FLINK-14719: --- > Making Semantic configurable in Flinkkafkaproducer to support exactly-once > semantic in

[jira] [Commented] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2020-06-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147741#comment-17147741 ] Shengkai Fang commented on FLINK-14719: --- In release 1.11, we still can't set `semantic` in

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

2020-06-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147739#comment-17147739 ] Piotr Nowojski commented on FLINK-18433: [~AHeise], this metrics comes from:

[jira] [Closed] (FLINK-17920) Add the Python example of Interval Join in Table API doc

2020-06-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17920. --- Resolution: Resolved > Add the Python example of Interval Join in Table API doc >

[jira] [Commented] (FLINK-17920) Add the Python example of Interval Join in Table API doc

2020-06-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147732#comment-17147732 ] Hequn Cheng commented on FLINK-17920: - Resolve in 1.11.0 via

[jira] [Updated] (FLINK-17920) Add the Python example of Interval Join in Table API doc

2020-06-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17920: Summary: Add the Python example of Interval Join in Table API doc (was: Add the Python example

[GitHub] [flink] hequn8128 merged pull request #12779: [FLINK-17920][python][docs] Add the Python example of Time-windowed j…

2020-06-29 Thread GitBox
hequn8128 merged pull request #12779: URL: https://github.com/apache/flink/pull/12779 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

[GitHub] [flink] hequn8128 commented on pull request #12779: [FLINK-17920][python][docs] Add the Python example of Time-windowed j…

2020-06-29 Thread GitBox
hequn8128 commented on pull request #12779: URL: https://github.com/apache/flink/pull/12779#issuecomment-651061687 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #12786: [FLINK-18187] Backport PubSub e2e test instabilities fix to 1.11

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12786: URL: https://github.com/apache/flink/pull/12786#issuecomment-650942829 ## CI report: * 3e6fef5f0a4a3ad6793e63094f697fb53758b9c6 Azure:

[GitHub] [flink] wanglijie95 commented on pull request #12754: [FLINK-5717][streaming] Fix NPE on SessionWindows with ContinuousProc…

2020-06-29 Thread GitBox
wanglijie95 commented on pull request #12754: URL: https://github.com/apache/flink/pull/12754#issuecomment-651046093 OK, I will fix them by the way. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on pull request #12790: Es hotfix

2020-06-29 Thread GitBox
flinkbot commented on pull request #12790: URL: https://github.com/apache/flink/pull/12790#issuecomment-651039924 ## CI report: * d0bc4ce412abeda326a0b217737d1df046996d72 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12789: [hotfix][docs] Fix Python example in event_time doc

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12789: URL: https://github.com/apache/flink/pull/12789#issuecomment-651033547 ## CI report: * 9fd390809551bcd428b34d1bd3a1d508aae7568e Azure:

[jira] [Created] (FLINK-18448) Update Google Cloud PubSub dependencies

2020-06-29 Thread Niels Basjes (Jira)
Niels Basjes created FLINK-18448: Summary: Update Google Cloud PubSub dependencies Key: FLINK-18448 URL: https://issues.apache.org/jira/browse/FLINK-18448 Project: Flink Issue Type:

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-29 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147666#comment-17147666 ] Yangze Guo commented on FLINK-16713: Hi, [~jackylau]. I think we need to have a discussion and a

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147665#comment-17147665 ] Dian Fu commented on FLINK-18446: - MATCH_RECOGINZE should not be used in the where statement. > Flink

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147663#comment-17147663 ] franklin DREW commented on FLINK-18446: --- !image-2020-06-29-17-53-55-931.png! thanks! But I had

[jira] [Updated] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] franklin DREW updated FLINK-18446: -- Attachment: image-2020-06-29-17-53-55-931.png > Flink SQL CEP can no recognize keywords

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147658#comment-17147658 ] Dian Fu commented on FLINK-18446: - Never mind. :) > Flink SQL CEP can no recognize keywords

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147650#comment-17147650 ] franklin DREW commented on FLINK-18446: --- I'm terribly sorry, But I read it wrong. > Flink SQL CEP

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147645#comment-17147645 ] Dian Fu commented on FLINK-18446: - [~feiyu] Sorry that I'm not getting your point. What's wrong with the

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147639#comment-17147639 ] franklin DREW commented on FLINK-18446: --- !image-2020-06-29-17-14-00-144.png! The modification is

[jira] [Updated] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread franklin DREW (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] franklin DREW updated FLINK-18446: -- Attachment: image-2020-06-29-17-14-00-144.png > Flink SQL CEP can no recognize keywords

[GitHub] [flink] flinkbot commented on pull request #12790: Es hotfix

2020-06-29 Thread GitBox
flinkbot commented on pull request #12790: URL: https://github.com/apache/flink/pull/12790#issuecomment-651033804 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] flinkbot commented on pull request #12789: [hotfix][docs] Fix Python example in event_time doc

2020-06-29 Thread GitBox
flinkbot commented on pull request #12789: URL: https://github.com/apache/flink/pull/12789#issuecomment-651033547 ## CI report: * 9fd390809551bcd428b34d1bd3a1d508aae7568e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-651020186 ## CI report: * 40781f4bb00a7b053218bf98836bc57ecd2e0d5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12774: [FLINK-18395][FLINK-18388][docs-zh] Translate "ORC Format" and "CSV Format" page into Chinese

2020-06-29 Thread GitBox
flinkbot edited a comment on pull request #12774: URL: https://github.com/apache/flink/pull/12774#issuecomment-650206487 ## CI report: * 671da5238ac4dd548a0e1602cd2205a3bce417c3 UNKNOWN * f91c53fad2b2e26aa6ac06302917f8ecd58a6bf4 UNKNOWN *

[GitHub] [flink] liuyongvs opened a new pull request #12790: Es hotfix

2020-06-29 Thread GitBox
liuyongvs opened a new pull request #12790: URL: https://github.com/apache/flink/pull/12790 ## What is the purpose of the change *fix bug* ## Documentation - Does this pull request introduce a new feature? (no) - If yes, how is the feature documented? (not

[jira] [Created] (FLINK-18447) Add 'flink-connector-base' to 'flink-dist'

2020-06-29 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-18447: Summary: Add 'flink-connector-base' to 'flink-dist' Key: FLINK-18447 URL: https://issues.apache.org/jira/browse/FLINK-18447 Project: Flink Issue Type:

[GitHub] [flink] liyubin117 commented on pull request #12789: [hotfix][docs] Fix Python example in event_time doc

2020-06-29 Thread GitBox
liyubin117 commented on pull request #12789: URL: https://github.com/apache/flink/pull/12789#issuecomment-651028400 @klion26 I have corrected Python example's time character of event_time doc, please take a look This is an

[jira] [Comment Edited] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147627#comment-17147627 ] Dian Fu edited comment on FLINK-18446 at 6/29/20, 8:55 AM: --- It should be

[jira] [Closed] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18446. --- Resolution: Invalid Closed as invalid. > Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from

[jira] [Commented] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

2020-06-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147627#comment-17147627 ] Dian Fu commented on FLINK-18446: - It should be `MATCH_RECOGNIZE` instead of `MATCH_RECOGINZE`. > Flink

[GitHub] [flink] flinkbot commented on pull request #12789: [hotfix][docs] Fix Python example in event_time doc

2020-06-29 Thread GitBox
flinkbot commented on pull request #12789: URL: https://github.com/apache/flink/pull/12789#issuecomment-651025493 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] liyubin117 opened a new pull request #12789: [hotfix][docs] Fix Python example in event_time doc

2020-06-29 Thread GitBox
liyubin117 opened a new pull request #12789: URL: https://github.com/apache/flink/pull/12789 ## What is the purpose of the change the Python example in event_time doc use unexpected timecharacter ## Brief change log * Fix documentation ## Verifying this change

[GitHub] [flink] zhijiangW merged pull request #12722: [FLINK-18064][docs] Added unaligned checkpointing to docs.

2020-06-29 Thread GitBox
zhijiangW merged pull request #12722: URL: https://github.com/apache/flink/pull/12722 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

  1   2   >