Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2650
Hi
Is last changes correct?
---
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-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650103#comment-15650103
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user ex00 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650089#comment-15650089
]
Anton Mushin commented on FLINK-4832:
-
Hello [~fhueske]
bq. We need to inject a Union before the Map
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2776
[docs] Fix typos in Table API documentation
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650023#comment-15650023
]
Jark Wu edited comment on FLINK-3848 at 11/9/16 7:07 AM:
-
Hi [~tonycox] , I have
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650023#comment-15650023
]
Jark Wu commented on FLINK-3848:
Hi [~tonycox] , I have looked into your work and think you may have
GitHub user BorisOsipov opened a pull request:
https://github.com/apache/flink/pull/2775
[hotfix] Fix wrong arguments order in assert
Fix wrong arguments order in assert
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user BorisOsipov opened a pull request:
https://github.com/apache/flink/pull/2774
[hotfix] PartitionerITCase replace comparing Integers by != to equals
Replace comparing Integers by != to equals
You can merge this pull request into a Git repository by running:
$ git
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649700#comment-15649700
]
Jark Wu commented on FLINK-4565:
Hi [~nvasilishin] ,
1. Yes, the HashSet should be reused. You can put
Xiaogang Shi created FLINK-5036:
---
Summary: Perform the grouping of keys in restoring instead of
checkpointing
Key: FLINK-5036
URL: https://issues.apache.org/jira/browse/FLINK-5036
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi edited comment on FLINK-5023 at 11/9/16 2:52 AM:
--
[~aljoscha] In
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi edited comment on FLINK-5023 at 11/9/16 2:46 AM:
--
@Aljoscha
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi edited comment on FLINK-5023 at 11/9/16 2:45 AM:
--
@Aljoscha
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi commented on FLINK-5023:
-
Aljoscha Krettek In that case, i think we should provide
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649511#comment-15649511
]
Tzu-Li (Gordon) Tai commented on FLINK-5017:
Ah, I see. I actually didn't realize it is
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649389#comment-15649389
]
ASF GitHub Bot commented on FLINK-4946:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2708
@greghogan It would be helpful to look at the Yarn container files which
include the container environment variables. This would help us to figure out
why the recursive `**` is not working. Another
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4975.
---
> Add a limit for how much data may be buffered during checkpoint alignment
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87100173
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87094727
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87099565
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87096436
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -337,37 +337,43 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4975.
-
Resolution: Fixed
Implemented in
- 1.2.0 via 07ab9f45341f8c49354d9357d9459ee2199b4e1d
- 1.1.4
[
https://issues.apache.org/jira/browse/FLINK-4985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4985.
---
> Report Declined/Canceled Checkpoints to Checkpoint Coordinator
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87098882
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649139#comment-15649139
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649137#comment-15649137
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87101256
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649136#comment-15649136
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649144#comment-15649144
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87102206
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649140#comment-15649140
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649138#comment-15649138
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649142#comment-15649142
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4976.
-
Resolution: Implemented
Done via resolution of the subtasks
> Add a way to abort in flight
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r87094884
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4984.
---
> Add Cancellation Barriers to BarrierTracker and BarrierBuffer
>
[
https://issues.apache.org/jira/browse/FLINK-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4984.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 0a79dd5fb165c714bdac8de770b45d9406177401
- 1.1.4 via
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648786#comment-15648786
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2467
Hi @iampeter
I've updated the PR according to your comments. Could you please review it
again?
Best regards,
Ivan.
---
If your project is set up for it, you can reply to this
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2708
@uce @mxm after adding the recursive wildcard the nested jar files are
copied to the application directory within HDFS. This is my first time testing
Flink on YARN and I am getting a
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648749#comment-15648749
]
ASF GitHub Bot commented on FLINK-4946:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15506583#comment-15506583
]
Ted Yu edited comment on FLINK-4534 at 11/8/16 8:47 PM:
Feel free to work on this.
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2754
Thanks for the thorough review!
Addressed the feedback, rebased, and will merge as soon as Travis gives a
green light...
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648707#comment-15648707
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user StephanEwen commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2773
---
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-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648702#comment-15648702
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648283#comment-15648283
]
ASF GitHub Bot commented on FLINK-4975:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2773
[backport] [FLINK-4975] [checkpointing] Add a limit for how much data may
be buffered in alignment
## This is a backport of #2754 to the 1.1.x branch.
## This already incorporates the
[
https://issues.apache.org/jira/browse/FLINK-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648247#comment-15648247
]
ASF GitHub Bot commented on FLINK-4963:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2725
Hey @greghogan, I didn't have time to review this one, you're a fast merger
:)
It looks like none of `VertexMertics`, `EdgeMetrics`,
`AverageClusteringCoefficient` are mentioned in the gelly docs.
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2754
Btw: Going through the `BarrierBuffer` and the way events are handled was
really instructive :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648234#comment-15648234
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87043464
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
---
@@ -135,19 +138,20 @@ else if
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648226#comment-15648226
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648219#comment-15648219
]
ASF GitHub Bot commented on FLINK-4975:
---
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/2754#discussion_r87043110
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -899,26 +926,480 @@ public void
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2754
Really good changes @StephanEwen. With the safeguard against spilling too
much data while aligning the checkpoint barriers Flink will be more robust and
deliver a better user experience in
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648215#comment-15648215
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648195#comment-15648195
]
Stephan Ewen commented on FLINK-3389:
-
I think it is very important to point out in the docs that
[
https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648183#comment-15648183
]
Aljoscha Krettek commented on FLINK-3389:
-
>From a quick look at the code it seems you documented
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648170#comment-15648170
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87039138
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -899,26 +926,480 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87039301
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/decline/AlignmentLimitExceededException.java
---
@@ -0,0 +1,33 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648167#comment-15648167
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648140#comment-15648140
]
Nikolay Vasilishin edited comment on FLINK-4565 at 11/8/16 5:11 PM:
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648140#comment-15648140
]
Nikolay Vasilishin commented on FLINK-4565:
---
Hi, guys, I faced some problems.
Now I have IN
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648131#comment-15648131
]
Aljoscha Krettek commented on FLINK-5024:
-
[~StephanEwen] I think this should be ok with regards
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648127#comment-15648127
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648129#comment-15648129
]
ASF GitHub Bot commented on FLINK-4975:
---
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/2754#discussion_r87035779
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/decline/InputEndOfStreamException.java
---
@@ -0,0 +1,32 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87035938
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/StatefulTask.java
---
@@ -69,7 +69,7 @@
*
* @param
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648123#comment-15648123
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648122#comment-15648122
]
Aljoscha Krettek commented on FLINK-5023:
-
[~StephanEwen] [~xiaogang.shi] In fact, I would prefer
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87035590
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/decline/CheckpointDeclineOnCancellationBarrierException.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648108#comment-15648108
]
ASF GitHub Bot commented on FLINK-4975:
---
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/2754#discussion_r87034115
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -525,81 +527,63 @@ else if
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648090#comment-15648090
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87033063
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -899,26 +926,480 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87030844
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -899,26 +926,480 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648061#comment-15648061
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648041#comment-15648041
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87028376
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
---
@@ -254,8 +357,20 @@ public void cleanup()
[
https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648038#comment-15648038
]
Stephan Ewen commented on FLINK-3389:
-
It is implemented. Is it documented?
> Add Pre-defined Options
[
https://issues.apache.org/jira/browse/FLINK-5034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5034:
Priority: Blocker (was: Major)
> Don't Write StateDescriptor to RocksDB Snapshot
>
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648012#comment-15648012
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on the issue:
Aljoscha Krettek created FLINK-5035:
---
Summary: Don't Write TypeSerializer to Heap State Snapshot
Key: FLINK-5035
URL: https://issues.apache.org/jira/browse/FLINK-5035
Project: Flink
Issue
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2542
Thank you @jfeher!
Could you clarify what you mean by filtering the data to get unique
item-user pairs? Is this because the iALS algorithm only supports binary
interactions (i.e. number of
Aljoscha Krettek created FLINK-5034:
---
Summary: Don't Write StateDescriptor to RocksDB Snapshot
Key: FLINK-5034
URL: https://issues.apache.org/jira/browse/FLINK-5034
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648000#comment-15648000
]
Aljoscha Krettek commented on FLINK-3389:
-
[~StephanEwen] isn't this implemented by now? If yes,
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15647991#comment-15647991
]
Aljoscha Krettek commented on FLINK-5016:
-
Sweet, so we don't have problems in the test after all.
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15647949#comment-15647949
]
ASF GitHub Bot commented on FLINK-4975:
---
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/2754#discussion_r87019713
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
---
@@ -254,8 +357,20 @@ public void cleanup()
[
https://issues.apache.org/jira/browse/FLINK-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4963.
-
Resolution: Implemented
Implemented in f025c455f2a2e4bc5bd5bb39b47c3dc1d1e3b117
> Tabulate edge
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2725
---
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-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15647934#comment-15647934
]
ASF GitHub Bot commented on FLINK-4963:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15647929#comment-15647929
]
ASF GitHub Bot commented on FLINK-5012:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2772
[FLINK-5012] Expose Timestamp in Timely FlatMap Functions
This also adds a Context parameter that holds the timestamp, time domain
and TimerService to declutter the parameter list of the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2754#discussion_r87017313
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -525,81 +527,63 @@ else if
[
https://issues.apache.org/jira/browse/FLINK-4975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15647917#comment-15647917
]
ASF GitHub Bot commented on FLINK-4975:
---
Github user StephanEwen commented on a diff in the pull
1 - 100 of 150 matches
Mail list logo
