[jira] [Closed] (FLINK-6491) Add QueryConfig to specify state retention time for streaming queries

2017-05-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6491. Resolution: Implemented Fix Version/s: 1.4.0 1.3.0 Implemented for 1.3 wit

[jira] [Closed] (FLINK-6483) Support time materialization

2017-05-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6483. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3 with 2c65843fc9

[GitHub] flink pull request #3870: [Flink 6537] Fixes and improvements for incrementa...

2017-05-11 Thread shixiaogang
Github user shixiaogang commented on a diff in the pull request: https://github.com/apache/flink/pull/3870#discussion_r116161754 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -922,6 +9

[GitHub] flink pull request #3870: [Flink 6537] Fixes and improvements for incrementa...

2017-05-11 Thread shixiaogang
Github user shixiaogang commented on a diff in the pull request: https://github.com/apache/flink/pull/3870#discussion_r116161318 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java --- @@

[GitHub] flink pull request #3870: [Flink 6537] Fixes and improvements for incrementa...

2017-05-11 Thread shixiaogang
Github user shixiaogang commented on a diff in the pull request: https://github.com/apache/flink/pull/3870#discussion_r116161230 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java --- @@

[GitHub] flink pull request #3870: [Flink 6537] Fixes and improvements for incrementa...

2017-05-11 Thread shixiaogang
Github user shixiaogang commented on a diff in the pull request: https://github.com/apache/flink/pull/3870#discussion_r116161117 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java --- @@

[jira] [Commented] (FLINK-6491) Add QueryConfig to specify state retention time for streaming queries

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007686#comment-16007686 ] ASF GitHub Bot commented on FLINK-6491: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-6483) Support time materialization

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007687#comment-16007687 ] ASF GitHub Bot commented on FLINK-6483: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3862: [FLINK-6483] [table] Support time materialization

2017-05-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3862 --- 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 enab

[GitHub] flink pull request #3863: [FLINK-6491][talbe]Add QueryConfig to specify stat...

2017-05-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3863 --- 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 enab

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007672#comment-16007672 ] ASF GitHub Bot commented on FLINK-6514: --- Github user aljoscha commented on the issue

[GitHub] flink pull request #3876: [FLINK-6514] [build] Create a proper separate Hado...

2017-05-11 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3876#discussion_r116157739 --- Diff: flink-shaded-hadoop/flink-shaded-hadoop2-uber/pom.xml --- @@ -0,0 +1,129 @@ + + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="

[GitHub] flink issue #3877: [backport] [FLINK-6514] [build] Create a proper separate ...

2017-05-11 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3877 The only diff from #3876 is the dropping of the jersey/jettison/servlet deps, right? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007670#comment-16007670 ] ASF GitHub Bot commented on FLINK-6514: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007669#comment-16007669 ] ASF GitHub Bot commented on FLINK-6514: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #3877: [backport] [FLINK-6514] [build] Create a proper se...

2017-05-11 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3877#discussion_r116157591 --- Diff: flink-shaded-hadoop/flink-shaded-hadoop2-uber/pom.xml --- @@ -0,0 +1,129 @@ + + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="

[GitHub] flink pull request #3876: [FLINK-6514] [build] Create a proper separate Hado...

2017-05-11 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3876#discussion_r116157373 --- Diff: flink-dist/pom.xml --- @@ -403,15 +403,6 @@ under the License. -

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007668#comment-16007668 ] ASF GitHub Bot commented on FLINK-6514: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

2017-05-11 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007657#comment-16007657 ] ramkrishna.s.vasudevan commented on FLINK-6284: --- I can try to do this by end

[jira] [Commented] (FLINK-6564) Build fails on file systems that do not distinguish between upper and lower case

2017-05-11 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007656#comment-16007656 ] Fang Yong commented on FLINK-6564: -- Thank you for your report, and also I meet this probl

[jira] [Commented] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007598#comment-16007598 ] ASF GitHub Bot commented on FLINK-6504: --- Github user shixiaogang commented on a diff

[GitHub] flink pull request #3859: [FLINK-6504] [FLINK-6467] [checkpoints] Add needed...

2017-05-11 Thread shixiaogang
Github user shixiaogang commented on a diff in the pull request: https://github.com/apache/flink/pull/3859#discussion_r116148624 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -911,9 +9

[GitHub] flink pull request #3806: [FLINK-6426][table]Update the document of group-wi...

2017-05-11 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3806#discussion_r116146470 --- Diff: docs/dev/table_api.md --- @@ -1099,14 +1099,14 @@ Temporal intervals can be represented as number of months (`Types.INTERVAL_MONTH

issues@flink.apache.org

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007577#comment-16007577 ] ASF GitHub Bot commented on FLINK-6426: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #3806: [FLINK-6426][table]Update the document of group-wi...

2017-05-11 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3806#discussion_r116146239 --- Diff: docs/dev/table_api.md --- @@ -1485,14 +1485,14 @@ Joins, set operations, and non-windowed aggregations are not supported yet. {%

issues@flink.apache.org

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007580#comment-16007580 ] ASF GitHub Bot commented on FLINK-6426: --- Github user sunjincheng121 commented on a d

[jira] [Commented] (FLINK-6457) Clean up ScalarFunction and TableFunction interface

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007513#comment-16007513 ] ASF GitHub Bot commented on FLINK-6457: --- GitHub user Xpray opened a pull request:

[GitHub] flink pull request #3880: [FLINK-6457] Clean up ScalarFunction and TableFunc...

2017-05-11 Thread Xpray
GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/3880 [FLINK-6457] Clean up ScalarFunction and TableFunction interface Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Updated] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

2017-05-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6310: -- Description: Here is related code: {code} public void endSession(JobID jobID) throws Exception { synchron

[jira] [Created] (FLINK-6564) Build fails on file systems that do not distinguish between upper and lower case

2017-05-11 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-6564: Summary: Build fails on file systems that do not distinguish between upper and lower case Key: FLINK-6564 URL: https://issues.apache.org/jira/browse/FLINK-6564 Projec

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

2017-05-11 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6563: -- Priority: Critical (was: Major) Component/s: Table API & SQL > Expose time indicator attributes

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

2017-05-11 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6563: - Summary: Expose time indicator attributes in the KafkaTableSource Key: FLINK-6563 URL: https://issues.apache.org/jira/browse/FLINK-6563 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6562) Support implicit table references for nested fields in SQL

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007320#comment-16007320 ] ASF GitHub Bot commented on FLINK-6562: --- GitHub user haohui opened a pull request:

[GitHub] flink pull request #3879: [FLINK-6562] Support implicit table references for...

2017-05-11 Thread haohui
GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/3879 [FLINK-6562] Support implicit table references for nested fields in SQL. You can merge this pull request into a Git repository by running: $ git pull https://github.com/haohui/flink FLINK-6562

[jira] [Commented] (FLINK-6483) Support time materialization

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007234#comment-16007234 ] ASF GitHub Bot commented on FLINK-6483: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3862: [FLINK-6483] [table] Support time materialization

2017-05-11 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3862 Thanks for the update @twalthr! Looks very good. Will merge this. --- 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-6221) Add Prometheus support to metrics

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007215#comment-16007215 ] ASF GitHub Bot commented on FLINK-6221: --- Github user hadronzoo commented on the issu

[GitHub] flink issue #3833: [FLINK-6221] Add PrometheusReporter

2017-05-11 Thread hadronzoo
Github user hadronzoo commented on the issue: https://github.com/apache/flink/pull/3833 @mbode thanks for working on this! One thing that I've found useful when exporting Flink's statsd metrics to Prometheus is to make several of the metric fields tags: like `job_name`, `task

[jira] [Created] (FLINK-6562) Support implicit table references for nested fields in SQL

2017-05-11 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6562: - Summary: Support implicit table references for nested fields in SQL Key: FLINK-6562 URL: https://issues.apache.org/jira/browse/FLINK-6562 Project: Flink Issue Type

[jira] [Updated] (FLINK-6562) Support implicit table references for nested fields in SQL

2017-05-11 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6562: -- Component/s: Table API & SQL > Support implicit table references for nested fields in SQL >

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-05-11 Thread haohui
Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r116092436 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@ -438,

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007125#comment-16007125 ] ASF GitHub Bot commented on FLINK-6225: --- Github user haohui commented on a diff in t

[jira] [Commented] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

2017-05-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007119#comment-16007119 ] Robert Metzger commented on FLINK-6284: --- I think nobody is working on the issue righ

[jira] [Commented] (FLINK-6561) GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007081#comment-16007081 ] ASF GitHub Bot commented on FLINK-6561: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6548) AvroOutputFormatTest fails on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007079#comment-16007079 ] ASF GitHub Bot commented on FLINK-6548: --- Github user zentol commented on the issue:

[GitHub] flink issue #3874: [FLINK-6558] Disable yarn tests on Windows

2017-05-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3874 Merging. --- 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 fea

[jira] [Commented] (FLINK-6558) Yarn tests fail on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007080#comment-16007080 ] ASF GitHub Bot commented on FLINK-6558: --- Github user zentol commented on the issue:

[GitHub] flink issue #3878: [FLINK-6561] Disable glob test on Windows

2017-05-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3878 Merging. --- 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 fea

[GitHub] flink issue #3871: [FLINK-6548] Fix AvroOutputFormatTest#testCompression on ...

2017-05-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3871 Merging. --- 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 fea

[jira] [Commented] (FLINK-6561) GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007074#comment-16007074 ] ASF GitHub Bot commented on FLINK-6561: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3878: [FLINK-6561] Disable glob test on Windows

2017-05-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3878 Looks good, +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 enabled and wish

[jira] [Commented] (FLINK-6561) GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007068#comment-16007068 ] ASF GitHub Bot commented on FLINK-6561: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3878: [FLINK-6561] Disable glob test on Windows

2017-05-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3878 [FLINK-6561] Disable glob test on Windows This PR disables a test case in the `GlobFilePathFilterTest`. The test verified that a file name containing asterisks `(*)` was properly filtered out; this

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007050#comment-16007050 ] ASF GitHub Bot commented on FLINK-6514: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request #3877: [backport] [FLINK-6514] [build] Create a proper se...

2017-05-11 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/3877 [backport] [FLINK-6514] [build] Create a proper separate Hadoop uber jar for 'flink-dist' assembly Backport of #3876 to `release-1.3` This fixes the issue that Flink cannot be started l

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007041#comment-16007041 ] ASF GitHub Bot commented on FLINK-6514: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request #3876: [FLINK-6514] [build] Create a proper separate Hado...

2017-05-11 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/3876 [FLINK-6514] [build] Create a proper separate Hadoop uber jar for 'flink-dist' assembly This fixes the issue that Flink cannot be started locally if built with Maven 3.3+ There are two

[jira] [Created] (FLINK-6561) GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows

2017-05-11 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6561: --- Summary: GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows Key: FLINK-6561 URL: https://issues.apache.org/jira/browse/FLINK-6561 Project: Fli

[jira] [Commented] (FLINK-6560) Restore maven parallelism in flink-tests

2017-05-11 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007026#comment-16007026 ] Greg Hogan commented on FLINK-6560: --- I had thought {{flink-tests}} was taking longer but

[jira] [Commented] (FLINK-6560) Restore maven parallelism in flink-tests

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007021#comment-16007021 ] ASF GitHub Bot commented on FLINK-6560: --- GitHub user greghogan opened a pull request

[jira] [Closed] (FLINK-6553) Calls to getSideOutput() result in warnings regarding unchecked assignments

2017-05-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6553. --- Resolution: Not A Problem Oh boy, i just forgot the generics on the original DataStream... >

[GitHub] flink pull request #3875: [FLINK-6560] [build] Restore maven parallelism in ...

2017-05-11 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3875 [FLINK-6560] [build] Restore maven parallelism in flink-tests Configure a default value for Maven variable 'flink.forkCountTestPackage'. You can merge this pull request into a Git repository by ru

[jira] [Commented] (FLINK-5053) Incremental / lightweight snapshots for checkpoints

2017-05-11 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006995#comment-16006995 ] Stefan Richter commented on FLINK-5053: --- I have opened this jira to track everything

[jira] [Commented] (FLINK-5053) Incremental / lightweight snapshots for checkpoints

2017-05-11 Thread vishnu viswanath (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006987#comment-16006987 ] vishnu viswanath commented on FLINK-5053: - is this task complete, I see all the pu

[jira] [Closed] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6414. --- > Use scala.binary.version in place of change-scala-version.sh > -

[jira] [Resolved] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6414. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 35c087129e2a27c2db47c5ed5ce3fb3523a7c719

[jira] [Commented] (FLINK-6466) Build Hadoop 2.8.0 convenience binaries

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006960#comment-16006960 ] ASF GitHub Bot commented on FLINK-6466: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3832: [FLINK-6466] [build] Build Hadoop 2.8.0 convenience binar...

2017-05-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3832 +1 for 1.4 - just spent some good time cleaning up dependencies (also from Hadoop) and this will almost certainly require to do another such pass... --- If your project is set up for it, you can

[jira] [Commented] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006955#comment-16006955 ] ASF GitHub Bot commented on FLINK-6414: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3800: [FLINK-6414] [build] Use scala.binary.version in place of...

2017-05-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3800 @rmetzger I have tried to put this into 1.3 as well - seems to work... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your proj

[jira] [Updated] (FLINK-6541) Jar upload directory not created

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-6541: Priority: Critical (was: Major) > Jar upload directory not created > --

[jira] [Commented] (FLINK-6541) Jar upload directory not created

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006952#comment-16006952 ] Stephan Ewen commented on FLINK-6541: - Good finds! Do you want to provide a pull requ

[jira] [Commented] (FLINK-6554) CompatibilityResult should contain a notCompatible() option

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006942#comment-16006942 ] Stephan Ewen commented on FLINK-6554: - +1, incompatibility is always possible and shou

[jira] [Commented] (FLINK-6553) Calls to getSideOutput() result in warnings regarding unchecked assignments

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006947#comment-16006947 ] Stephan Ewen commented on FLINK-6553: - Is this simply a missing {{@SafeVarargs}} or mo

[jira] [Updated] (FLINK-6560) Restore maven parallelism in flink-tests

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-6560: Priority: Critical (was: Minor) > Restore maven parallelism in flink-tests > --

[jira] [Commented] (FLINK-6560) Restore maven parallelism in flink-tests

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006939#comment-16006939 ] Stephan Ewen commented on FLINK-6560: - +1, I also see longer build time locally > Res

[jira] [Assigned] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-6514: --- Assignee: Stephan Ewen > Cannot start Flink Cluster in standalone mode >

[GitHub] flink pull request #3873: [FLINK-6555] [futures] Generalize ConjunctFuture t...

2017-05-11 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3873#discussion_r116062457 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -163,26 +165,31 @@ public static ConjunctFuture combin

[jira] [Commented] (FLINK-6555) Generalize ConjunctFuture

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006916#comment-16006916 ] ASF GitHub Bot commented on FLINK-6555: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006903#comment-16006903 ] Stephan Ewen commented on FLINK-6514: - There are more issues. The way this is set up r

[jira] [Commented] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006889#comment-16006889 ] Stephan Ewen commented on FLINK-6116: - Ah, great! Yes, this definition of identity by

[jira] [Created] (FLINK-6560) Restore maven parallelism in flink-tests

2017-05-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6560: - Summary: Restore maven parallelism in flink-tests Key: FLINK-6560 URL: https://issues.apache.org/jira/browse/FLINK-6560 Project: Flink Issue Type: Bug Co

[jira] [Closed] (FLINK-6393) Add Evenly Graph Generator to Flink Gelly

2017-05-11 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6393. - Resolution: Implemented Fix Version/s: 1.4.0 1.3.0 master: 3ee8c69aa4390a8d51b33

[jira] [Created] (FLINK-6559) Rename 'slaves' to 'workers'

2017-05-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6559: --- Summary: Rename 'slaves' to 'workers' Key: FLINK-6559 URL: https://issues.apache.org/jira/browse/FLINK-6559 Project: Flink Issue Type: Improvement Co

[jira] [Commented] (FLINK-6558) Yarn tests fail on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006810#comment-16006810 ] ASF GitHub Bot commented on FLINK-6558: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3874: [FLINK-6558] Disable yarn tests on Windows

2017-05-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3874 Looks good to me, +1 to merge this... --- 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 en

[jira] [Commented] (FLINK-6548) AvroOutputFormatTest fails on Windows

2017-05-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006808#comment-16006808 ] ASF GitHub Bot commented on FLINK-6548: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3871: [FLINK-6548] Fix AvroOutputFormatTest#testCompression on ...

2017-05-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3871 +1, looks good --- 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

[jira] [Comment Edited] (FLINK-5753) CEP timeout handler.

2017-05-11 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006685#comment-16006685 ] Kostas Kloudas edited comment on FLINK-5753 at 5/11/17 4:59 PM:

[GitHub] flink pull request #3802: Add Evenly Graph Generator to Flink Gelly

2017-05-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3802 --- 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 enab

[GitHub] flink pull request #3866: A refactor to avoid cloned code in try-catch block...

2017-05-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3866 --- 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 enab

[jira] [Resolved] (FLINK-6501) Make sure NOTICE files are bundled into shaded JAR files

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6501. - Resolution: Fixed Fixed in - 1.3.0 via 95fd2d371eae43be1ea2534efe653af1a7095d0b - 1.4.0 via 60

[jira] [Closed] (FLINK-6501) Make sure NOTICE files are bundled into shaded JAR files

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6501. --- > Make sure NOTICE files are bundled into shaded JAR files > -

[jira] [Closed] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6515. --- > KafkaConsumer checkpointing fails because of ClassLoader issues > --

[jira] [Resolved] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6515. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed in - 1.3.0 via cc3512ee9bbcc965278b43642cc94

[jira] [Closed] (FLINK-6508) Include license files of packaged dependencies

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6508. --- > Include license files of packaged dependencies > -- > >

[jira] [Resolved] (FLINK-6508) Include license files of packaged dependencies

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6508. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed in - 1.3.0 via 1b2173712dea5a5b95633af82623b

[jira] [Commented] (FLINK-6542) Non-keyed, non-windowed aggregation fails

2017-05-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006720#comment-16006720 ] Xingcan Cui commented on FLINK-6542: Hi [~twalthr], maybe we forget to call env.execut

[jira] [Commented] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006719#comment-16006719 ] Stephan Ewen commented on FLINK-5679: - {{PartitionedStateCheckpointingITCase}} refacto

[jira] [Closed] (FLINK-6531) Deserialize checkpoint hooks with user classloader

2017-05-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6531. --- > Deserialize checkpoint hooks with user classloader > --

  1   2   3   >