GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3890
[FLINK-6569] flink-table KafkaJsonTableSource example doesn't work.
This PR makes the proposed changes on the document and changes the Java
unit tests to reflect the suggested usages of the API.
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008889#comment-16008889
]
ASF GitHub Bot commented on FLINK-6569:
---
GitHub user haohui opened a pull request:
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/3810
Nice work!
I have rebased master.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16009102#comment-16009102
]
ASF GitHub Bot commented on FLINK-6397:
---
Github user ifndef-SleePy commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008853#comment-16008853
]
Greg Hogan commented on FLINK-6573:
---
[~naagachowdary] glad to hear of your success and thank you for
Github user willmiao closed the pull request at:
https://github.com/apache/flink/pull/1121
---
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-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16009133#comment-16009133
]
ASF GitHub Bot commented on FLINK-2591:
---
Github user willmiao closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008891#comment-16008891
]
Haohui Mai commented on FLINK-6529:
---
Will do. Thanks!
> Rework the shading model in Flink
>
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008821#comment-16008821
]
Haohui Mai commented on FLINK-6568:
---
Hit the same issue multiple times when testing out 1.3. Are we good
Haohui Mai created FLINK-6574:
-
Summary: External catalog should support a single level catalog
Key: FLINK-6574
URL: https://issues.apache.org/jira/browse/FLINK-6574
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6569:
-
Assignee: Haohui Mai
> flink-table KafkaJsonTableSource example doesn't work
>
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6568:
-
Assignee: Haohui Mai
> flink-table doesn't work without flink-streaming-scala dependency
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3862
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3863
---
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-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
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
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
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,
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-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 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
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
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007862#comment-16007862
]
Tzu-Li (Gordon) Tai commented on FLINK-6554:
Discussed this with [~Zentol] offline.
An
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16007863#comment-16007863
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff in the pull
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
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
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-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007986#comment-16007986
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user rmetzger commented on the issue:
[
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
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008015#comment-16008015
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008013#comment-16008013
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008051#comment-16008051
]
Aljoscha Krettek commented on FLINK-6552:
-
Congratulations, you found a bug!
I have a PR coming
[
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
[
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
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-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008018#comment-16008018
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user DmytroShkvyra commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007895#comment-16007895
]
Timo Walther commented on FLINK-6542:
-
Sorry for the confusion [~xccui] [~fhueske]. It seems that I
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007946#comment-16007946
]
Chesnay Schepler edited comment on FLINK-6549 at 5/12/17 10:54 AM:
---
yes
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
[
https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007981#comment-16007981
]
ASF GitHub Bot commented on FLINK-6562:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007997#comment-16007997
]
Fabian Hueske commented on FLINK-6563:
--
Actually, the missing {{DefinedProctimeAttribute}} and
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008014#comment-16008014
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user ramkrish86 commented on a diff in the pull
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008035#comment-16008035
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user DmytroShkvyra commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008047#comment-16008047
]
ASF GitHub Bot commented on FLINK-6284:
---
GitHub user tillrohrmann opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007882#comment-16007882
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user rmetzger commented on a diff in the pull
[
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-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007905#comment-16007905
]
Andrey commented on FLINK-6541:
---
Hi!
Sure, I would love to provide pull request. However due to the legal
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007906#comment-16007906
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007957#comment-16007957
]
Chesnay Schepler commented on FLINK-6552:
-
Here's a minimal self-contained example that causes the
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007999#comment-16007999
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007998#comment-16007998
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008000#comment-16008000
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on a diff in the pull
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16008030#comment-16008030
]
ASF GitHub Bot commented on FLINK-6566:
---
GitHub user tzulitai opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008056#comment-16008056
]
ASF GitHub Bot commented on FLINK-6552:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007979#comment-16007979
]
ASF GitHub Bot commented on FLINK-6565:
---
GitHub user tzulitai opened a pull request:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007946#comment-16007946
]
Chesnay Schepler commented on FLINK-6549:
-
yes there's a type, different types but the same name.
[
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
[
https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008027#comment-16008027
]
Fabian Hueske commented on FLINK-6564:
--
Will rename the `license` folder to `licenses` and fix this.
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
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008043#comment-16008043
]
ASF GitHub Bot commented on FLINK-6284:
---
Github user tillrohrmann commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3877
The only diff from #3876 is the dropping of the jersey/jettison/servlet
deps, right?
---
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-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007672#comment-16007672
]
ASF GitHub Bot commented on FLINK-6514:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3876#discussion_r116157739
--- Diff: flink-shaded-hadoop/flink-shaded-hadoop2-uber/pom.xml ---
@@ -0,0 +1,129 @@
+
+
+
+http://maven.apache.org/POM/4.0.0;
[
https://issues.apache.org/jira/browse/FLINK-6491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007686#comment-16007686
]
ASF GitHub Bot commented on FLINK-6491:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007687#comment-16007687
]
ASF GitHub Bot commented on FLINK-6483:
---
Github user asfgit closed the pull request at:
[
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-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007756#comment-16007756
]
ASF GitHub Bot commented on FLINK-6555:
---
Github user tillrohrmann commented on a diff in the pull
[
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:
[
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-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6543:
-
Issue Type: Task (was: Improvement)
> Deprecate toDataStream
> --
>
>
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007773#comment-16007773
]
ASF GitHub Bot commented on FLINK-6534:
---
Github user shixiaogang commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007785#comment-16007785
]
Xiaogang Shi commented on FLINK-6545:
-
I prefer not to use `SavepointSerializer` to
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
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-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007833#comment-16007833
]
Aljoscha Krettek commented on FLINK-6549:
-
I think there might be a typo in the description.
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3870#discussion_r116161230
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java
---
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3870#discussion_r116161117
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalKeyedStateHandle.java
---
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007811#comment-16007811
]
Fabian Hueske commented on FLINK-6542:
--
Thanks for looking into this [~xccui]!
I think you are right.
[
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-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007787#comment-16007787
]
ASF GitHub Bot commented on FLINK-6284:
---
GitHub user ramkrish86 opened a pull request:
1 - 100 of 266 matches
Mail list logo
