[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

[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=16040080#comment-16040080 ] ASF GitHub Bot commented on FLINK-6494: --- Github user zjureel closed the pull request at:

[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

[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=16040017#comment-16040017 ] Fang Yong commented on FLINK-6511: -- Thank you for your reply [~till.rohrmann], It's sound good! I noted

[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=16039960#comment-16039960 ] mingleizhang commented on FLINK-6857: - +1 :) > Add global default Kryo serializer configuration to

[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=16039959#comment-16039959 ] hongyuhong commented on FLINK-6858: --- Hi [~fhueske], the implemention of unbounded event-time now is emit

[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

[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

[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 >

[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

[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,

[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=16039449#comment-16039449 ] ASF GitHub Bot commented on FLINK-6661: --- Github user greghogan commented on the issue:

[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

[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

[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=16039311#comment-16039311 ] ASF GitHub Bot commented on FLINK-6823: --- Github user greghogan commented on a diff in the pull

[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=16039310#comment-16039310 ] ASF GitHub Bot commented on FLINK-6823: --- Github user greghogan commented on a diff in the pull

[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

[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

[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=16039287#comment-16039287 ] ASF GitHub Bot commented on FLINK-6302: --- Github user alpinegizmo commented on the issue:

[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 >

[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:

[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=16039252#comment-16039252 ] ASF GitHub Bot commented on FLINK-6822: --- Github user greghogan commented on a diff in the pull

[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=16039259#comment-16039259 ] ASF GitHub Bot commented on FLINK-6302: --- Github user StephanEwen commented on the issue:

[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

[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=16039258#comment-16039258 ] ASF GitHub Bot commented on FLINK-6825: --- Github user greghogan commented on the issue:

[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=16039256#comment-16039256 ] ASF GitHub Bot commented on FLINK-6828: --- Github user greghogan commented on the issue:

[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

[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

[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

[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=16039253#comment-16039253 ] ASF GitHub Bot commented on FLINK-6826: --- Github user greghogan commented on the issue:

[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

[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

[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=16039240#comment-16039240 ] ASF GitHub Bot commented on FLINK-6821: --- Github user greghogan commented on the issue:

[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

[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=16039238#comment-16039238 ] ASF GitHub Bot commented on FLINK-6723: --- Github user greghogan commented on the issue:

[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,

[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=16039212#comment-16039212 ] ASF GitHub Bot commented on FLINK-6783: --- Github user dawidwys commented on a diff in the pull

[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

[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=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

[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=16039198#comment-16039198 ] ASF GitHub Bot commented on FLINK-6820: --- Github user greghogan commented on the issue:

[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=16039197#comment-16039197 ] Fabian Hueske commented on FLINK-6697: -- I think {{'w.rowtime}} is a good solution to this problem. At

[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:

[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:

[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

[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=16039186#comment-16039186 ] ASF GitHub Bot commented on FLINK-6723: --- Github user greghogan commented on the issue:

[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=16039148#comment-16039148 ] ASF GitHub Bot commented on FLINK-6198: --- Github user tzulitai commented on a diff in the pull

[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

[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=16039129#comment-16039129 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039138#comment-16039138 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039144#comment-16039144 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039139#comment-16039139 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039143#comment-16039143 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039133#comment-16039133 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039130#comment-16039130 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039142#comment-16039142 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039134#comment-16039134 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039136#comment-16039136 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039135#comment-16039135 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039137#comment-16039137 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039140#comment-16039140 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039141#comment-16039141 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039132#comment-16039132 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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=16039131#comment-16039131 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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=16039122#comment-16039122 ] ASF GitHub Bot commented on FLINK-6852: --- Github user greghogan commented on the issue:

[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

[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=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

[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=16039105#comment-16039105 ] Greg Hogan commented on FLINK-6850: --- [~yew1eb] the website code is at

[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=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

[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=16039077#comment-16039077 ] Francisco Rosa commented on FLINK-6807: --- Thanks Robert. I am behind an environment blocking access

[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=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

[GitHub] flink issue #4059: [FLINK-6830] Add StatefulJobSavepointFrom13MigrationITCas...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4059 Addressed @aljoscha @kl0u @zentol's comments. Also rebased on `master` for another Travis run. If green, will merge by the end of today to `master` and `release-1.3` if there's no other

[jira] [Commented] (FLINK-6830) Add ITTests for savepoint migration from 1.3

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

[jira] [Commented] (FLINK-6602) Table source with defined time attributes allows empty string

[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038991#comment-16038991 ] Fabian Hueske commented on FLINK-6602: -- I think we should allow {{null}} to indicate that no time

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[GitHub] flink issue #4061: [FLINK-6841][table]Using TableSourceTable for both Stream...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4061 I'm not sure about this change. A batch table source would be able to create a time attribute if it implements `DefinedProctimeAttribute`, right? --- If your project is set up for it, you can reply

  1   2   3   >