[GitHub] flink issue #3574: [FLINK-5653] Add processing time OVER ROWS BETWEEN x PREC...

2017-03-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3574 I agree @huawei-flink, an efficient order-preserving state primitive (generic or specific for time) would be very helpful. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943177#comment-15943177 ] ASF GitHub Bot commented on FLINK-3466: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2252: [FLINK-3466] [runtime] Cancel state handled on state rest...

2017-03-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2252 I think it is yes. We worked around it in the meantime... --- 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-6073) Support for SQL inner queries for proctime

2017-03-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943164#comment-15943164 ] Fabian Hueske commented on FLINK-6073: -- Thanks for this proposal. I think we discussed this use case

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943135#comment-15943135 ] ASF GitHub Bot commented on FLINK-3257: --- Github user senorcarbone commented on a diff in the pull

[GitHub] flink pull request #1668: [FLINK-3257] Add Exactly-Once Processing Guarantee...

2017-03-27 Thread senorcarbone
Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/1668#discussion_r108152267 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java --- @@ -64,6 +70,22 @@ public void

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

2017-03-27 Thread Anna Beer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943118#comment-15943118 ] Anna Beer commented on FLINK-5785: -- [~Zentol] https://github.com/p4nna/flink/pull/1 > Add an Imputer for

[jira] [Commented] (FLINK-6157) Make TypeInformation fully serializable

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943117#comment-15943117 ] ASF GitHub Bot commented on FLINK-6157: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #3619: [FLINK-6157] [core] Make TypeInformation fully ser...

2017-03-27 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/3619 [FLINK-6157] [core] Make TypeInformation fully serializable This PR ensures that all type information in flink-core, flink-java, flink-scala is serializable. It introduces a test base for type

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

2017-03-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943111#comment-15943111 ] Chesnay Schepler commented on FLINK-5785: - [~beera] Could you provide a link to the pull request?

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

2017-03-27 Thread Anna Beer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943106#comment-15943106 ] Anna Beer commented on FLINK-5785: -- [~skonto] I made a pull request. The imputer works now for a DataSet

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943105#comment-15943105 ] ASF GitHub Bot commented on FLINK-3257: --- Github user senorcarbone commented on the issue:

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

2017-03-27 Thread senorcarbone
Github user senorcarbone commented on the issue: https://github.com/apache/flink/pull/1668 Thanks for the review @gyfora and @StephanEwen , these are very good points. @StephanEwen makes sense to not really index/keep metadata of individual records in log slices, it is extra

[jira] [Commented] (FLINK-6141) Add buffering service for stream operators

2017-03-27 Thread Ventura Del Monte (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943094#comment-15943094 ] Ventura Del Monte commented on FLINK-6141: -- I would like to tackle this issue, if it is fine with

[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943063#comment-15943063 ] ASF GitHub Bot commented on FLINK-2720: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3615: [FLINK-2720] support flink-storm metrics

2017-03-27 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3615 Multiple PRs are added to one ticket but the commit header must reference the Jira ID. I think the comments here are sufficient so there is no need to close and open a new PR. --- If your

[jira] [Closed] (FLINK-5911) Command-line parameters

2017-03-27 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5911. - Resolution: Implemented Implemented in f2a8bc92df583c0a6beb519fd8a84cb40edbd060 > Command-line

[jira] [Commented] (FLINK-5911) Command-line parameters

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943041#comment-15943041 ] ASF GitHub Bot commented on FLINK-5911: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3433: [FLINK-5911] [gelly] Command-line parameters

2017-03-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3433 --- 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 is

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943028#comment-15943028 ] Stephan Ewen commented on FLINK-5982: - [~till.rohrmann] Why not throw an illegal state exception in

[jira] [Commented] (FLINK-6194) More broken links in docs

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943002#comment-15943002 ] ASF GitHub Bot commented on FLINK-6194: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3618: [FLINK-6194] [docs] Fix broken links

2017-03-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3618 --- 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 is

[jira] [Closed] (FLINK-6194) More broken links in docs

2017-03-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6194. -- Resolution: Fixed Fix Version/s: 1.3.0 Merged in 037b5cb (master). > More broken links in docs

[GitHub] flink pull request #3618: [FLINK-6194] [docs] Fix broken links

2017-03-27 Thread patricklucas
GitHub user patricklucas opened a pull request: https://github.com/apache/flink/pull/3618 [FLINK-6194] [docs] Fix broken links Fix automatically-identified broken links in docs. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-6096) Refactor the migration of old versioned savepoints

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942994#comment-15942994 ] ASF GitHub Bot commented on FLINK-6096: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-6096) Refactor the migration of old versioned savepoints

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942995#comment-15942995 ] ASF GitHub Bot commented on FLINK-6096: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-6096) Refactor the migration of old versioned savepoints

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942993#comment-15942993 ] ASF GitHub Bot commented on FLINK-6096: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #3558: [FLINK-6096][checkpoint] Refactor the migration of...

2017-03-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3558#discussion_r107908694 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/v0/SavepointV0.java --- @@ -0,0 +1,207 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #3558: [FLINK-6096][checkpoint] Refactor the migration of...

2017-03-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3558#discussion_r108133263 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/v0/SavepointV0.java --- @@ -0,0 +1,207 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #3558: [FLINK-6096][checkpoint] Refactor the migration of...

2017-03-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3558#discussion_r107908422 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/MigrationInstantiationUtil.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

2017-03-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942990#comment-15942990 ] Chesnay Schepler commented on FLINK-5892: - [~maguowei] What's your progress on this issue? >

[jira] [Commented] (FLINK-6194) More broken links in docs

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942984#comment-15942984 ] ASF GitHub Bot commented on FLINK-6194: --- GitHub user patricklucas opened a pull request:

[jira] [Commented] (FLINK-5498) Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)

2017-03-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942973#comment-15942973 ] Fabian Hueske commented on FLINK-5498: -- Another comment: I think we can implement this as follows: -

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-27 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942972#comment-15942972 ] Wei-Che Wei commented on FLINK-5982: Hi [~till.rohrmann] Ok, I see. Thanks for your suggestion. >

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942957#comment-15942957 ] Till Rohrmann commented on FLINK-5982: -- Hi [~tonywei], one of the ideas for the refactoring is to

[GitHub] flink issue #3590: [FLINK-5654] - Add processing time OVER RANGE BETWEEN x P...

2017-03-27 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3590 @fhueske thanks Fabian for the note. I will do a rebase today on the PR as there was apparently a merge of the retraction support. I will also try to enhance the tests. Hopefully by tomorrow there

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942944#comment-15942944 ] ASF GitHub Bot commented on FLINK-5654: --- Github user rtudoran commented on the issue:

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

2017-03-27 Thread Yaroslav Mykhaylov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942939#comment-15942939 ] Yaroslav Mykhaylov commented on FLINK-5860: --- Hi [~shijinkui], what do you have a question? if

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942928#comment-15942928 ] ASF GitHub Bot commented on FLINK-4565: --- Github user DmytroShkvyra commented on the issue:

[GitHub] flink issue #3502: [FLINK-4565] Support for SQL IN operator

2017-03-27 Thread DmytroShkvyra
Github user DmytroShkvyra commented on the issue: https://github.com/apache/flink/pull/3502 Hi @twalthr at last all tests are green! --- 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

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942922#comment-15942922 ] ASF GitHub Bot commented on FLINK-5653: --- Github user huawei-flink commented on the issue:

[GitHub] flink issue #3574: [FLINK-5653] Add processing time OVER ROWS BETWEEN x PREC...

2017-03-27 Thread huawei-flink
Github user huawei-flink commented on the issue: https://github.com/apache/flink/pull/3574 @fhueske Thanks a lot of the clarification. I understand the issue better now, and see your attempt to make an average case that would work for both in memory as well as on external

[jira] [Created] (FLINK-6194) More broken links in docs

2017-03-27 Thread Patrick Lucas (JIRA)
Patrick Lucas created FLINK-6194: Summary: More broken links in docs Key: FLINK-6194 URL: https://issues.apache.org/jira/browse/FLINK-6194 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

2017-03-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942857#comment-15942857 ] Timo Walther commented on FLINK-5829: - [~wheat9] if it is not much effort to extend the class in order

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-03-27 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3600 @zhengcanbin ,@StephanEwen ,@shijinkui. After push this issue, we must illustrate in flink configuration. If we want to use kerberos authentication with ZK server, we must set

[jira] [Commented] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942855#comment-15942855 ] ASF GitHub Bot commented on FLINK-6117: --- Github user Rucongzhang commented on the issue:

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942840#comment-15942840 ] ASF GitHub Bot commented on FLINK-5653: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3574: [FLINK-5653] Add processing time OVER ROWS BETWEEN x PREC...

2017-03-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3574 Hi @huawei-flink, thanks for your detailed explanation. The benefits of the MapState are that we only need to deserialize all keys and not all rows as in the ValueState or ListState case.

[GitHub] flink issue #3600: [FLINK-6117]Make setting of 'zookeeper.sasl.disable' work...

2017-03-27 Thread zhengcanbin
Github user zhengcanbin commented on the issue: https://github.com/apache/flink/pull/3600 @EronWright @vijikarthi --- 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

[jira] [Commented] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942814#comment-15942814 ] ASF GitHub Bot commented on FLINK-6117: --- Github user zhengcanbin commented on the issue:

[GitHub] flink issue #3574: [FLINK-5653] Add processing time OVER ROWS BETWEEN x PREC...

2017-03-27 Thread huawei-flink
Github user huawei-flink commented on the issue: https://github.com/apache/flink/pull/3574 Hi @fhueske, @sunjincheng121 , let me try to explain my perspective on this specific case (row based, proc time). This is for the purpose of discussion, to show that we are spending

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942809#comment-15942809 ] ASF GitHub Bot commented on FLINK-5653: --- Github user huawei-flink commented on the issue:

[jira] [Closed] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion

2017-03-27 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-5217. Resolution: Fixed > Deprecated interface Checkpointed make clear suggestion >

[jira] [Closed] (FLINK-5754) released tag missing .gitigonore .travis.yml .gitattributes

2017-03-27 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-5754. Resolution: Won't Fix > released tag missing .gitigonore .travis.yml .gitattributes >

[jira] [Commented] (FLINK-5754) released tag missing .gitigonore .travis.yml .gitattributes

2017-03-27 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942804#comment-15942804 ] shijinkui commented on FLINK-5754: -- [~greghogan] It's OK > released tag missing .gitigonore .travis.yml

[jira] [Updated] (FLINK-4562) table examples make an divided module in flink-examples

2017-03-27 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-4562: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-6193 > table examples make an divided

[GitHub] flink issue #3616: [FLINK-6188] Correctly handle PARALLELISM_DEFAULT in stre...

2017-03-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3616 This is not completely done yet. It seems I still have to change when max parallelism is instantiated for this to work. --- If your project is set up for it, you can reply to this email and have

[jira] [Created] (FLINK-6193) Flink dist directory normalize

2017-03-27 Thread shijinkui (JIRA)
shijinkui created FLINK-6193: Summary: Flink dist directory normalize Key: FLINK-6193 URL: https://issues.apache.org/jira/browse/FLINK-6193 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6188) Some setParallelism() methods can't cope with default parallelism

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942794#comment-15942794 ] ASF GitHub Bot commented on FLINK-6188: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion

2017-03-27 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942790#comment-15942790 ] Stefan Richter commented on FLINK-5217: --- [~shijinkui] the JavaDocs for {{Checkpointed}} and

[jira] [Updated] (FLINK-5723) Use "Used" instead of "Initial" to make taskmanager tag more readable

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5723: Issue Type: Sub-task (was: Improvement) Parent: FLINK-5839 > Use "Used" instead of "Initial" to

[jira] [Updated] (FLINK-5417) Fix the wrong config file name

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5417: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > Fix the wrong config file name >

[jira] [Updated] (FLINK-5729) add hostname option in SocketWindowWordCount example to be more convenient

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5729: Issue Type: Sub-task (was: Improvement) Parent: FLINK-5839 > add hostname option in

[jira] [Updated] (FLINK-5825) In yarn mode, a small pic can not be loaded

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5825: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > In yarn mode, a small pic can not be loaded >

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5901: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > DAG can not show properly in IE >

[jira] [Updated] (FLINK-5903) taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5903: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > taskmanager.numberOfTaskSlots and

[jira] [Updated] (FLINK-5916) make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5916: Issue Type: Sub-task (was: Improvement) Parent: FLINK-5839 > make env.java.opts.jobmanager and

[jira] [Updated] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-6020: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > Blob Server cannot handle multiple job

[jira] [Updated] (FLINK-5981) SSL version and ciper suites cannot be constrained as configured

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5981: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > SSL version and ciper suites cannot be

[jira] [Updated] (FLINK-6189) Do not use yarn client config to do sanity check

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-6189: Issue Type: Sub-task (was: Bug) Parent: FLINK-5839 > Do not use yarn client config to do sanity

[jira] [Updated] (FLINK-6174) Introduce a leader election service in yarn mode to make JobManager always available

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-6174: Issue Type: Sub-task (was: Improvement) Parent: FLINK-5839 > Introduce a leader election service

[jira] [Updated] (FLINK-6192) reuse zookeeer client created by CuratorFramework

2017-03-27 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-6192: Issue Type: Sub-task (was: Improvement) Parent: FLINK-5839 > reuse zookeeer client created by

[jira] [Commented] (FLINK-6192) reuse zookeeer client created by CuratorFramework

2017-03-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942785#comment-15942785 ] ASF GitHub Bot commented on FLINK-6192: --- GitHub user WangTaoTheTonic opened a pull request:

[GitHub] flink pull request #3617: [FLINK-6192]reuse zookeeper client created by Cura...

2017-03-27 Thread WangTaoTheTonic
GitHub user WangTaoTheTonic opened a pull request: https://github.com/apache/flink/pull/3617 [FLINK-6192]reuse zookeeper client created by CuratorFramework Now in yarn mode, there're three places using zookeeper client(web monitor, jobmanager and resourcemanager) in

[jira] [Created] (FLINK-6192) reuse zookeeer client created by CuratorFramework

2017-03-27 Thread Tao Wang (JIRA)
Tao Wang created FLINK-6192: --- Summary: reuse zookeeer client created by CuratorFramework Key: FLINK-6192 URL: https://issues.apache.org/jira/browse/FLINK-6192 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-03-27 Thread Zhenghua Gao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942759#comment-15942759 ] Zhenghua Gao commented on FLINK-6173: - Hi [~fhueske], My maven version is 3.3.9. Maven 3.0.3 is too

[jira] [Updated] (FLINK-6178) Allow upgrades to state serializers

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6178: --- Description: Currently, users are locked in with the serializer implementation used

[jira] [Commented] (FLINK-3320) Add not operator to CEP's pattern API

2017-03-27 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942742#comment-15942742 ] Anton Mushin commented on FLINK-3320: - Hi [~dawidwys], I am not working on the issue. You can take it

[jira] [Comment Edited] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

2017-03-27 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855653#comment-15855653 ] Anton Mushin edited comment on FLINK-5435 at 3/27/17 6:48 AM: -- Hi. We have

[jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API

2017-03-27 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-3320: --- Assignee: (was: Anton Mushin) > Add not operator to CEP's pattern API >

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

2017-03-27 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942740#comment-15942740 ] Anton Mushin commented on FLINK-4604: - Hi everyone, Calcite 1.12 has been release:

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Description: This sub-task follows after FLINK-6190. For non-primitive type

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Description: This sub-task follows after FLINK-6190. For non-primitive type

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Description: This sub-task follows after FLINK-6190. For non-primitive type

[jira] [Updated] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6190: --- Description: In order for serializers to be able to be reconfigured on restore, we

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Description: This sub-task follows after FLINK-6190. For non-primitive type

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Description: This sub-task follows after FLINK-6190. For non-primitive type

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

2017-03-27 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942695#comment-15942695 ] ramkrishna.s.vasudevan commented on FLINK-5752: --- Wil start working on this some time this

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Description: This sub-task follows after FLINK-6190. For non-primitive type

[jira] [Created] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-03-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6191: -- Summary: Make non-primitive, internal built-in serializers reconfigurable Key: FLINK-6191 URL: https://issues.apache.org/jira/browse/FLINK-6191 Project:

<    1   2