[
https://issues.apache.org/jira/browse/FLINK-8338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322168#comment-16322168
]
ASF GitHub Bot commented on FLINK-8338:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5224
Thanks for your review @GJL. I've addressed your comments and rebased onto
the latest master.
---
[
https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322191#comment-16322191
]
Stefan Richter commented on FLINK-8413:
---
Can you share a (minimal) code example that shows this
flora karniav created FLINK-8414:
Summary: Gelly performance seriously decreases when using the
suggested parallelism configuration
Key: FLINK-8414
URL: https://issues.apache.org/jira/browse/FLINK-8414
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5276
closed via 71ede3992afe8f6907dd3c6c1e232c5b745048b4
---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5275
closed via a316989e5dfbb1dc0d555193425a4d6bd5f42d8d
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5225#discussion_r160970084
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java ---
@@ -51,45 +45,23 @@ public String getId() {
}
Github user NicoK closed the pull request at:
https://github.com/apache/flink/pull/5276
---
[
https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322269#comment-16322269
]
ASF GitHub Bot commented on FLINK-8339:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322270#comment-16322270
]
ASF GitHub Bot commented on FLINK-8371:
---
Github user NicoK commented on the issue:
Github user NicoK closed the pull request at:
https://github.com/apache/flink/pull/5275
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5225#discussion_r160970851
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ---
@@ -561,7 +640,7 @@ protected int cancel(String[] args) throws
[
https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suganya updated FLINK-8413:
---
Summary: Snapshot state of aggregated data is not maintained in flink's
checkpointing (was: Snapshote state
[
https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suganya updated FLINK-8413:
---
Summary: Snapshote state of aggregated data is not maintained in flink's
checkpointing (was: Checkpointing
[
https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5704:
Fix Version/s: 1.5.0
> Deprecate FlinkKafkaConsumer constructors in favor of improvements
[
https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5728:
Fix Version/s: 1.5.0
> FlinkKafkaProducer should flush on checkpoint by default
>
GitHub user elbaulp opened a pull request:
https://github.com/apache/flink/pull/5283
Fixed doc typo in DataStream API
Miss-spelled multiple as muplitple
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/elbaulp/flink fix-doc-typo
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/commit/a03cdfabe6eab48509b42a6831a21e488b9c3e80#commitcomment-26789565
In .travis.yml:
In .travis.yml on line 93:
You're right. I'll correct it.
---
[
https://issues.apache.org/jira/browse/FLINK-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322189#comment-16322189
]
ASF GitHub Bot commented on FLINK-8296:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
flora karniav updated FLINK-8414:
-
Description:
I am running Gelly examples with different datasets in a cluster of 5 machines
(1
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160967520
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java
---
@@ -132,32 +141,49 @@ public
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160956609
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StateInitializationContextImplTest.java
---
@@ -124,14 +140,69 @@
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160923874
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java
---
@@ -0,0 +1,123 @@
+/*
+ *
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160962776
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamTaskStateManagerImplTest.java
---
@@ -0,0 +1,323 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322291#comment-16322291
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160929798
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateManager.java
---
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160959867
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamOperatorSnapshotRestoreTest.java
---
@@ -98,7 +101,26 @@
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322301#comment-16322301
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322303#comment-16322303
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322300#comment-16322300
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160723465
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateManagerImpl.java
---
@@ -0,0 +1,640 @@
+/*
+
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160912998
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -380,6 +390,20 @@ public void postStop() throws
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160970483
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/StateBackendITCase.java
---
@@ -85,8 +84,24 @@ public String
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160913576
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateManagerImpl.java
---
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160957609
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StateInitializationContextImplTest.java
---
@@ -124,14 +140,69 @@
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322296#comment-16322296
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160717297
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateContext.java
---
@@ -0,0 +1,73 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322306#comment-16322306
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160909861
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateUtil.java ---
@@ -71,4 +72,22 @@ public static void
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322302#comment-16322302
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322293#comment-16322293
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322288#comment-16322288
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322299#comment-16322299
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160724253
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateManagerImpl.java
---
@@ -0,0 +1,640 @@
+/*
+
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160943448
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -316,7 +292,38 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322305#comment-16322305
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160941763
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java
---
@@ -210,10 +211,11 @@ public void
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160962445
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamTaskStateManagerImplTest.java
---
@@ -0,0 +1,323 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322292#comment-16322292
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160725404
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -214,49 +217,55 @@ public
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160940119
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DummyEnvironment.java
---
@@ -53,10 +54,15 @@
private final
[
https://issues.apache.org/jira/browse/FLINK-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8406:
Fix Version/s: 1.4.1
1.5.0
> BucketingSink does not detect hadoop file
[
https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8371:
Fix Version/s: 1.5.0
> Buffers are not recycled in a non-spilled SpillableSubpartition upon
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5224#discussion_r160946952
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/util/MockedCliFrontend.java
---
@@ -20,40 +20,22 @@
import
[
https://issues.apache.org/jira/browse/FLINK-8338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322158#comment-16322158
]
ASF GitHub Bot commented on FLINK-8338:
---
Github user tillrohrmann commented on a diff in the pull
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5188
Thank you for the review @pnowojski! Have addressed your comments.
---
[
https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322191#comment-16322191
]
Stefan Richter edited comment on FLINK-8413 at 1/11/18 1:25 PM:
Can you
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5283
Thanks, good catch!
@elbaulp can you include the `[hotfix]` and `[doc]` tags to the commit
message? All our commit requires proper tags to indicate the issue id (or
`hotfix` for typos),
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319953#comment-16319953
]
Nico Kruber edited comment on FLINK-7499 at 1/11/18 2:13 PM:
-
Merged.
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-8371.
--
Resolution: Fixed
Fix Version/s: 1.4.1
Merged.
1.5.0: 4c3f6075bcad0e85db947d7db7817a678d21a85e
[
https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322271#comment-16322271
]
ASF GitHub Bot commented on FLINK-8371:
---
Github user NicoK closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322268#comment-16322268
]
ASF GitHub Bot commented on FLINK-7499:
---
Github user NicoK closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322267#comment-16322267
]
ASF GitHub Bot commented on FLINK-7499:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322126#comment-16322126
]
ASF GitHub Bot commented on FLINK-8233:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322173#comment-16322173
]
ASF GitHub Bot commented on FLINK-8233:
---
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/5194#discussion_r160950656
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/JobExecutionResultHandlerTest.java
---
@@ -0,0 +1,160 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319953#comment-16319953
]
Nico Kruber edited comment on FLINK-7499 at 1/11/18 2:13 PM:
-
Merged.
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-7499.
--
Resolution: Fixed
Fix Version/s: 1.4.1
> double buffer release in SpillableSubpartitionView
>
[
https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322275#comment-16322275
]
ASF GitHub Bot commented on FLINK-8339:
---
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/5225#discussion_r160970724
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java ---
@@ -51,45 +45,23 @@ public String getId() {
}
[
https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322274#comment-16322274
]
ASF GitHub Bot commented on FLINK-8339:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322297#comment-16322297
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322285#comment-16322285
]
ASF GitHub Bot commented on FLINK-8339:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322287#comment-16322287
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322295#comment-16322295
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160948522
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskStateManager.java
---
@@ -0,0 +1,185 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322304#comment-16322304
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322290#comment-16322290
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322298#comment-16322298
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160942938
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -316,7 +292,38 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322294#comment-16322294
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322289#comment-16322289
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user pnowojski commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5225#discussion_r160972443
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ---
@@ -561,7 +640,7 @@ protected int cancel(String[] args) throws
[
https://issues.apache.org/jira/browse/FLINK-8400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321948#comment-16321948
]
ASF GitHub Bot commented on FLINK-8400:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5273
---
[
https://issues.apache.org/jira/browse/FLINK-8400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8400.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
Timo Walther created FLINK-8412:
---
Summary: Show outdated warning for 1.3 docs
Key: FLINK-8412
URL: https://issues.apache.org/jira/browse/FLINK-8412
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8404.
Resolution: Fixed
Fixed via 8353123b39ea49cc5b3bd9d324972bf6ae02f2a6
> Mark Flip-6 tests with
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8234.
Resolution: Fixed
Fixed via 08e550c98674738ab883ea84c0350093c9765ab6
> Cache JobExecutionResult
[
https://issues.apache.org/jira/browse/FLINK-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7949.
--
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322066#comment-16322066
]
ASF GitHub Bot commented on FLINK-7949:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322065#comment-16322065
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322067#comment-16322067
]
ASF GitHub Bot commented on FLINK-8404:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5184
---
[
https://issues.apache.org/jira/browse/FLINK-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8412.
-
Resolution: Fixed
Fixed in 0c1cdb2cc3e5becab9344c2b9b30cad14b62331a
> Show outdated warning for
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322108#comment-16322108
]
ASF GitHub Bot commented on FLINK-6352:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5282
[FLINK-6352] [kafka] Timestamp-based offset configuration for
FlinkKafkaConsumer
## What is the purpose of the change
This PR is based on @zjureel's initial efforts on the feature in
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5282
cc @zjureel
---
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322119#comment-16322119
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3915
Hi @zjureel, I went ahead to address my own review / concerns with the
change in another PR that is based on your current work: #5282. I hope that is
okay, and would be great if you would like to
1 - 100 of 246 matches
Mail list logo
