[
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=15932181#comment-15932181
]
sunjincheng commented on FLINK-6074:
Hi, [~aljoscha] Agree with you. I'll close this JIRA.
> Fix
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://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 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 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.
[
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
[
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
[
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
[
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
[
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=15932092#comment-15932092
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user vijikarthi commented on a diff in the pull
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
[
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
[
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
[
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
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
[
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=15932078#comment-15932078
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on the issue:
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
[
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
[
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
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
[
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
[
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
[
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
[
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:
[
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:
[
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:
[
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:
[
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 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
checkpointStateHandle =
[
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
[
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
[
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:
[
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 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
[
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
[
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
[
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
[
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=15931924#comment-15931924
]
Aljoscha Krettek commented on FLINK-6074:
-
I opened FLINK-6118 which tracks in a more general way
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
[
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
[
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 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 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=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
[
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 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
[
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
[
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 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
[
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:
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
>
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
[
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
[
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
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
[
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
[
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.
>
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
71 matches
Mail list logo