[jira] [Commented] (FLINK-6661) Merge "Subtasks" and "TaskManagers" view

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

[jira] [Comment Edited] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040295#comment-16040295 ] mingleizhang edited comment on FLINK-6849 at 6/7/17 6:59 AM: -

[GitHub] flink issue #3998: [FLINK-6661][web] Merge "Subtasks" and "SubtasksByTaskMan...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3998 we got enough space, so why not be explicit about it :) Will change it while merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Comment Edited] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040295#comment-16040295 ] mingleizhang edited comment on FLINK-6849 at 6/7/17 6:41 AM: -

[jira] [Commented] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040295#comment-16040295 ] mingleizhang commented on FLINK-6849: - I think we can do this refactor by the below th

[GitHub] flink pull request #4075: [FLINK-6494] Migrate ResourceManager/Yarn/Mesos co...

Github user zjureel closed the pull request at: https://github.com/apache/flink/pull/4075 --- 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 ena

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040080#comment-16040080 ] ASF GitHub Bot commented on FLINK-6494: --- Github user zjureel closed the pull request

[GitHub] flink pull request #4082: TimeIndicators

Github user sunjincheng121 closed the pull request at: https://github.com/apache/flink/pull/4082 --- 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

[jira] [Commented] (FLINK-6511) JobClient does not properly clean up BlobCache resources

[ https://issues.apache.org/jira/browse/FLINK-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040017#comment-16040017 ] Fang Yong commented on FLINK-6511: -- Thank you for your reply [~till.rohrmann], It's sound

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039960#comment-16039960 ] mingleizhang commented on FLINK-6857: - +1 :) > Add global default Kryo serializer con

[jira] [Commented] (FLINK-6858) Unbounded event time Over Window emits incorrect timestamps

[ https://issues.apache.org/jira/browse/FLINK-6858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039959#comment-16039959 ] hongyuhong commented on FLINK-6858: --- Hi [~fhueske], the implemention of unbounded event-

[jira] [Updated] (FLINK-6389) Upgrade hbase dependency to 1.3.1

[ https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6389: -- Description: hbase 1.3.1 has been released. It fixes compatibility issue in 1.3.0 release, among other bug fixe

[jira] [Updated] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6422: -- Description: Here is related code: {code} if (minNumSplits < 1) { throw new IllegalArgumentException(

[jira] [Resolved] (FLINK-6467) Potential lack of synchronization w.r.t. newSstFiles in RocksDBKeyedStateBackend#releaseResources()

[ https://issues.apache.org/jira/browse/FLINK-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6467. --- Resolution: Not A Problem > Potential lack of synchronization w.r.t. newSstFiles in > RocksDBKeyedStateBacken

[GitHub] flink pull request #4082: TimeIndicators

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4082 TimeIndicators Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items i

[jira] [Updated] (FLINK-6811) Add TIMESTAMPADD supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6811: --- Description: * Syntax timestampAdd (datepart SqlTypeFamily.ANY, number:SqlTypeFamily.INTEGER, date:Sq

[jira] [Commented] (FLINK-6661) Merge "Subtasks" and "TaskManagers" view

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

[GitHub] flink issue #3998: [FLINK-6661][web] Merge "Subtasks" and "SubtasksByTaskMan...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3998 LGTM. My only suggestion would be to ask if the checkbox description should be lengthened to ""Aggregate statistics by TaskManager" or even "Aggregate task statistics by TaskManager". --- If your

[jira] [Created] (FLINK-6860) update Apache Beam in page Ecosystem

Xu Mingmin created FLINK-6860: - Summary: update Apache Beam in page Ecosystem Key: FLINK-6860 URL: https://issues.apache.org/jira/browse/FLINK-6860 Project: Flink Issue Type: Task Compo

[jira] [Commented] (FLINK-6823) Activate checkstyle for runtime/broadcast

[ https://issues.apache.org/jira/browse/FLINK-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039311#comment-16039311 ] ASF GitHub Bot commented on FLINK-6823: --- Github user greghogan commented on a diff i

[jira] [Commented] (FLINK-6823) Activate checkstyle for runtime/broadcast

[ https://issues.apache.org/jira/browse/FLINK-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039310#comment-16039310 ] ASF GitHub Bot commented on FLINK-6823: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #4068: [FLINK-6823] Activate checkstyle for runtime/broad...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4068#discussion_r120427357 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableManager.java --- @@ -18,34 +18,42 @@ package org.apac

[GitHub] flink pull request #4068: [FLINK-6823] Activate checkstyle for runtime/broad...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4068#discussion_r120427634 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableManager.java --- @@ -18,34 +18,42 @@ package org.apac

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

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

[GitHub] flink issue #3720: [FLINK-6302] Documentation build error on ruby 2.4

Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/3720 Yes, let's get this done. On Jun 6, 2017 19:03, "Stephan Ewen" wrote: > @alpinegizmo @zentol > Now that #4043

[jira] [Created] (FLINK-6859) StateCleaningCountTrigger should not delete timer

Fabian Hueske created FLINK-6859: Summary: StateCleaningCountTrigger should not delete timer Key: FLINK-6859 URL: https://issues.apache.org/jira/browse/FLINK-6859 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-6822) Activate checkstyle for runtime/plugable

[ https://issues.apache.org/jira/browse/FLINK-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039252#comment-16039252 ] ASF GitHub Bot commented on FLINK-6822: --- Github user greghogan commented on a diff i

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

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

[GitHub] flink issue #3720: [FLINK-6302] Documentation build error on ruby 2.4

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3720 @alpinegizmo @zentol Now that #4043 is merged, can we rebase this one? --- 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 proj

[jira] [Commented] (FLINK-6825) Activate checkstyle for runtime/heartbeat

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

[jira] [Commented] (FLINK-6828) Activate checkstyle for runtime/deployment

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

[GitHub] flink issue #4067: [FLINK-6825] Activate checkstyle for runtime/heartbeat

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4067 +1 --- 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 featur

[jira] [Created] (FLINK-6858) Unbounded event time Over Window emits incorrect timestamps

Fabian Hueske created FLINK-6858: Summary: Unbounded event time Over Window emits incorrect timestamps Key: FLINK-6858 URL: https://issues.apache.org/jira/browse/FLINK-6858 Project: Flink Is

[GitHub] flink issue #4066: [FLINK-6828] Activate checkstyle for runtime/deployment

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4066 +1 --- 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 featur

[jira] [Commented] (FLINK-6826) Activate checkstyle for runtime/net

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

[GitHub] flink issue #4065: [FLINK-6826] Activate checkstyle for runtime/net

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4065 +1 --- 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 featur

[GitHub] flink pull request #4064: [FLINK-6822] Activate checkstyle for runtime/pluga...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4064#discussion_r120417811 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/plugable/ReusingDeserializationDelegate.java --- @@ -16,33 +16,31 @@ * limitations un

[jira] [Assigned] (FLINK-6747) Table API / SQL Docs: Streaming Page

[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6747: --- Assignee: (was: Timo Walther) > Table API / SQL Docs: Streaming Page > --

[jira] [Assigned] (FLINK-6748) Table API / SQL Docs: Table API Page

[ https://issues.apache.org/jira/browse/FLINK-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6748: --- Assignee: Timo Walther > Table API / SQL Docs: Table API Page > -

[jira] [Commented] (FLINK-6821) Activate checkstyle for runtime/fs

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

[GitHub] flink issue #4063: [FLINK-6821] Activate checkstyle for runtime/fs

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4063 +1 --- 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 featur

[jira] [Commented] (FLINK-6723) Activate strict checkstyle for flink-libraries

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

[GitHub] flink issue #4069: [FLINK-6723] Activate strict checkstyle for flink-librari...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4069 Thanks @tzulitai. --- 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, o

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039212#comment-16039212 ] ASF GitHub Bot commented on FLINK-6783: --- Github user dawidwys commented on a diff in

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120412137 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java --- @@ -507,12 +505,41 @@ public AllWindowedS

[jira] [Commented] (FLINK-6723) Activate strict checkstyle for flink-libraries

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

[GitHub] flink issue #4069: [FLINK-6723] Activate strict checkstyle for flink-librari...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4069 @greghogan I think the failing tests for this is due to https://issues.apache.org/jira/browse/FLINK-6836 (a different issue from the pom ordering fix). --- If your project is set up for it, you ca

[jira] [Commented] (FLINK-6820) Activate checkstyle for runtime/filecache

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

[jira] [Commented] (FLINK-6697) Add batch multi-window support

[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039197#comment-16039197 ] Fabian Hueske commented on FLINK-6697: -- I think {{'w.rowtime}} is a good solution to

[jira] [Updated] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6857: --- Description: See ML for original discussion: http://apache-flink-user-mailing-list-ar

[jira] [Updated] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6857: --- Description: See ML for original discussion: http://apache-flink-user-mailing-list-ar

[GitHub] flink issue #4062: [FLINK-6820] Activate checkstyle for runtime/filecache

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4062 +1 --- 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 featur

[jira] [Created] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

Tzu-Li (Gordon) Tai created FLINK-6857: -- Summary: Add global default Kryo serializer configuration to StreamExecutionEnvironment Key: FLINK-6857 URL: https://issues.apache.org/jira/browse/FLINK-6857

[GitHub] flink issue #4069: [FLINK-6723] Activate strict checkstyle for flink-librari...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4069 +1 Are the tests failing for lack of the fix reordering the pom in `flink-dist`? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-6723) Activate strict checkstyle for flink-libraries

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

[jira] [Commented] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039148#comment-16039148 ] ASF GitHub Bot commented on FLINK-6198: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #4041: [FLINK-6198] [cep] Update CEP documentation.

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4041#discussion_r120403427 --- Diff: docs/dev/libs/cep.md --- @@ -1155,5 +1199,9 @@ The changes required are: implementing the `FilterFunction` interface. 2. Change you

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039129#comment-16039129 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039138#comment-16039138 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039144#comment-16039144 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039139#comment-16039139 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039143#comment-16039143 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039133#comment-16039133 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039130#comment-16039130 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039142#comment-16039142 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039134#comment-16039134 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039136#comment-16039136 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039135#comment-16039135 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039137#comment-16039137 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039140#comment-16039140 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039141#comment-16039141 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039132#comment-16039132 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039131#comment-16039131 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120397513 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java --- @@ -254,9 +274,19 @@ public StreamExecution

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120398290 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -221,14 +221,18 @@ protected WithWindow(Dat

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120397389 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java --- @@ -227,9 +237,19 @@ public StreamExecution

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120384026 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -216,7 +253,15 @@ private static void registerFactory(Type

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120398789 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -267,13 +267,15 @@ private boolean validateK

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120397022 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java --- @@ -231,14 +231,18 @@ protected WithWindow(

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120396063 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java --- @@ -507,12 +505,41 @@ public AllWindowedSt

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120387120 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -354,49 +479,21 @@ private static void registerFactory(Type

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120399201 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -981,12 +976,42 @@ public WindowedStream(K

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120397178 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java --- @@ -203,9 +203,19 @@ public StreamExecution

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120389039 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -422,37 +521,52 @@ private static void registerFactory(Type

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r12038 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -336,8 +461,8 @@ private static void registerFactory(Type t

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120398682 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -300,14 +304,18 @@ protected WithWindow(Dat

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120397600 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java --- @@ -574,13 +574,15 @@ public ExecutionConfig getE

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120392260 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -464,57 +578,52 @@ private static void registerFactory(Type

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120391605 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -464,57 +578,52 @@ private static void registerFactory(Type

[jira] [Commented] (FLINK-6852) Fix misuse of GCD

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

[GitHub] flink issue #4077: [FLINK-6852] Fix misuse of GCD

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4077 +1 --- 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 featur

[jira] [Commented] (FLINK-6852) Fix misuse of GCD

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

[GitHub] flink issue #4077: [FLINK-6852] Fix misuse of GCD

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4077 thanks for the PR @Xpray +1 to merge. --- 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 e

[jira] [Commented] (FLINK-6850) Links on "Powered by Flink" page not rendered correctly

[ https://issues.apache.org/jira/browse/FLINK-6850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039105#comment-16039105 ] Greg Hogan commented on FLINK-6850: --- [~yew1eb] the website code is at {{https://github.c

[jira] [Created] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

Tzu-Li (Gordon) Tai created FLINK-6856: -- Summary: Eagerly check if serializer config snapshots are deserializable when snapshotting Key: FLINK-6856 URL: https://issues.apache.org/jira/browse/FLINK-6856

[jira] [Commented] (FLINK-6817) Fix NPE when preceding is not set in OVER window

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

[GitHub] flink issue #4055: [FLINK-6817] [table] Fix NPE when preceding is not set in...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4055 Yes, looks good to me as well. +1 for merging and including in 1.3.1 --- 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 do

[jira] [Commented] (FLINK-6807) Elasticsearch 5 connector artifact not published to maven

[ https://issues.apache.org/jira/browse/FLINK-6807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16039077#comment-16039077 ] Francisco Rosa commented on FLINK-6807: --- Thanks Robert. I am behind an environment b

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

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

[GitHub] flink pull request #4081: [FLINK-6844] [scala] Implement compatibility metho...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4081 [FLINK-6844] [scala] Implement compatibility methods for TraversableSerializer The `TraversableSerializer` is used for Scala collections, and therefore may take part in checkpointing and should ha

  1   2   3   >