[jira] [Created] (FLINK-7646) Restart failed jobs with configurable parallelism range

2017-09-19 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7646: - Summary: Restart failed jobs with configurable parallelism range Key: FLINK-7646 URL: https://issues.apache.org/jira/browse/FLINK-7646 Project: Flink Issue Type:

[jira] [Closed] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6733. - Resolution: Fixed > Remove commented out AvgAggregationFunction.java >

[jira] [Reopened] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-6733: --- Assignee: Mikhail Lipkovich (was: Kurt Young) > Remove commented out AvgAggregationFunction.java >

[GitHub] flink pull request #4685: [hotfix] Fix typo for English spells in Debugging ...

2017-09-19 Thread YMorisawa
GitHub user YMorisawa opened a pull request: https://github.com/apache/flink/pull/4685 [hotfix] Fix typo for English spells in Debugging Classloading documentation Fixed some basic spelling mistake in Docs. --- devided -> divided deploymens -> deployments posible ->

[jira] [Updated] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-6733: -- Priority: Trivial (was: Major) Issue Type: Improvement (was: Bug) > Remove commented out

[jira] [Closed] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6733. - Resolution: Fixed > Remove commented out AvgAggregationFunction.java >

[jira] [Reopened] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-6733: --- Assignee: Kurt Young (was: Mikhail Lipkovich) > Remove commented out AvgAggregationFunction.java >

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

2017-09-19 Thread Kent Murra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172649#comment-16172649 ] Kent Murra commented on FLINK-6173: --- The guidance to use a previous version of Maven seems to be for

[jira] [Created] (FLINK-7645) Modify system-metrics part show in the document

2017-09-19 Thread Hai Zhou_UTC+8 (JIRA)
Hai Zhou_UTC+8 created FLINK-7645: - Summary: Modify system-metrics part show in the document Key: FLINK-7645 URL: https://issues.apache.org/jira/browse/FLINK-7645 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6733) Remove commented out AvgAggregationFunction.java

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

[GitHub] flink pull request #4630: [FLINK-6733] Remove commented out AvgAggregationFu...

2017-09-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4630 ---

[jira] [Closed] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6733. - Resolution: Fixed Fix Version/s: 1.4.0 > Remove commented out AvgAggregationFunction.java >

[jira] [Updated] (FLINK-7644) Line the extra semicolon in the source code

2017-09-19 Thread Hai Zhou_UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou_UTC+8 updated FLINK-7644: -- Description: eg. final TestDuplicateSerializer keySerializer = new

[jira] [Created] (FLINK-7644) Line the extra semicolon in the source code

2017-09-19 Thread Hai Zhou_UTC+8 (JIRA)
Hai Zhou_UTC+8 created FLINK-7644: - Summary: Line the extra semicolon in the source code Key: FLINK-7644 URL: https://issues.apache.org/jira/browse/FLINK-7644 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

2017-09-19 Thread Hai Zhou_UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou_UTC+8 reassigned FLINK-6444: - Assignee: Hai Zhou_UTC+8 > Add a check that '@VisibleForTesting' methods are only used

[jira] [Closed] (FLINK-7626) Add some metric description about checkpoints

2017-09-19 Thread Hai Zhou_UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou_UTC+8 closed FLINK-7626. - Resolution: Fixed > Add some metric description about checkpoints >

[jira] [Commented] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard

2017-09-19 Thread Hai Zhou_UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172561#comment-16172561 ] Hai Zhou_UTC+8 commented on FLINK-7634: --- +1 > Add option to create a savepoint while canceling a

[jira] [Commented] (FLINK-7613) Fix documentation error in QuickStart

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

[GitHub] flink pull request #4666: [FLINK-7613][Documentation] Fixed typographical er...

2017-09-19 Thread raymondtay
Github user raymondtay commented on a diff in the pull request: https://github.com/apache/flink/pull/4666#discussion_r139849283 --- Diff: docs/dev/datastream_api.md --- @@ -497,7 +497,9 @@ env.generateSequence(1,10).map(new MyMapper()).setBufferTimeout(timeoutMillis);

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172532#comment-16172532 ] ASF GitHub Bot commented on FLINK-6233: --- Github user xccui commented on a diff in the pull request:

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-09-19 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139849018 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/RowTimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,83 @@ +/*

[jira] [Commented] (FLINK-7613) Fix documentation error in QuickStart

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

[GitHub] flink pull request #4666: [FLINK-7613][Documentation] Fixed typographical er...

2017-09-19 Thread raymondtay
Github user raymondtay commented on a diff in the pull request: https://github.com/apache/flink/pull/4666#discussion_r139848500 --- Diff: docs/dev/execution_configuration.md --- @@ -42,44 +42,44 @@ var executionConfig = env.getConfig The following configuration options

[jira] [Commented] (FLINK-7531) Move existing REST handler to flink-runtime

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

[GitHub] flink pull request #4600: [FLINK-7531] Move Flink legacy rest handler to fli...

2017-09-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4600 ---

[jira] [Closed] (FLINK-7531) Move existing REST handler to flink-runtime

2017-09-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7531. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 4fc019a96a08446d7ba5f57664904abcd585e31c >

[jira] [Closed] (FLINK-7529) Retrieve complete REST address from RestfulGateway

2017-09-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7529. Resolution: Fixed Fix Version/s: 1.4.0 Added via 32770103253e01cd61c8634378cfa1b26707e19a >

[GitHub] flink pull request #4599: [FLINK-7529] Retrieve complete REST address from g...

2017-09-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4599 ---

[jira] [Commented] (FLINK-7529) Retrieve complete REST address from RestfulGateway

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

[jira] [Commented] (FLINK-7528) Create Dispatcher REST endpoint

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

[GitHub] flink pull request #4598: [FLINK-7528] Create DispatcherRestEndpoint and int...

2017-09-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4598 ---

[jira] [Closed] (FLINK-7528) Create Dispatcher REST endpoint

2017-09-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7528. Resolution: Fixed Fix Version/s: 1.4.0 Added via 6a62f1455313ee8fae0ff79945da61fb67ec8edb >

[jira] [Closed] (FLINK-7527) Add redirection logic to AbstractRestHandler

2017-09-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7527. Resolution: Fixed Fix Version/s: 1.4.0 Added via 75e84e04f5a3e2766e331fd05ddb725fe9b00d99 >

[jira] [Commented] (FLINK-7527) Add redirection logic to AbstractRestHandler

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

[GitHub] flink pull request #4597: [FLINK-7527] [rest] Let AbstractRestHandler extend...

2017-09-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4597 ---

[jira] [Commented] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration

2017-09-19 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172361#comment-16172361 ] Bowen Li commented on FLINK-7643: - Looks like it's related to FLINK-7365 > HadoopFileSystem always

[jira] [Updated] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration

2017-09-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7643: - Affects Version/s: 1.4.0 > HadoopFileSystem always reloads GlobalConfiguration >

[jira] [Commented] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172286#comment-16172286 ] ASF GitHub Bot commented on FLINK-7514: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4591: [FLINK-7514][tests] fix BackPressureStatsTrackerITCase re...

2017-09-19 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4591 @zentol unfortunately, when changing to using Netty's buffer counting, it will check any form of illegal reference count usages, and a double-free is one of them. Even without Netty, this pattern

[jira] [Commented] (FLINK-7527) Add redirection logic to AbstractRestHandler

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

[GitHub] flink pull request #4597: [FLINK-7527] [rest] Let AbstractRestHandler extend...

2017-09-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4597#discussion_r139805450 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ErrorResponseBody.java --- @@ -38,6 +40,10 @@ public

[jira] [Commented] (FLINK-7603) Support within clause in MatchRecognize

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172085#comment-16172085 ] ASF GitHub Bot commented on FLINK-7603: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #4684: [FLINK-7603][savepoint/doc] Document how to take a...

2017-09-19 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4684 [FLINK-7603][savepoint/doc] Document how to take a savepoint on YARN ## What is the purpose of the change The documentation should have a separate entry for savepoint related CLI

[jira] [Closed] (FLINK-6549) Improve error message for type mismatches with side outputs

2017-09-19 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-6549. --- Resolution: Fixed > Improve error message for type mismatches with side outputs >

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-19 Thread Aitozi
Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r139742368 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -405,6 +411,8 @@ public void

[jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

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

[GitHub] flink pull request #4678: [FLINK-7630] [Java API] Allow passing a File or an...

2017-09-19 Thread tony810430
Github user tony810430 closed the pull request at: https://github.com/apache/flink/pull/4678 ---

[jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171911#comment-16171911 ] ASF GitHub Bot commented on FLINK-7630: --- Github user tony810430 commented on the issue:

[GitHub] flink issue #4678: [FLINK-7630] [Java API] Allow passing a File or an InputS...

2017-09-19 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/4678 I thought it would be closed automatically. But it's okay, I will close it. Thanks for your quick review. ---

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[GitHub] flink issue #4625: [FLINK-6233] [table] Support time-bounded stream inner jo...

2017-09-19 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4625 Btw, I noticed I did not reply to your comments. I think it would be good to have the eager state cleaning in the initial version. Shouldn't be too much effort. Basically, getting the

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139728162 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/RowTimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,83 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139727416 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,74 @@ +/*

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139723927 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139723011 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r139722338 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -131,340 +116,308 @@ class

[jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

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

[GitHub] flink issue #4678: [FLINK-7630] [Java API] Allow passing a File or an InputS...

2017-09-19 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4678 I merged, could you please close this PR? And thanks for working on this! 😃 ---

[jira] [Closed] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2017-09-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7630. --- Resolution: Fixed Implemented on release-1.3 in 100951e279ad352f3b8921970217cd8edf14ac20

[jira] [Commented] (FLINK-6733) Remove commented out AvgAggregationFunction.java

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171814#comment-16171814 ] ASF GitHub Bot commented on FLINK-6733: --- Github user mlipkovich commented on the issue:

[GitHub] flink issue #4630: [FLINK-6733] Remove commented out AvgAggregationFunction....

2017-09-19 Thread mlipkovich
Github user mlipkovich commented on the issue: https://github.com/apache/flink/pull/4630 @zentol thanks for your comment. As I understand I can't merge it without a formal review. May I ask you to review it? ---

[GitHub] flink pull request #4638: [FLINK-6563] [table] Add time indicator support to...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4638#discussion_r139714565 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -62,10 +88,107

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

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

[jira] [Commented] (FLINK-5944) Flink should support reading Snappy Files

2017-09-19 Thread Mikhail Lipkovich (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171805#comment-16171805 ] Mikhail Lipkovich commented on FLINK-5944: -- The build has failed again but errors seem to be

[jira] [Commented] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171797#comment-16171797 ] ASF GitHub Bot commented on FLINK-7575: --- Github user jameslafa commented on the issue:

[GitHub] flink issue #4647: [FLINK-7575] [WEB-DASHBOARD] Display "Fetching..." instea...

2017-09-19 Thread jameslafa
Github user jameslafa commented on the issue: https://github.com/apache/flink/pull/4647 @zentol I agree, it make it a lot easier to read. I just pushed the update. Thanks for your feedback. ---

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

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

[GitHub] flink pull request #4638: [FLINK-6563] [table] Add time indicator support to...

2017-09-19 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4638#discussion_r139711376 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -106,8

[jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

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

[GitHub] flink issue #4678: [FLINK-7630] [Java API] Allow passing a File or an InputS...

2017-09-19 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4678 The changes look good! 👍 I especially like the added tests and documentation. ---

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

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

[GitHub] flink issue #4521: [FLINK-7357] [table] Created extended rules for WindowSta...

2017-09-19 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4521 Thanks for the PR @walterddr. We also need to replace group aux functions in the expressions of the filter predicate to support something like this: ``` HAVING SUM(a) >

[jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

2017-09-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171770#comment-16171770 ] Aljoscha Krettek commented on FLINK-7635: - Sounds good! +1 The important thing is also to have

[jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

2017-09-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7635: Summary: Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction (was:

[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

2017-09-19 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4665#discussion_r139702816 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java --- @@ -405,6 +411,8 @@ public

[jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext

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

[GitHub] flink issue #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / Use in ...

2017-09-19 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4616 @pnowojski and @EronWright I changed the name of the `Context`, I added a test in `StreamSinkOperatorTest`, I added methods or querying current processing time/watermark to the context. I changed

[jira] [Created] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration

2017-09-19 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7643: -- Summary: HadoopFileSystem always reloads GlobalConfiguration Key: FLINK-7643 URL: https://issues.apache.org/jira/browse/FLINK-7643 Project: Flink Issue Type:

[jira] [Closed] (FLINK-7581) Name netty threads of rest components

2017-09-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7581. --- Resolution: Fixed 1.4: 06d8e83009628a325e012635339b7e0b2821ddea > Name netty threads of rest

[jira] [Closed] (FLINK-7583) Create singleton isntance for the content type header

2017-09-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7583. --- Resolution: Fixed 1.4: ad4c41532ac22a0accf82c7ea9427aed9b71aaf4 > Create singleton isntance

[GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe...

2017-09-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4665 Would be good to rename the metric to `numLateRecordsDropped` to be more consistent with existing metrics. @aljoscha will have to comment on whether the counting is correct or not.

[jira] [Commented] (FLINK-5944) Flink should support reading Snappy Files

2017-09-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171711#comment-16171711 ] ASF GitHub Bot commented on FLINK-5944: --- GitHub user mlipkovich opened a pull request:

[GitHub] flink pull request #4683: [FLINK-5944] Support reading of Snappy files

2017-09-19 Thread mlipkovich
GitHub user mlipkovich opened a pull request: https://github.com/apache/flink/pull/4683 [FLINK-5944] Support reading of Snappy files ## What is the purpose of the change Support reading of Snappy compressed text files (both Xerial and Hadoop snappy) ## Brief

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

  1   2   3   >