[
https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007743#comment-16007743
]
Michał Jurkiewicz commented on FLINK-5753:
--
[~kkl0u],
My job is operating is eve
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6563:
-
Fix Version/s: 1.3.0
> Expose time indicator attributes in the KafkaTableSource
>
[
https://issues.apache.org/jira/browse/FLINK-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6543:
-
Issue Type: Task (was: Improvement)
> Deprecate toDataStream
> --
>
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3873#discussion_r116169564
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -163,26 +165,31 @@ public static ConjunctFuture combi
[
https://issues.apache.org/jira/browse/FLINK-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6517:
-
Priority: Critical (was: Major)
> Support multiple consecutive windows
>
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6542:
-
Fix Version/s: 1.3.0
> Non-keyed, non-windowed aggregation fails
> ---
[
https://issues.apache.org/jira/browse/FLINK-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6517:
-
Fix Version/s: 1.3.0
> Support multiple consecutive windows
>
[
https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007756#comment-16007756
]
ASF GitHub Bot commented on FLINK-6555:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6543:
-
Fix Version/s: 1.3.0
> Deprecate toDataStream
> --
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6542:
-
Priority: Critical (was: Major)
> Non-keyed, non-windowed aggregation fails
> ---
[
https://issues.apache.org/jira/browse/FLINK-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6462:
-
Fix Version/s: 1.3.0
> Add requiresOver interface for AggregateFunction
> ---
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3870#discussion_r116172093
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
---
@@ -18,91 +18,137 @@
package org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007773#comment-16007773
]
ASF GitHub Bot commented on FLINK-6534:
---
Github user shixiaogang commented on a diff
Tzu-Li (Gordon) Tai created FLINK-6565:
--
Summary: Improve error messages for state restore failures
Key: FLINK-6565
URL: https://issues.apache.org/jira/browse/FLINK-6565
Project: Flink
I
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3859
I noticed that FLINK-6504 is also fixed in
https://github.com/apache/flink/pull/3870 , close this pr and let us address
all problems of incremental checkpointing there.
---
If your project is s
Github user shixiaogang closed the pull request at:
https://github.com/apache/flink/pull/3859
---
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-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007781#comment-16007781
]
ASF GitHub Bot commented on FLINK-6504:
---
Github user shixiaogang commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007782#comment-16007782
]
ASF GitHub Bot commented on FLINK-6504:
---
Github user shixiaogang closed the pull req
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3870#discussion_r116174101
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java
---
Tzu-Li (Gordon) Tai created FLINK-6566:
--
Summary: Narrow down interface for compatibility hook method in
VersionedIOReadableWritable
Key: FLINK-6566
URL: https://issues.apache.org/jira/browse/FLINK-6566
[
https://issues.apache.org/jira/browse/FLINK-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6566:
---
Affects Version/s: 1.3.0
> Narrow down interface for compatibility hook method in
> V
[
https://issues.apache.org/jira/browse/FLINK-6545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007785#comment-16007785
]
Xiaogang Shi commented on FLINK-6545:
-
I prefer not to use `SavepointSerializer` to se
GitHub user ramkrish86 opened a pull request:
https://github.com/apache/flink/pull/3881
FLINK-6284 Incorrect sorting of completed checkpoints in
ZooKeeperCompletedCheckpointStore
ZooKeeperCompletedCheckpointStore
Thanks for contributing to Apache Flink. Before you open your
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3870#discussion_r116175297
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java
---
[
https://issues.apache.org/jira/browse/FLINK-6545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007786#comment-16007786
]
ASF GitHub Bot commented on FLINK-6545:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007787#comment-16007787
]
ASF GitHub Bot commented on FLINK-6284:
---
GitHub user ramkrish86 opened a pull reques
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3873
You're right with the thread safety. I will change it. I will introduce a
`WaitingFuture` which will simply wait on the completion of all its futures and
discard all future values, thus, returni
[
https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007789#comment-16007789
]
ASF GitHub Bot commented on FLINK-6555:
---
Github user tillrohrmann commented on the i
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3870#discussion_r116179467
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
---
@@ -18,91 +18,137 @@
package org.apache.
[
https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007798#comment-16007798
]
ASF GitHub Bot commented on FLINK-6534:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007811#comment-16007811
]
Fabian Hueske commented on FLINK-6542:
--
Thanks for looking into this [~xccui]!
I thin
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-6542.
--
Resolution: Not A Problem
> Non-keyed, non-windowed aggregation fails
>
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6552:
Component/s: (was: Streaming)
DataStream API
> Ambiguous error message
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3873
Updated the PR to incorporate the PR review. Thanks for the review
@StephanEwen.
---
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-6550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6550:
Component/s: (was: Streaming)
DataStream API
> Calling ctx.collect with
[
https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007830#comment-16007830
]
ASF GitHub Bot commented on FLINK-6555:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6551:
Component/s: (was: Streaming)
DataStream API
> OutputTag name should no
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007833#comment-16007833
]
Aljoscha Krettek commented on FLINK-6549:
-
I think there might be a typo in the de
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007838#comment-16007838
]
Aljoscha Krettek commented on FLINK-6552:
-
Absolutely right, the message should be
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116185935
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -346,11 +346,7 @@ public int exists(Stri
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007843#comment-16007843
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-6554:
--
Assignee: Tzu-Li (Gordon) Tai
> CompatibilityResult should contain a notCompati
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116188234
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -346,11 +346,7 @@ public int exists(String
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007862#comment-16007862
]
Tzu-Li (Gordon) Tai commented on FLINK-6554:
Discussed this with [~Zentol] off
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007862#comment-16007862
]
Tzu-Li (Gordon) Tai edited comment on FLINK-6554 at 5/12/17 9:31 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007863#comment-16007863
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007870#comment-16007870
]
Robert Metzger edited comment on FLINK-6564 at 5/12/17 9:38 AM:
[
https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007870#comment-16007870
]
Robert Metzger commented on FLINK-6564:
---
I wonder if we could just rename the {{LICE
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007882#comment-16007882
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3876#discussion_r116190819
--- Diff: flink-dist/pom.xml ---
@@ -403,15 +403,6 @@ under the License.
-
[
https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-6544:
Assignee: Kaibo Zhou
> Expose Backend State Interface for UDAGG
> -
[
https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang updated FLINK-6544:
-
Summary: Expose State Backend Interface for UDAGG (was: Expose Backend
State Interface for UDAGG)
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007895#comment-16007895
]
Timo Walther commented on FLINK-6542:
-
Sorry for the confusion [~xccui] [~fhueske]. It
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3876
The change looks good for me.
I'll verify it with my Cloudera VM to make sure it works with provided
hadoop versions as well.
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007905#comment-16007905
]
Andrey commented on FLINK-6541:
---
Hi!
Sure, I would love to provide pull request. However du
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007906#comment-16007906
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6549:
Description:
A type mismatch when using side outputs causes a ClassCastException to be
thro
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007946#comment-16007946
]
Chesnay Schepler commented on FLINK-6549:
-
yes there's a type, different types but
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007946#comment-16007946
]
Chesnay Schepler edited comment on FLINK-6549 at 5/12/17 10:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007957#comment-16007957
]
Chesnay Schepler commented on FLINK-6552:
-
Here's a minimal self-contained example
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3882
[FLINK-6565] Fail memory-backed state restores with meaningful message if
previous serializer is unavailable
Currently, without eager state registration, if on restore of memory-backed
states (`De
[
https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007979#comment-16007979
]
ASF GitHub Bot commented on FLINK-6565:
---
GitHub user tzulitai opened a pull request:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3879
Thanks for the PR @haohui. Looks good to me.
I'll replace the test and extend `CompositeAccessTest` before merging.
---
If your project is set up for it, you can reply to this email and have you
[
https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007981#comment-16007981
]
ASF GitHub Bot commented on FLINK-6562:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007986#comment-16007986
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3876
This PR works in my VM. There's just some weird behavior when starting
Flink on YARN.
I'll cross check with AWS EMR to see if its a YARN or a VM/Cloudera issue.
I wanted to check on EMR
[
https://issues.apache.org/jira/browse/FLINK-1750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1750:
Assignee: Alex De Castro
> Add canonical correlation analysis (CCA) to machine learning lib
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007997#comment-16007997
]
Fabian Hueske commented on FLINK-6563:
--
Actually, the missing {{DefinedProctimeAttrib
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116208844
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -346,17 +346,20 @@ public int exists(Str
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116207779
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -346,17 +346,20 @@ public int exists(Str
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116207072
--- Diff: pom.xml ---
@@ -101,7 +101,8 @@ under the License.
0.7.4
5.0.4
3.4.6
- 2.12.0
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007998#comment-16007998
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008000#comment-16008000
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007999#comment-16007999
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a dif
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116211032
--- Diff: pom.xml ---
@@ -101,7 +101,8 @@ under the License.
0.7.4
5.0.4
3.4.6
- 2.12.0
+
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116211132
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -346,17 +346,20 @@ public int exists(Strin
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008014#comment-16008014
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008013#comment-16008013
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3881#discussion_r116211254
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
---
@@ -346,17 +346,20 @@ public int exists(Strin
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008015#comment-16008015
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff
Github user DmytroShkvyra commented on the issue:
https://github.com/apache/flink/pull/3673
Hi @fhueske I have fixed all your notes and build almost green. :(
I have got only yarn test fail:
```
Failed tests:
YARNSessionFIFOITCase.testJavaAPI:249 Error while deploying
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008018#comment-16008018
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user DmytroShkvyra commented on the
[
https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-6564:
Assignee: Fabian Hueske
> Build fails on file systems that do not distinguish between upper
[
https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008027#comment-16008027
]
Fabian Hueske commented on FLINK-6564:
--
Will rename the `license` folder to `licenses
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3883
[FLINK-6566] [core] More restricted interface for
VersionedIOReadableWritable hooks
This PR makes the method hooks for defining compatible
serialization versions of `VersionedIOReadableWritable
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3673
Thanks for the update @DmytroShkvyra!
---
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
enable
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008031#comment-16008031
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008030#comment-16008030
]
ASF GitHub Bot commented on FLINK-6566:
---
GitHub user tzulitai opened a pull request:
Github user DmytroShkvyra commented on the issue:
https://github.com/apache/flink/pull/3673
Thanks a lot Fabian!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wish
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008035#comment-16008035
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user DmytroShkvyra commented on the
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008043#comment-16008043
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3881
Hi @ramkrish86, I might have found an easy way to solve the problem. Take a
look at
https://github.com/tillrohrmann/flink/commit/5bd499329d68c6f3236b4e89ba25fdb9acb7e422.
If this solves the pro
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3884
[FLINK-6284] Correct sorting of completed checkpoints in
ZooKeeperStateHandleStore
In order to store completed checkpoints in an increasing order in ZooKeeper,
the paths for the completed c
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008047#comment-16008047
]
ASF GitHub Bot commented on FLINK-6284:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-6552:
---
Assignee: Aljoscha Krettek
> Ambiguous error message when retrieving multiple side-ou
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6552:
Summary: Side outputs don't allow differing output types (was: Ambiguous
error message when
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008051#comment-16008051
]
Aljoscha Krettek commented on FLINK-6552:
-
Congratulations, you found a bug! 😅
I
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3885
[FLINK-6552] Allow differing types for side outputs
R: @zentol
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink jira-6552-fix-sid
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008056#comment-16008056
]
ASF GitHub Bot commented on FLINK-6552:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6552:
Priority: Blocker (was: Major)
> Side outputs don't allow differing output types
>
1 - 100 of 252 matches
Mail list logo
