[jira] [Closed] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6074. -- Resolution: Won't Fix > Fix processFunction with watermark not work well in tableAPI >

[jira] [Commented] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932181#comment-15932181 ] sunjincheng commented on FLINK-6074: Hi, [~aljoscha] Agree with you. I'll close this JIRA. > Fix

[GitHub] flink pull request #3569: [flink-6036]Let catalog support partition

2017-03-19 Thread beyond1920
GitHub user beyond1920 opened a pull request: https://github.com/apache/flink/pull/3569 [flink-6036]Let catalog support partition This pr aims to let catalog support partition. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-6119) ClusterClient Detach Mode configurable in client-api

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

[GitHub] flink pull request #3568: [FLINK-6119]: ClusterClient Detach Mode configurab...

2017-03-19 Thread RalphSu
GitHub user RalphSu opened a pull request: https://github.com/apache/flink/pull/3568 [FLINK-6119]: ClusterClient Detach Mode configurable in client-api Author: ralp...@apache.org This closes #FLINK-6119 Thanks for contributing to Apache Flink. Before you open your

[GitHub] flink issue #3559: [flink-6037] [Table API & SQL]hotfix: metadata provider d...

2017-03-19 Thread beyond1920
Github user beyond1920 commented on the issue: https://github.com/apache/flink/pull/3559 @KurtYoung , thanks for the review. I've updated the pr based on your comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Updated] (FLINK-6102) Update protobuf to latest version

2017-03-19 Thread Su Ralph (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Su Ralph updated FLINK-6102: Fix Version/s: 1.2.1 > Update protobuf to latest version > - > >

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Summary: GroupBy fields with expression can not be selected (was: GroupBy fields with expression can

[jira] [Commented] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

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

[GitHub] flink pull request #3566: [FLINK-6117]makes setting of 'zookeeper.sasl.disab...

2017-03-19 Thread vijikarthi
Github user vijikarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/3566#discussion_r106829135 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java --- @@ -89,6 +90,7 @@ public static CuratorFramework

[jira] [Updated] (FLINK-6120) Implement heartbeat logic between JobManager and ResourceManager

2017-03-19 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-6120: Description: It is part of work for Flip-6. The HeartbeatManager is mainly used for monitoring heartbeat

[jira] [Updated] (FLINK-6120) Implement heartbeat logic between JobManager and ResourceManager

2017-03-19 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-6120: Summary: Implement heartbeat logic between JobManager and ResourceManager (was: Implement heartbeat logic

[jira] [Updated] (FLINK-4354) Implement heartbeat logic between TaskManager and ResourceManager

2017-03-19 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-4354: Description: It is part of work for Flip-6. The {{HeartbeatManager}} is mainly used for monitoring

[jira] [Created] (FLINK-6120) Implement heartbeat logic between JobMaster and ResourceManager

2017-03-19 Thread zhijiang (JIRA)
zhijiang created FLINK-6120: --- Summary: Implement heartbeat logic between JobMaster and ResourceManager Key: FLINK-6120 URL: https://issues.apache.org/jira/browse/FLINK-6120 Project: Flink Issue

[jira] [Closed] (FLINK-4364) Implement heartbeat logic between TaskManager and JobManager

2017-03-19 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-4364. --- > Implement heartbeat logic between TaskManager and JobManager >

[jira] [Commented] (FLINK-6014) Allow the registration of state objects in checkpoints

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

[GitHub] flink issue #3524: [FLINK-6014][checkpoint] Allow the registration of state ...

2017-03-19 Thread shixiaogang
Github user shixiaogang commented on the issue: https://github.com/apache/flink/pull/3524 @StephanEwen Thanks a lot for your valuable comments. I will update the PR as suggested. * I think it's a good idea that we make the `StateRegistry` into `SharedStateRegistry`. That will

[jira] [Updated] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

2017-03-19 Thread canbinzheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] canbinzheng updated FLINK-6117: --- Environment: Ubuntu, non-secured (was: Ubuntu) > 'zookeeper.sasl.disable' not takes effet when

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected either using original name or expression

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Created] (FLINK-6119) ClusterClient Detach Mode configurable in client-api

2017-03-19 Thread Su Ralph (JIRA)
Su Ralph created FLINK-6119: --- Summary: ClusterClient Detach Mode configurable in client-api Key: FLINK-6119 URL: https://issues.apache.org/jira/browse/FLINK-6119 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected either using original name or expression

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Updated] (FLINK-6066) Separate logical and physical RelNode layer in Flink

2017-03-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-6066: -- Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-5565) > Separate logical and

[jira] [Updated] (FLINK-6101) GroupBy fields with expression can not be selected either using original name or expression

2017-03-19 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-6101: --- Description: currently the TableAPI do not support selecting GroupBy fields with expression either

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-19 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932059#comment-15932059 ] Luke Hutchison commented on FLINK-6115: --- N.B. the tuple field in question was of type String[], so

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[GitHub] flink pull request #3567: [FLINK-6107] Add custom checkstyle for flink-strea...

2017-03-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3567#discussion_r106821090 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java --- @@ -28,7 +28,7 @@

[GitHub] flink pull request #3567: [FLINK-6107] Add custom checkstyle for flink-strea...

2017-03-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3567#discussion_r106821059 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableAllWindowFunction.java --- @@ -1,48 +0,0 @@

[GitHub] flink pull request #3567: [FLINK-6107] Add custom checkstyle for flink-strea...

2017-03-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3567#discussion_r106821067 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableWindowFunction.java --- @@ -1,48 +0,0 @@

[GitHub] flink pull request #3567: [FLINK-6107] Add custom checkstyle for flink-strea...

2017-03-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3567#discussion_r106821137 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamingReader.java --- @@ -1,30 +0,0 @@ -/* - * Licensed to the

[GitHub] flink pull request #3567: [FLINK-6107] Add custom checkstyle for flink-strea...

2017-03-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3567#discussion_r106820944 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/OutputSelectorWrapper.java --- @@ -1,28 +0,0 @@ -/* -

[jira] [Updated] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

2017-03-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6052: -- Description: {code} Tuple2 checkpointStateHandle =

[jira] [Updated] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

2017-03-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5943: -- Description: {code} protected void shutdown(ApplicationStatus status, String msg) { // Need to clear the

[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

2017-03-19 Thread Geoffrey Mon (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931953#comment-15931953 ] Geoffrey Mon commented on FLINK-5183: - Thanks for your help! > [py] Support multiple jobs per Python

[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

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

[jira] [Closed] (FLINK-5183) [py] Support multiple jobs per Python plan file

2017-03-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5183. --- Resolution: Fixed Fix Version/s: 1.3.0 2ce080da627cbc77527b69bfb877d4904e9a0701 >

[GitHub] flink pull request #3232: [FLINK-5183] [py] Support mulitple jobs per plan f...

2017-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3232 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6114: Component/s: Core > Type checking fails with generics, even when concrete type of field is

[jira] [Commented] (FLINK-6113) Implement split/select with Side Outputs

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931927#comment-15931927 ] Aljoscha Krettek commented on FLINK-6113: - +1 This is the obvious next step! :-) > Implement

[jira] [Updated] (FLINK-6113) Implement split/select with Side Outputs

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6113: Summary: Implement split/select with Side Outputs (was: Implement split/select with

[jira] [Assigned] (FLINK-6113) Implement split/select with OutputTag

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-6113: --- Assignee: Aljoscha Krettek > Implement split/select with OutputTag >

[jira] [Commented] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931924#comment-15931924 ] Aljoscha Krettek commented on FLINK-6074: - I opened FLINK-6118 which tracks in a more general way

[jira] [Created] (FLINK-6118) Chained operators forward watermark without checking

2017-03-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6118: --- Summary: Chained operators forward watermark without checking Key: FLINK-6118 URL: https://issues.apache.org/jira/browse/FLINK-6118 Project: Flink

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931916#comment-15931916 ] Aljoscha Krettek commented on FLINK-5985: - [~srichter] Did you also put this onto the release-1.2

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[GitHub] flink issue #3567: [FLINK-6107] Add custom checkstyle for flink-streaming-ja...

2017-03-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3567 Love the checks that were enabled. They really cover most (if not all) issues that we have to raise in reviews at the moment. --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request #3567: [FLINK-6107] Add custom checkstyle for flink-strea...

2017-03-19 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/3567 [FLINK-6107] Add custom checkstyle for flink-streaming-java I played around with this a bit over the weekend... 😃 This is a proposal for a way forward from the discussion on code style

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

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

[jira] [Updated] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

2017-03-19 Thread canbinzheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] canbinzheng updated FLINK-6117: --- Description: The value of 'zookeeper.sasl.disable' not used in the right way when starting

[jira] [Commented] (FLINK-5183) [py] Support multiple jobs per Python plan file

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

[GitHub] flink issue #3232: [FLINK-5183] [py] Support mulitple jobs per plan file

2017-03-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3232 I will now try this out and merge it if it workds. --- 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

[jira] [Closed] (FLINK-5568) Introduce interface for catalog, and provide an in-memory implementation, and integrate with calcite schema

2017-03-19 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jingzhang closed FLINK-5568. > Introduce interface for catalog, and provide an in-memory implementation, and > integrate with calcite

[jira] [Resolved] (FLINK-5568) Introduce interface for catalog, and provide an in-memory implementation, and integrate with calcite schema

2017-03-19 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jingzhang resolved FLINK-5568. -- Resolution: Fixed > Introduce interface for catalog, and provide an in-memory implementation, and >

[GitHub] flink pull request #3566: [FLINK-6117]makes setting of 'zookeeper.sasl.disab...

2017-03-19 Thread gaqzcb
GitHub user gaqzcb opened a pull request: https://github.com/apache/flink/pull/3566 [FLINK-6117]makes setting of 'zookeeper.sasl.disable' work correctly Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

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

[jira] [Created] (FLINK-6117) 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework

2017-03-19 Thread canbinzheng (JIRA)
canbinzheng created FLINK-6117: -- Summary: 'zookeeper.sasl.disable' not takes effet when starting CuratorFramework Key: FLINK-6117 URL: https://issues.apache.org/jira/browse/FLINK-6117 Project: Flink

[jira] [Closed] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

2017-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-5995. -- Resolution: Fixed > Get a Exception when creating the ListStateDescriptor with a TypeInformation >

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

2017-03-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6116: --- Summary: Watermarks don't work when unioning with same DataStream Key: FLINK-6116 URL: https://issues.apache.org/jira/browse/FLINK-6116 Project: Flink

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

2017-03-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6116: Priority: Blocker (was: Major) > Watermarks don't work when unioning with same DataStream

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-19 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931600#comment-15931600 ] Luke Hutchison commented on FLINK-6115: --- More generally, why is it not possible to serialize tuples

[jira] [Created] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-19 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6115: - Summary: Need more helpful error message when trying to serialize a tuple with a null field Key: FLINK-6115 URL: https://issues.apache.org/jira/browse/FLINK-6115

[jira] [Closed] (FLINK-6067) DataSetCalc which contains filterCondition and projects would not be choose as best path in Batch TableAPI/SQL

2017-03-19 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jingzhang closed FLINK-6067. Resolution: Fixed > DataSetCalc which contains filterCondition and projects would not be choose > as best

[jira] [Commented] (FLINK-6067) DataSetCalc which contains filterCondition and projects would not be choose as best path in Batch TableAPI/SQL

2017-03-19 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931593#comment-15931593 ] jingzhang commented on FLINK-6067: -- [~ykt836], it works, thanks a lot. I would close this jira. >

[jira] [Created] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-19 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6114: - Summary: Type checking fails with generics, even when concrete type of field is not needed Key: FLINK-6114 URL: https://issues.apache.org/jira/browse/FLINK-6114