[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-6101:
---
Fix Version/s: 1.3.0
> GroupBy fields with arithmetic expression (include UDF) can not be selected
> -
[
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 us
[
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 us
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932217#comment-15932217
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user gaqzcb commented on a diff in t
Github user gaqzcb commented on a diff in the pull request:
https://github.com/apache/flink/pull/3566#discussion_r106839886
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
---
@@ -89,6 +90,7 @@ public static CuratorFramework
startCuratorFra
[
https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932215#comment-15932215
]
ASF GitHub Bot commented on FLINK-5634:
---
Github user jgrier closed the pull request
Github user jgrier closed the pull request at:
https://github.com/apache/flink/pull/3204
---
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
[
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 arithmetic expression (include UDF) can not be
selected (was: GroupBy fi
[
https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932206#comment-15932206
]
ASF GitHub Bot commented on FLINK-6020:
---
Github user WangTaoTheTonic commented on th
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3525
ping @StephanEwen
---
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 wishe
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932181#comment-15932181
]
sunjincheng commented on FLINK-6074:
Hi, [~aljoscha] Agree with you. I'll close this J
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 https://github.com/aliba
[
https://issues.apache.org/jira/browse/FLINK-6119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932155#comment-15932155
]
ASF GitHub Bot commented on FLINK-6119:
---
GitHub user RalphSu opened a pull request:
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 p
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. If
[
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 us
[
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 us
[
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 us
[
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 us
[
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
> -
>
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932092#comment-15932092
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user vijikarthi commented on a diff
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
startCurato
[
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 ta
[
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 b
[
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 heartbea
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 Ty
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932078#comment-15932078
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on the is
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 nee
[
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 start
[
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 us
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
[
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 us
[
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 ph
[
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 us
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932059#comment-15932059
]
Luke Hutchison commented on FLINK-6115:
---
N.B. the tuple field in question was of typ
[
https://issues.apache.org/jira/browse/FLINK-6066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-6066:
-
Assignee: Kurt Young
> Separate logical and physical RelNode layer in Flink
> ---
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932005#comment-15932005
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932004#comment-15932004
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932003#comment-15932003
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932002#comment-15932002
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932006#comment-15932006
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user zentol commented on a diff in t
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 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 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 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 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 @@
-/*
-
[
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, String>
checkpointStateHandle = checkpointStateHandles.peekLast();
[
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 j
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931953#comment-15931953
]
Geoffrey Mon commented on FLINK-5183:
-
Thanks for your help!
> [py] Support multiple
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931933#comment-15931933
]
ASF GitHub Bot commented on FLINK-5183:
---
Github user asfgit closed the pull request
[
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
> [py]
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 enab
[
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 n
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931927#comment-15931927
]
Aljoscha Krettek commented on FLINK-6113:
-
+1 This is the obvious next step! :-)
[
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 OutputT
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931924#comment-15931924
]
Aljoscha Krettek commented on FLINK-6074:
-
I opened FLINK-6118 which tracks in a m
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
Issu
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931916#comment-15931916
]
Aljoscha Krettek commented on FLINK-5985:
-
[~srichter] Did you also put this onto
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931801#comment-15931801
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user zentol commented on the issue:
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 hav
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
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931770#comment-15931770
]
ASF GitHub Bot commented on FLINK-6107:
---
GitHub user aljoscha opened a pull request:
[
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
CuratorFra
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
canbinzheng updated FLINK-6117:
---
Affects Version/s: (was: 1.1.5)
(was: 1.3.0)
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5183:
---
Assignee: Geoffrey Mon
> [py] Support multiple jobs per Python plan file
> --
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931633#comment-15931633
]
ASF GitHub Bot commented on FLINK-5183:
---
Github user zentol commented on the issue:
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 fe
[
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 schema
[
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
> int
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 consideratio
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931614#comment-15931614
]
ASF GitHub Bot commented on FLINK-6117:
---
GitHub user gaqzcb opened a pull request:
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
[
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
>
77 matches
Mail list logo
