[jira] [Created] (FLINK-7473) Possible Leak in GlobalWindows

Steve Jerman created FLINK-7473: --- Summary: Possible Leak in GlobalWindows Key: FLINK-7473 URL: https://issues.apache.org/jira/browse/FLINK-7473 Project: Flink Issue Type: Bug Componen

[jira] [Updated] (FLINK-7473) Possible Leak in GlobalWindows

[ https://issues.apache.org/jira/browse/FLINK-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steve Jerman updated FLINK-7473: Attachment: timerIssue.zip Sample project showing the issue. Look for org.apache.flink.streaming.ap

[GitHub] flink issue #4530: [FLINK-7245] [stream] Support holding back watermarks wit...

Github user xccui commented on the issue: https://github.com/apache/flink/pull/4530 Thanks for the comments @fhueske. I will pay more attention to the coding style. Actually, there are many ways to implement this feature. At first, I planed to override the `processWatermark`

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131587#comment-16131587 ] ASF GitHub Bot commented on FLINK-7245: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-7077) Implement task release to support dynamic scaling

[ https://issues.apache.org/jira/browse/FLINK-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131597#comment-16131597 ] ASF GitHub Bot commented on FLINK-7077: --- GitHub user EronWright opened a pull reques

[GitHub] flink pull request #4560: Flink 7077

GitHub user EronWright opened a pull request: https://github.com/apache/flink/pull/4560 Flink 7077 ## Description _This PR extends #4555 - please disregard commits from Aug 16, 2017._ [FLINK-7077] [mesos] Implement task release to support dynamic scaling

[GitHub] flink issue #4502: [FLINK-7062] [table, cep] Support the basic functionality...

Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4502 @fhueske @kl0u @dawidwys @wuchong Any feedback? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this featu

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131616#comment-16131616 ] Jark Wu commented on FLINK-7446: [~fhueske] Great! I will make a pull request in the next

[jira] [Commented] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE

[ https://issues.apache.org/jira/browse/FLINK-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131607#comment-16131607 ] ASF GitHub Bot commented on FLINK-7062: --- Github user dianfu commented on the issue:

[GitHub] flink issue #4482: [FLINK-4534] Fix synchronization issue in BucketingSink

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4482 lgtm --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] flink issue #4356: [FLINK-5486] Fix lacking of synchronization in BucketingS...

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4356 Run QA again ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if th

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131626#comment-16131626 ] ASF GitHub Bot commented on FLINK-4534: --- Github user tedyu commented on the issue:

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131628#comment-16131628 ] ASF GitHub Bot commented on FLINK-5486: --- Github user tedyu commented on the issue:

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131629#comment-16131629 ] Xingcan Cui commented on FLINK-7446: Now that the rowtime field is an existing one in

[jira] [Assigned] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-7446: -- Assignee: Jark Wu > Support to define an existing field as the rowtime field for TableSource >

[GitHub] flink issue #4356: [FLINK-5486] Fix lacking of synchronization in BucketingS...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4356 Okay. Ted. I will trigger the QA soon. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131631#comment-16131631 ] ASF GitHub Bot commented on FLINK-5486: --- Github user zhangminglei commented on the i

[jira] [Created] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs

Joe created FLINK-7474: -- Summary: Flink supports consuming data from and sink data to Azure eventhubs Key: FLINK-7474 URL: https://issues.apache.org/jira/browse/FLINK-7474 Project: Flink Issue Type: N

[jira] [Commented] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs

[ https://issues.apache.org/jira/browse/FLINK-7474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131685#comment-16131685 ] ASF GitHub Bot commented on FLINK-7474: --- Github user zhuganghuaonnet commented on th

[GitHub] flink issue #4535: Eventhubs-support read from and write to Azure eventhubs

Github user zhuganghuaonnet commented on the issue: https://github.com/apache/flink/pull/4535 @Tzu-Li Tai I have created a jira https://issues.apache.org/jira/browse/FLINK-7474. Pls help to review. Thx. :) F

[GitHub] flink issue #4535: Eventhubs-support read from and write to Azure eventhubs

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4535 @zhuganghuaonnet please also rebase this pull request (there are conflicting classes) and change the pull request title. --- If your project is set up for it, you can reply to this email and have y

[GitHub] flink issue #4557: [hotifx][streaming] Simplify state of TwoPhaseCommitSinkF...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4557 This LGTM, +1. Merging this .. Minor nitpick for the future: I think although this is a small fix, the nature of the fix still deserves a dedicated JIRA ticket for it. Hotfixes, AFAIK,

[GitHub] flink issue #4557: [hotifx][streaming] Simplify state of TwoPhaseCommitSinkF...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4557 Ok, I will create JIRA issues for such things in the future. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-7473) Possible Leak in GlobalWindows

[ https://issues.apache.org/jira/browse/FLINK-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131745#comment-16131745 ] Steve Jerman commented on FLINK-7473: - OK. I think I have figured my issue. When sett

[jira] [Commented] (FLINK-7442) Add option for using a child-first classloader for loading user code

[ https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131754#comment-16131754 ] ASF GitHub Bot commented on FLINK-7442: --- Github user aljoscha commented on the issue

[GitHub] flink issue #4554: [FLINK-7442] Add option for using child-first classloader...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4554 The system class loader stuff was leftover from an earlier version, I didn't mean to have that in there. In the first version I copied the `ChildFirstClassLoader` from https://github.com/ap

[jira] [Closed] (FLINK-7473) Possible Leak in GlobalWindows

[ https://issues.apache.org/jira/browse/FLINK-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steve Jerman closed FLINK-7473. --- Resolution: Not A Bug Release Note: user error. > Possible Leak in GlobalWindows > -

[GitHub] flink issue #4554: [FLINK-7442] Add option for using child-first classloader...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4554 This is the exception I got with the class loader from https://github.com/apache/flink/blob/fa11845b926f8371e9cee47775ca0e48176b686e/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/

[jira] [Commented] (FLINK-7442) Add option for using a child-first classloader for loading user code

[ https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131779#comment-16131779 ] ASF GitHub Bot commented on FLINK-7442: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-7129) Dynamically changing patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131782#comment-16131782 ] Dian Fu commented on FLINK-7129: Hi [~dawidwys], Thanks a lot for your work here. I'm very

[jira] [Created] (FLINK-7475) ListState support update

yf created FLINK-7475: - Summary: ListState support update Key: FLINK-7475 URL: https://issues.apache.org/jira/browse/FLINK-7475 Project: Flink Issue Type: Improvement Components: Core

[jira] [Comment Edited] (FLINK-7129) Dynamically changing patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131782#comment-16131782 ] Dian Fu edited comment on FLINK-7129 at 8/18/17 6:22 AM: - Hi [~daw

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131805#comment-16131805 ] Fabian Hueske commented on FLINK-7446: -- That's in fact a good question. In principle

[GitHub] flink issue #4530: [FLINK-7245] [stream] Support holding back watermarks wit...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4530 I see, didn't consider the private timeServiceManager. Maybe this is the best approach then. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131812#comment-16131812 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on the issue:

<    1   2