[GitHub] [flink-statefun] tzulitai commented on pull request #101: [FLINK-17287][github] Disable merge commit button

2020-05-03 Thread GitBox
tzulitai commented on pull request #101: URL: https://github.com/apache/flink-statefun/pull/101#issuecomment-623272705 LGTM, merging! Thanks @zentol. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
RocMarshal commented on a change in pull request #11979: URL: https://github.com/apache/flink/pull/11979#discussion_r419201525 ## File path: docs/training/event_driven.zh.md ## @@ -29,19 +29,18 @@ under the License. ## Process Functions -### Introduction +### 介绍 -A

[GitHub] [flink] RocMarshal commented on a change in pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
RocMarshal commented on a change in pull request #11979: URL: https://github.com/apache/flink/pull/11979#discussion_r419201525 ## File path: docs/training/event_driven.zh.md ## @@ -29,19 +29,18 @@ under the License. ## Process Functions -### Introduction +### 介绍 -A

[GitHub] [flink] RocMarshal commented on a change in pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
RocMarshal commented on a change in pull request #11979: URL: https://github.com/apache/flink/pull/11979#discussion_r419201078 ## File path: docs/training/event_driven.zh.md ## @@ -29,19 +29,18 @@ under the License. ## Process Functions -### Introduction +### 介绍 -A

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
RocMarshal commented on a change in pull request #11979: URL: https://github.com/apache/flink/pull/11979#discussion_r419193254 ## File path: docs/training/event_driven.zh.md ## @@ -269,38 +259,35 @@ SingleOutputStreamOperator hourlyTips = fares

[GitHub] [flink] becketqin commented on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-03 Thread GitBox
becketqin commented on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-623213157 My updated patch did exactly what you said. I will merge the patch once the CI passes. This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116 ## CI report: * 0cf113b8691682a97bfe53df12564ac72018fb07 Azure:

[GitHub] [flink] StephanEwen commented on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-03 Thread GitBox
StephanEwen commented on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-623172729 To expedite the merge a bit, how about just (1) switching to `DataOutputStream` (that is a JDK class, not a Flink class, I assume you searched for it in the Flink

[GitHub] [flink] flinkbot edited a comment on pull request #11980: [FLINK-17499][state-processor-api] LazyTimerService used to register …

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11980: URL: https://github.com/apache/flink/pull/11980#issuecomment-623160625 ## CI report: * 67689c04b081510c3992d369a65735ec010aa468 Azure:

[GitHub] [flink] flinkbot commented on pull request #11980: [FLINK-17499][state-processor-api] LazyTimerService used to register …

2020-05-03 Thread GitBox
flinkbot commented on pull request #11980: URL: https://github.com/apache/flink/pull/11980#issuecomment-623160625 ## CI report: * 67689c04b081510c3992d369a65735ec010aa468 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #11980: [FLINK-17499][state-processor-api] LazyTimerService used to register …

2020-05-03 Thread GitBox
flinkbot commented on pull request #11980: URL: https://github.com/apache/flink/pull/11980#issuecomment-623158253 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

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

2020-05-03 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-17499: - Summary: LazyTimerService used to register timers via State Processing API incorrectly mixes

[jira] [Commented] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

2020-05-03 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098523#comment-17098523 ] Seth Wiesman commented on FLINK-17499: -- Thanks for opening this ticket! > LazyTimerService used to

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

2020-05-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17499: --- Labels: pull-request-available (was: ) > LazyTimerService used to register timers via

[GitHub] [flink] flinkbot edited a comment on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-623121072 ## CI report: * 574cf931d200bcbebcb1f3740ccb80270dfed470 Azure:

[GitHub] [flink] sjwiesman opened a new pull request #11980: [FLINK-17499][state-processor-api] LazyTimerService used to register …

2020-05-03 Thread GitBox
sjwiesman opened a new pull request #11980: URL: https://github.com/apache/flink/pull/11980 …timers via State Processing API incorectly mixes event time timers with processing time timers ## What is the purpose of the change Fix registration of timer service in state

[GitHub] [flink] flinkbot edited a comment on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116 ## CI report: * 89d8665ddbcdd11cff8652f39fea4d0601f809ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116 ## CI report: * 89d8665ddbcdd11cff8652f39fea4d0601f809ac Azure:

[jira] [Commented] (FLINK-17393) Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

2020-05-03 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098515#comment-17098515 ] Etienne Chauchot commented on FLINK-17393: -- I just started working on Flink, so I might not

[GitHub] [flink] tweise commented on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

2020-05-03 Thread GitBox
tweise commented on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-623148841 @rmetzger @carp84 thanks for the review. Double checked for transitive dependency changes and found none. PTAL.

[GitHub] [flink] XBaith commented on a change in pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
XBaith commented on a change in pull request #11979: URL: https://github.com/apache/flink/pull/11979#discussion_r419131197 ## File path: docs/training/event_driven.zh.md ## @@ -29,19 +29,18 @@ under the License. ## Process Functions -### Introduction +### 介绍 -A

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

2020-05-03 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-17499: - Affects Version/s: 1.11.0 > LazyTimerService used to register timers via State Processing API

[jira] [Assigned] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

2020-05-03 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-17499: Assignee: Seth Wiesman > LazyTimerService used to register timers via State Processing

[GitHub] [flink] flinkbot commented on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot commented on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
flinkbot commented on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623134054 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

[jira] [Updated] (FLINK-17291) Translate tutorial on event-driven applications to chinese

2020-05-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17291: --- Labels: pull-request-available (was: ) > Translate tutorial on event-driven applications

[GitHub] [flink] RocMarshal opened a new pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-03 Thread GitBox
RocMarshal opened a new pull request #11979: URL: https://github.com/apache/flink/pull/11979 Translate 'docs/training/event_driven.zh.md' to Chinese ## What is the purpose of the change *Rich Chinese documents of Flink* ## Brief change log -

[jira] [Assigned] (FLINK-17423) Support Python UDTF in blink planner under batch mode

2020-05-03 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17423: --- Assignee: Huang Xingbo > Support Python UDTF in blink planner under batch mode >

[jira] [Commented] (FLINK-17423) Support Python UDTF in blink planner under batch mode

2020-05-03 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098484#comment-17098484 ] Hequn Cheng commented on FLINK-17423: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-17423) Support Python UDTF in blink planner under batch mode

2020-05-03 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17423. --- Resolution: Resolved > Support Python UDTF in blink planner under batch mode >

[GitHub] [flink] flinkbot edited a comment on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-03 Thread GitBox
flinkbot edited a comment on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-623121072 ## CI report: * 574cf931d200bcbebcb1f3740ccb80270dfed470 Azure:

[GitHub] [flink] flinkbot commented on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-03 Thread GitBox
flinkbot commented on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-623121072 ## CI report: * 574cf931d200bcbebcb1f3740ccb80270dfed470 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

2020-05-03 Thread Adam Laczynski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Laczynski updated FLINK-17499: --- Description: @Override public void register*ProcessingTime*Timer(long time) {  

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

2020-05-03 Thread Adam Laczynski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Laczynski updated FLINK-17499: --- Description: @Override public void

[jira] [Created] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

2020-05-03 Thread Adam Laczynski (Jira)
Adam Laczynski created FLINK-17499: -- Summary: LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers Key: FLINK-17499 URL:

[GitHub] [flink] carp84 commented on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

2020-05-03 Thread GitBox
carp84 commented on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-623119306 Second @rmetzger . I checked the shade plugin output after the version change and confirmed there's no additional bundled dependency introduced, so a one-line update in

[GitHub] [flink] flinkbot commented on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-03 Thread GitBox
flinkbot commented on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-623118502 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] caozhen1937 opened a new pull request #11978: [FLINK-16086][docs]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-03 Thread GitBox
caozhen1937 opened a new pull request #11978: URL: https://github.com/apache/flink/pull/11978 ## What is the purpose of the change Translate "Temporal Tables" page of "Streaming Concepts" into Chinese This

[jira] [Updated] (FLINK-16086) Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16086: --- Labels: pull-request-available (was: ) > Translate "Temporal Tables" page of "Streaming

[GitHub] [flink] becketqin commented on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-03 Thread GitBox
becketqin commented on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-623112338 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-17498) MapCancelingITCase.testMapCancelling fails with timeout

2020-05-03 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17498: -- Summary: MapCancelingITCase.testMapCancelling fails with timeout Key: FLINK-17498 URL: https://issues.apache.org/jira/browse/FLINK-17498 Project: Flink

[jira] [Updated] (FLINK-17498) MapCancelingITCase.testMapCancelling fails with timeout

2020-05-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17498: --- Description: CI:

[jira] [Comment Edited] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-05-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098429#comment-17098429 ] Robert Metzger edited comment on FLINK-17274 at 5/3/20, 1:24 PM: -

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-05-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098429#comment-17098429 ] Robert Metzger commented on FLINK-17274: Another case:

[jira] [Commented] (FLINK-17497) Quickstarts Java nightly end-to-end test fails with "class file has wrong version 55.0, should be 52.0"

2020-05-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098428#comment-17098428 ] Robert Metzger commented on FLINK-17497: Most likely a jdk8, jdk11 cache mixup. I will open a PR

[jira] [Created] (FLINK-17497) Quickstarts Java nightly end-to-end test fails with "class file has wrong version 55.0, should be 52.0"

2020-05-03 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17497: -- Summary: Quickstarts Java nightly end-to-end test fails with "class file has wrong version 55.0, should be 52.0" Key: FLINK-17497 URL:

[jira] [Updated] (FLINK-17342) Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

2020-05-03 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17342: -- Summary: Schedule savepoint if max-inflight-checkpoints limit is reached

[jira] [Closed] (FLINK-16125) Make zookeeper.connect optional for Kafka connectors

2020-05-03 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-16125. Fix Version/s: (was: 1.10.2) 1.10.1 Resolution: Fixed Backported to

[jira] [Commented] (FLINK-16521) Remove unused FileUtils#isClassFile

2020-05-03 Thread Guru Prasad (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098353#comment-17098353 ] Guru Prasad commented on FLINK-16521: - Hi, Can I work on this > Remove unused FileUtils#isClassFile

[GitHub] [flink] rmetzger commented on a change in pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

2020-05-03 Thread GitBox
rmetzger commented on a change in pull request #11975: URL: https://github.com/apache/flink/pull/11975#discussion_r419070528 ## File path: flink-connectors/flink-connector-kinesis/pom.xml ## @@ -35,7 +35,7 @@ under the License. 1.11.603