[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-15 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400595#comment-16400595 ] Sihua Zhou commented on FLINK-8922: --- Hmm... I will try it out, I'm looping the code of

[jira] [Reopened] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8885: - reopen to fix fixVersion > The DispatcherThreadFactory should register uncaught exception

[jira] [Closed] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8885. --- Resolution: Duplicate Fix Version/s: (was: 1.6.0) (was:

[jira] [Reopened] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent()

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8806: - reopen to fix fixVErsion > Failure in UnionInputGate getNextBufferOrEvent() >

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400646#comment-16400646 ] ASF GitHub Bot commented on FLINK-8968: --- GitHub user sihuazhou opened a pull request:

[GitHub] flink pull request #5705: [FLINK-8968][state]Fix native resource leak caused...

2018-03-15 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5705 [FLINK-8968][state]Fix native resource leak caused by ReadOptions ## What is the purpose of the change This PR fixes (FLINK-8968)[https://issues.apache.org/jira/browse/FLINK-8968] Pull

[jira] [Closed] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStrea

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8685. --- Resolution: Duplicate Fix Version/s: (was: 1.5.0) > Code of method >

[jira] [Reopened] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStr

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8685: - reopen to change fixVersion > Code of method >

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Description: The built-in aggregation functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400662#comment-16400662 ] ASF GitHub Bot commented on FLINK-8968: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-15 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5705 LGTM 👍 ---

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Affects Version/s: (was: 1.4.1) 1.5.0 1.3.2

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Description: The built-in aggregation functions   was: Error calculation based on rolling

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Summary: Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group

[jira] [Closed] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent()

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8806. --- Resolution: Duplicate Fix Version/s: (was: 1.6.0) (was:

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400743#comment-16400743 ] Fernando Díaz commented on FLINK-6895: -- Do you mean the string to format? It can be a column

[GitHub] flink pull request #5675: [FLINK-7804][flip6] YarnResourceManager does not e...

2018-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5675#discussion_r174834515 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -325,67 +328,74 @@ public float getProgress() {

[GitHub] flink pull request #5675: [FLINK-7804][flip6] YarnResourceManager does not e...

2018-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5675#discussion_r174834772 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -395,10 +405,13 @@ public void onNodesUpdated(List list) {

[jira] [Commented] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

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

[jira] [Commented] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

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

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-15 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 @StefanRRichter Could you please have a look at this? ---

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400650#comment-16400650 ] ASF GitHub Bot commented on FLINK-8968: --- Github user sihuazhou commented on the issue:

[jira] [Created] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8968: - Summary: Fix native resource leak caused by ReadOptions Key: FLINK-8968 URL: https://issues.apache.org/jira/browse/FLINK-8968 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400654#comment-16400654 ] Fabian Hueske commented on FLINK-8903: -- Hi [~lilizhao], Sorry for being too eager when closing the

[jira] [Assigned] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8903: - Assignee: Shuyi Chen > Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are

[jira] [Commented] (FLINK-8304) Document Kubernetes and Flink HA setup

2018-03-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401026#comment-16401026 ] Ufuk Celebi commented on FLINK-8304: I think your understanding is correct (although the terminology

[jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2018-03-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7775: -- Description: {code} public int getNumberOfCachedJobs() { return jobRefCounters.size(); } {code} The

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400963#comment-16400963 ] Fabian Hueske commented on FLINK-8903: -- Thanks Shuyi! In fact, I was curious how hard it would be to

[jira] [Updated] (FLINK-7282) Credit-based Network Flow Control

2018-03-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7282: External issue URL: https://docs.google.com/document/d/1chTOuOqe0sBsjldA_r-wXYeSIhU2zRGpUaTaik7QZ84

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400925#comment-16400925 ] Shuyi Chen commented on FLINK-8903: --- [~fhueske], I can help take a look at this issue. > Built-in agg

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400990#comment-16400990 ] Shuyi Chen commented on FLINK-8903: --- Hi [~fhueske], please work on it if you are already in the middle.

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

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

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 Travis CI pending after rebasing this, will push as soon at it gives us a green light... ---

[jira] [Reopened] (FLINK-7283) PythonPlanBinderTest issues with python paths

2018-03-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7283: > PythonPlanBinderTest issues with python paths >

[jira] [Updated] (FLINK-7283) PythonPlanBinderTest issues with python paths

2018-03-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7283: --- Fix Version/s: (was: 1.3.4) 1.3.3 > PythonPlanBinderTest

[jira] [Closed] (FLINK-7283) PythonPlanBinderTest issues with python paths

2018-03-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7283. -- Resolution: Fixed > PythonPlanBinderTest issues with python paths >

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_...

2018-03-15 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r174965171 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala --- @@ -103,6 +106,19 @@

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401160#comment-16401160 ] ASF GitHub Bot commented on FLINK-8903: --- GitHub user fhueske opened a pull request:

[jira] [Assigned] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8903: Assignee: Fabian Hueske (was: Shuyi Chen) > Built-in agg functions VAR_POP, VAR_SAMP,

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

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

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

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

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_...

2018-03-15 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r174962566 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/calcite/rel/rules/AggregateReduceFunctionsRule.java --- @@ -0,0 +1,590 @@ +/* + *

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_...

2018-03-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/5706 [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_SAMP, STDEV_POP functions on GROUP BY windows. ## What is the purpose of the change * Fixes the computation of `VAR_SAMP`, `VAR_POP`,

[GitHub] flink issue #5703: [FLINK-8915] CheckpointingStatisticsHandler fails to retu...

2018-03-15 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5703 @tillrohrmann please review this PR, thanks! ---

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401356#comment-16401356 ] ASF GitHub Bot commented on FLINK-8915: --- Github user yanghua commented on the issue:

[jira] [Created] (FLINK-8969) Move TimerService into state backend

2018-03-15 Thread Bowen Li (JIRA)
Bowen Li created FLINK-8969: --- Summary: Move TimerService into state backend Key: FLINK-8969 URL: https://issues.apache.org/jira/browse/FLINK-8969 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work

2018-03-15 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401420#comment-16401420 ] Wind commented on FLINK-8930: - ok, I've already understood, thanks for the explanations ! > TableApi

[jira] [Commented] (FLINK-8969) Move TimerService into state backend

2018-03-15 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401485#comment-16401485 ] Sihua Zhou commented on FLINK-8969: --- Hi [~phoenixjiangnan], Where is the previous discussion, could you

[GitHub] flink issue #5698: [FLINK-8945] [kinesis] Allow customization of KinesisProx...

2018-03-15 Thread tweise
Github user tweise commented on the issue: https://github.com/apache/flink/pull/5698 +1 @StephanEwen can we get this into 1.5.0 ? ---

[jira] [Commented] (FLINK-8945) Allow customization of the KinesisProxy

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401380#comment-16401380 ] ASF GitHub Bot commented on FLINK-8945: --- Github user tweise commented on the issue:

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

2018-03-15 Thread liurenjie1024
Github user liurenjie1024 commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174990348 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,162 @@ +/* + *

[jira] [Closed] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value

2018-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-8364. --- Resolution: Invalid > Add iterator() to ListState which returns empty iterator when it has no value >

[jira] [Commented] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-03-15 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401391#comment-16401391 ] Renjie Liu commented on FLINK-8953: --- Hi, Tim: I want to look into this, could you assign this to me? >

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

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

[jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8771: Affects Version/s: 1.5.0 > Upgrade scalastyle to 1.0.0 > --- > >

[jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8771: Fix Version/s: 1.6.0 > Upgrade scalastyle to 1.0.0 > --- > > Key:

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

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

[GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l...

2018-03-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5327 Thanks @hequn8128! We're pretty busy with the Flink 1.5 release right now. This will be one of the first features to add once 1.5 is out! Best, Fabian ---

[jira] [Closed] (FLINK-6238) support OVER on batch SQL

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6238. Resolution: Duplicate Duplicate of FLINK-6473 > support OVER on batch SQL >

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400182#comment-16400182 ] Fernando Díaz commented on FLINK-6895: -- Taking a look at this [MySQL

[jira] [Created] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

2018-03-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8951: Summary: Support OVER windows PARTITION BY (rounded) timestamp Key: FLINK-8951 URL: https://issues.apache.org/jira/browse/FLINK-8951 Project: Flink Issue

[jira] [Updated] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8562: - Affects Version/s: 1.6.0 1.5.0 > Fix YARNSessionFIFOSecuredITCase >

[jira] [Updated] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8562: - Priority: Blocker (was: Major) > Fix YARNSessionFIFOSecuredITCase >

[jira] [Closed] (FLINK-6979) Add documentation for Aggregation Functions in Tables/UDF doc

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6979. Resolution: Fixed Assignee: Shaoxuan Wang Fix Version/s: 1.4.0 Documentation was

[jira] [Created] (FLINK-8950) "Materialize" Tables to avoid recomputation.

2018-03-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8950: Summary: "Materialize" Tables to avoid recomputation. Key: FLINK-8950 URL: https://issues.apache.org/jira/browse/FLINK-8950 Project: Flink Issue Type: New

[jira] [Created] (FLINK-8949) Rest API failure with long URL

2018-03-15 Thread Truong Duc Kien (JIRA)
Truong Duc Kien created FLINK-8949: -- Summary: Rest API failure with long URL Key: FLINK-8949 URL: https://issues.apache.org/jira/browse/FLINK-8949 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-6100) Add documentation for Projectable and Filterable TableSource

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6100. Resolution: Fixed Fix Version/s: 1.4.0 > Add documentation for Projectable and Filterable

[jira] [Assigned] (FLINK-6100) Add documentation for Projectable and Filterable TableSource

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6100: Assignee: Fabian Hueske > Add documentation for Projectable and Filterable TableSource >

[jira] [Closed] (FLINK-3497) Add SQL scalar functions to Table API

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3497. Resolution: Fixed Assignee: Timo Walther Closing. All sub issues have been resolved. > Add

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

2018-03-15 Thread Truong Duc Kien (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400215#comment-16400215 ] Truong Duc Kien commented on FLINK-8297: Isn't this also related to 

[jira] [Commented] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399978#comment-16399978 ] ASF GitHub Bot commented on FLINK-8771: --- GitHub user bowenli86 opened a pull request:

[jira] [Commented] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

2018-03-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399988#comment-16399988 ] Timo Walther commented on FLINK-8852: - Hi [~liurenjie1024], I'm actively working on this right now:

[jira] [Assigned] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-15 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8946: --- Assignee: vinoyang > TaskManager stop sending metrics after JobManager failover >

[jira] [Commented] (FLINK-6075) ORDER BY *time ASC

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400031#comment-16400031 ] Fabian Hueske commented on FLINK-6075: -- The missing {{RANK}} function is not the issue. You could do

[jira] [Closed] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4569. --- Resolution: Fixed master: a04c8a08383e329213bd74c726f9834b7d19762d 1.5:

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400010#comment-16400010 ] Chesnay Schepler commented on FLINK-8703: - Partially addressed in: master:

[GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL...

2018-03-15 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5660 Hi @xccui, I will review this as soon as possible. Right now the priority is the Flink 1.5 release with FLIP-6 support. ---

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1630#comment-1630 ] ASF GitHub Bot commented on FLINK-8861: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #5679: [FLINK-8916] Checkpointing Mode is always shown to...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5679 ---

[GitHub] flink pull request #5692: [docs] Fix typo in Python API docs

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5692 ---

[jira] [Updated] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8904: Fix Version/s: (was: 1.6.0) > Flink-client tests do not restore previous sysout after

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400030#comment-16400030 ] ASF GitHub Bot commented on FLINK-8861: --- Github user xccui commented on the issue:

[GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL...

2018-03-15 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5660 I see, @twalthr. Sorry for my impatience. ---

[GitHub] flink pull request #5702: [FLINK-8771] Upgrade scalastyle to 1.0.0

2018-03-15 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5702 [FLINK-8771] Upgrade scalastyle to 1.0.0 ## What is the purpose of the change Upgrade scalastyle from 0.8.0 to 1.0.0 ## Brief change log - Upgrade scalastyle from 0.8.0

[jira] [Closed] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8904. --- Resolution: Fixed master: 80ee267386a3bc3c27c95a628255031953506128 1.5:

[GitHub] flink pull request #5668: [FLINK-8703][tests] Port StreamingScalabilityAndLa...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5668 ---

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Updated] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8904: Affects Version/s: (was: 1.6.0) > Flink-client tests do not restore previous sysout

[GitHub] flink pull request #5689: [FLINK-4569][tests] Respect exceptions thrown in t...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5689 ---

[GitHub] flink pull request #5670: [FLINK-8904][cli][tests] always restore the previo...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5670 ---

[jira] [Commented] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

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

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

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

[jira] [Commented] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

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

[GitHub] flink pull request #5666: [FLINK-8703][tests] Port KafkaShortRetentionTestBa...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5666 ---

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5667: [FLINK-8703][tests] Port NotSoMiniClusterIteration...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5667 ---

[GitHub] flink pull request #5677: [hotfix] [streaming API] update doc of InternalTim...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5677 ---

[jira] [Created] (FLINK-8947) Timeout handler issue

2018-03-15 Thread dhiraj prajapati (JIRA)
dhiraj prajapati created FLINK-8947: --- Summary: Timeout handler issue Key: FLINK-8947 URL: https://issues.apache.org/jira/browse/FLINK-8947 Project: Flink Issue Type: Bug

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 Thanks for checking this out. Merging to 1.5 and 1.6 then... ---

  1   2   >