[jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721533#comment-15721533 ] Fabian Hueske commented on FLINK-4704: -- +1 Let's do this before the 1.2 release. > M

[jira] [Updated] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4704: - Fix Version/s: 1.2.0 > Move Table API to org.apache.flink.table >

[jira] [Commented] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721535#comment-15721535 ] Fabian Hueske commented on FLINK-5186: -- +1 let's do this before Flink 1.2 > Move Row

[jira] [Updated] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4704: - Priority: Critical (was: Major) > Move Table API to org.apache.flink.table >

[jira] [Updated] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5186: - Fix Version/s: 1.2.0 > Move Row and RowTypeInfo into Flink core >

[jira] [Updated] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5186: - Priority: Critical (was: Major) > Move Row and RowTypeInfo into Flink core >

[jira] [Comment Edited] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721535#comment-15721535 ] Fabian Hueske edited comment on FLINK-5186 at 12/5/16 8:04 AM: -

[jira] [Assigned] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4704: --- Assignee: Timo Walther > Move Table API to org.apache.flink.table > -

[jira] [Created] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

2016-12-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5255: Summary: Improve single row check in DataSetSingleRowJoinRule Key: FLINK-5255 URL: https://issues.apache.org/jira/browse/FLINK-5255 Project: Flink Issue Type

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721565#comment-15721565 ] Fabian Hueske commented on FLINK-5255: -- Hi [~AlexanderShoshin], you implemented the {

[jira] [Created] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5256: Summary: Extend DataSetSingleRowJoin to support Left and Right joins Key: FLINK-5256 URL: https://issues.apache.org/jira/browse/FLINK-5256 Project: Flink Is

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721589#comment-15721589 ] Fabian Hueske commented on FLINK-5256: -- [~AlexanderShoshin] are you interested in wor

[jira] [Commented] (FLINK-4300) Improve error message for different Scala versions of JM and Client

2016-12-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721686#comment-15721686 ] Sergio Fernández commented on FLINK-4300: - Any progress on this? As [docker-flin

[jira] [Updated] (FLINK-5188) Adjust all the imports referencing Row and RowTypeInfo

2016-12-05 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5188: - Summary: Adjust all the imports referencing Row and RowTypeInfo (was: Shade dependency) > Adjust

[jira] [Updated] (FLINK-5188) Adjust all the imports referencing Row

2016-12-05 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5188: - Summary: Adjust all the imports referencing Row (was: Adjust all the imports referencing Row and

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

2016-12-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2629 Hi @bjlovegithub, just wanted check whether I can help you with anything to complete this PR and get it merged. If that's the case, then let me know. --- If your project is set up for it, you c

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721714#comment-15721714 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on the i

[GitHub] flink pull request #2729: [FLINK-4883]Prevent UDFs implementations through S...

2016-12-05 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2729#discussion_r90827814 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/ScalaObjectChecker.java --- @@ -0,0 +1,51 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

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

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

2016-12-05 Thread bjlovegithub
Github user bjlovegithub commented on the issue: https://github.com/apache/flink/pull/2629 Hi @tillrohrmann Thanks for your help. I am still working on it, adding more test cases and modifying its internal data structure. It almost has been done. But due to other jobs, I can not work

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721738#comment-15721738 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the i

[jira] [Created] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-05 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5257: - Summary: Display optimized logical plan when explaining table Key: FLINK-5257 URL: https://issues.apache.org/jira/browse/FLINK-5257 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable

2016-12-05 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5251: -- Component/s: Table API & SQL > Decouple StreamTableSourceScan with TableSourceTable > --

[jira] [Commented] (FLINK-4303) Add CEP examples

2016-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721761#comment-15721761 ] Till Rohrmann commented on FLINK-4303: -- True, we can use the cep-monitoring example o

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-12-05 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 Hi @fhueske , I see conflicts PR check, should I rebase new commits, or merge it? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

[GitHub] flink pull request #2937: [FLINK-4303] Examples for CEP library.

2016-12-05 Thread chermenin
GitHub user chermenin opened a pull request: https://github.com/apache/flink/pull/2937 [FLINK-4303] Examples for CEP library. Added example programs written in Java and Scala. They based on @tillrohrmann 's monitoring example. This issue will be closed by this PR: https://issue

[GitHub] flink pull request #2938: [FLINK-4692] [tableApi] Add tumbling group-windows...

2016-12-05 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2938 [FLINK-4692] [tableApi] Add tumbling group-windows for batch tables Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideratio

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[jira] [Commented] (FLINK-4303) Add CEP examples

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

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

[jira] [Created] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication

2016-12-05 Thread David Anderson (JIRA)
David Anderson created FLINK-5258: - Summary: reorganize the docs to improve navigation and reduce duplication Key: FLINK-5258 URL: https://issues.apache.org/jira/browse/FLINK-5258 Project: Flink

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-12-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2810 Please rebase. Thanks! --- 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

[GitHub] flink pull request #2939: [FLINK-5113] Ports all functions in the tests to t...

2016-12-05 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2939 [FLINK-5113] Ports all functions in the tests to the new checkpointing interface. This PR only touches testing code. It refactors all the tests that were using the `Checkpointed` and `Checkpointed

[jira] [Commented] (FLINK-5113) Make all Testing Functions implement CheckpointedFunction Interface.

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

[jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API

2016-12-05 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-3320: --- Assignee: Anton Mushin > Add not operator to CEP's pattern API >

[jira] [Commented] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication

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

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721865#comment-15721865 ] Robert Metzger commented on FLINK-5039: --- Thanks a lot for looking into the issue. I

[jira] [Commented] (FLINK-4303) Add CEP examples

2016-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721869#comment-15721869 ] Till Rohrmann commented on FLINK-4303: -- I've uploaded the code to the repository htt

[GitHub] flink pull request #2940: [FLINK-5258] [docs] reorganize the docs to improve...

2016-12-05 Thread alpinegizmo
GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/2940 [FLINK-5258] [docs] reorganize the docs to improve navigation and reduce duplication Goals: * improve navigation and discoverability: important topics shouldn't be hard to find * reduce

[GitHub] flink pull request #2941: [FLINK-3555] Web interface does not render job inf...

2016-12-05 Thread bitchelov
GitHub user bitchelov opened a pull request: https://github.com/apache/flink/pull/2941 [FLINK-3555] Web interface does not render job information properly Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerat

[jira] [Commented] (FLINK-3555) Web interface does not render job information properly

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

[jira] [Commented] (FLINK-4693) Add session group-windows for batch tables

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721897#comment-15721897 ] ASF GitHub Bot commented on FLINK-4693: --- GitHub user sunjincheng121 opened a pull re

[GitHub] flink pull request #2942: [FLINK-4693][tableApi] Add session group-windows f...

2016-12-05 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/2942 [FLINK-4693][tableApi] Add session group-windows for batch tables Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into conside

[jira] [Updated] (FLINK-5221) Checkpointed workless in Window Operator

2016-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5221: - Fix Version/s: 1.2.0 > Checkpointed workless in Window Operator >

[jira] [Created] (FLINK-5259) wrong execution environment in retry delays example

2016-12-05 Thread David Anderson (JIRA)
David Anderson created FLINK-5259: - Summary: wrong execution environment in retry delays example Key: FLINK-5259 URL: https://issues.apache.org/jira/browse/FLINK-5259 Project: Flink Issue Typ

[jira] [Updated] (FLINK-5221) Checkpointed workless in Window Operator

2016-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5221: - Affects Version/s: 1.2.0 > Checkpointed workless in Window Operator >

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-05 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2886 I tested this, but could not reproduce the reported erroneous behaviour. After the task manager reconnects to a new job manager, the metrics are still being reported. I tested this with JMX and Log4j rep

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

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

[GitHub] flink issue #2928: [FLINK-5108] Remove ClientShutdownHook during job executi...

2016-12-05 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2928 Thanks for the PR! This removes the shutdown hook after the cluster has been deployed. The original intend was to remove it only after job submission. Probably it makes sense to remove it all-together. I

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

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

[GitHub] flink pull request #2943: [FLINK-5259] [docs] wrong execution environment in...

2016-12-05 Thread alpinegizmo
GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/2943 [FLINK-5259] [docs] wrong execution environment in batch retry delays… At dev/batch/fault_tolerance.html#retry-delays StreamExecutionEnvironment is used in the example code, but this page is a

[jira] [Commented] (FLINK-5259) wrong execution environment in retry delays example

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

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-05 Thread Bruno Dumon (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721927#comment-15721927 ] Bruno Dumon commented on FLINK-5039: Looks like a suboptimal solution to me, given tha

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

2016-12-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2629 Great to hear @bjlovegithub :-) Ping me once you've pushed some new commits. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If yo

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721929#comment-15721929 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on the i

[jira] [Closed] (FLINK-5246) Don't discard unknown checkpoint messages in the CheckpointCoordinator

2016-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5246. Resolution: Fixed Fixed via https://github.com/apache/flink/commit/da09d418c1add17169368a38aeb9d793

[GitHub] flink pull request #2930: [FLINK-5246] Don't discard checkpoint messages if ...

2016-12-05 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2930 --- 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 i

[jira] [Commented] (FLINK-5246) Don't discard unknown checkpoint messages in the CheckpointCoordinator

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721958#comment-15721958 ] ASF GitHub Bot commented on FLINK-5246: --- Github user tillrohrmann closed the pull re

[jira] [Commented] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721959#comment-15721959 ] Ufuk Celebi commented on FLINK-4651: Talked to [~aljoscha] about back porting this, I

[jira] [Commented] (FLINK-5233) Upgrade Jackson version because of class loader leak

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721962#comment-15721962 ] Ufuk Celebi commented on FLINK-5233: Talked to [~rmetzger] about this. He couldn't rep

[jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721966#comment-15721966 ] Ufuk Celebi commented on FLINK-5048: Talked to [~rmetzger] about this and we would lik

[jira] [Updated] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5048: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Kafka Consumer (0.9/0.10) threading model l

[jira] [Assigned] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

2016-12-05 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-5255: Assignee: Alexander Shoshin > Improve single row check in DataSetSingleRowJoinRule

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

2016-12-05 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721990#comment-15721990 ] Alexander Shoshin commented on FLINK-5255: -- Hi [~fhueske]. Yes, I would. Thanks

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-05 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722033#comment-15722033 ] Alexander Shoshin commented on FLINK-5256: -- Yes, I am. I will take it. [~fhueske]

[jira] [Assigned] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-05 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-5256: Assignee: Alexander Shoshin > Extend DataSetSingleRowJoin to support Left and Right

[jira] [Created] (FLINK-5260) Add docs about how to react to cancellation

2016-12-05 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5260: -- Summary: Add docs about how to react to cancellation Key: FLINK-5260 URL: https://issues.apache.org/jira/browse/FLINK-5260 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

2016-12-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722059#comment-15722059 ] Till Rohrmann commented on FLINK-5214: -- Hi [~xiaogang.shi], you're right that in case

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722067#comment-15722067 ] Fabian Hueske commented on FLINK-5256: -- The query {code} SELECT b, sum(a) FROM x GR

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722069#comment-15722069 ] Fabian Hueske commented on FLINK-5256: -- Thanks [~AlexanderShoshin]! > Extend DataSet

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-12-05 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 @wuchong, @fhueske, question about field shuffling, should I shuffle it in RowCsvInputFormat by setting an order to scan, or let LogicalCal do it? --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

[jira] [Commented] (FLINK-5247) Setting allowedLateness to a non-zero value should throw exception for processing-time windows

2016-12-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722172#comment-15722172 ] Aljoscha Krettek commented on FLINK-5247: - I'm not sure we actually want this. The

[jira] [Created] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

2016-12-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5261: --- Summary: ScheduledDropwizardReporter does not properly clean up metrics Key: FLINK-5261 URL: https://issues.apache.org/jira/browse/FLINK-5261 Project: Flink

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

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

[GitHub] flink issue #2928: [FLINK-5108] Remove ClientShutdownHook during job executi...

2016-12-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2928 What speaks against not having a shutdown hook at all? --- 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 ha

[jira] [Commented] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

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

[GitHub] flink pull request #2944: [FLINK-5261] Clean up meters in ScheduledDropwizar...

2016-12-05 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2944 [FLINK-5261] Clean up meters in ScheduledDropwizardReporter This PR fixes the metric-cleanup in the `ScheduledDropwizardReporter`. We were missing a separate branch for meters within `notifyOfRemoved

[jira] [Updated] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

2016-12-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5261: Fix Version/s: (was: 1.1.4) > ScheduledDropwizardReporter does not properly clean up met

[jira] [Updated] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

2016-12-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5261: Affects Version/s: (was: 1.1.3) > ScheduledDropwizardReporter does not properly clean up

[jira] [Reopened] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-5248: > SavepointITCase doesn't catch savepoint restore failure >

[jira] [Updated] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5248: --- Fix Version/s: 1.1.4 1.2.0 > SavepointITCase doesn't catch savepoint restore failur

[jira] [Closed] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5248. -- Resolution: Fixed Fixed in 4dee8fe (master), a5065e3 (release-1.1). > SavepointITCase doesn't catch sav

[jira] [Closed] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

2016-12-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5248. -- Resolution: Fixed > SavepointITCase doesn't catch savepoint restore failure > --

[GitHub] flink pull request #2944: [FLINK-5261] Clean up meters in ScheduledDropwizar...

2016-12-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2944#discussion_r90864577 --- Diff: flink-metrics/flink-metrics-dropwizard/src/main/java/org/apache/flink/dropwizard/ScheduledDropwizardReporter.java --- @@ -91,6 +91,10 @@ protected Sche

[GitHub] flink pull request #2944: [FLINK-5261] Clean up meters in ScheduledDropwizar...

2016-12-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2944#discussion_r90864749 --- Diff: flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/ScheduledDropwizardReporterTest.java --- @@ -124,6 +129,89 @@ public v

[jira] [Commented] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722282#comment-15722282 ] ASF GitHub Bot commented on FLINK-5261: --- Github user uce commented on a diff in the

[GitHub] flink pull request #2944: [FLINK-5261] Clean up meters in ScheduledDropwizar...

2016-12-05 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2944#discussion_r90864551 --- Diff: flink-metrics/flink-metrics-dropwizard/src/main/java/org/apache/flink/dropwizard/ScheduledDropwizardReporter.java --- @@ -91,6 +91,10 @@ protected Sche

[jira] [Commented] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722281#comment-15722281 ] ASF GitHub Bot commented on FLINK-5261: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722283#comment-15722283 ] ASF GitHub Bot commented on FLINK-5261: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

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

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-05 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2886 Can you open a PR with a backport of this for 1.1.4 please? --- 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 t

[jira] [Created] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts

2016-12-05 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-5262: - Summary: Docs: Introduce a Gemfile.lock to avoid dependency range conflicts Key: FLINK-5262 URL: https://issues.apache.org/jira/browse/FLINK-5262 Project: F

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

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

[GitHub] flink issue #2729: [FLINK-4883]Prevent UDFs implementations through Scala si...

2016-12-05 Thread Renkai
Github user Renkai commented on the issue: https://github.com/apache/flink/pull/2729 Hi, @StefanRRichter , I optimized the code with your advice. --- 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 ha

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2016-12-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15722311#comment-15722311 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the iss

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2016-12-05 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 Sorry, something was wrong when I am rebase. --- 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 feat

[jira] [Updated] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts

2016-12-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5262: -- Description: The {{Gemfile}} for specifying the Ruby dependencies of our documentation h

[GitHub] flink pull request #2945: [FLINK-5262][docs] Introduce Gemfile.lock to avoid...

2016-12-05 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2945 [FLINK-5262][docs] Introduce Gemfile.lock to avoid dependency range conflicts The Gemfile for specifying the Ruby dependencies of our documentation has fixed dependency versions to avoid incompatibl

  1   2   3   >