[
https://issues.apache.org/jira/browse/FLINK-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8318:
Fix Version/s: 1.4.1
1.5.0
> Conflict jackson library with ElasticSearch
[
https://issues.apache.org/jira/browse/FLINK-8363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313309#comment-16313309
]
Aljoscha Krettek commented on FLINK-8363:
-
Probably everything except the filesystem connector and
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313308#comment-16313308
]
ASF GitHub Bot commented on FLINK-8346:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5231
Very nice, thanks!
Merging this...
---
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313298#comment-16313298
]
Aljoscha Krettek commented on FLINK-8364:
-
+1 to what [~fhueske] said!
> ListState should return
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5205#discussion_r159899525
--- Diff: flink-core/src/main/java/org/apache/flink/util/AbstractID.java ---
@@ -186,7 +186,7 @@ private static long byteArrayToLong(byte[] ba, int
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313297#comment-16313297
]
ASF GitHub Bot commented on FLINK-8037:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313293#comment-16313293
]
Aljoscha Krettek commented on FLINK-6214:
-
Nope, no reason except no-one has gotten around to it
[
https://issues.apache.org/jira/browse/FLINK-8361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313291#comment-16313291
]
Aljoscha Krettek commented on FLINK-8361:
-
Ah yes, definitely remove. I left it in when I added
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5204
The code looks good, thanks! Merging this...
For the next contributions, it would be great if you could give the Pull
Request a proper description, as the text of the pull request
[
https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313257#comment-16313257
]
ASF GitHub Bot commented on FLINK-8260:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5191
This looks like an accidentally opened pull request. Can you please close
it?
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5179
These look like good changes. +1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313206#comment-16313206
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313212#comment-16313212
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313211#comment-16313211
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313210#comment-16313210
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313213#comment-16313213
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313208#comment-16313208
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313209#comment-16313209
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313207#comment-16313207
]
ASF GitHub Bot commented on FLINK-8203:
---
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/5132#discussion_r159887168
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -450,37 +450,54 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159878618
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/StreamTableEnvironmentValidationTest.scala
---
@@ -138,4 +145,25 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159885776
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -450,37 +450,54 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159876208
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -446,52 +443,60 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159889511
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -450,37 +450,54 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159878296
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
---
@@ -532,35 +527,27 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159880719
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -492,11 +509,16 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159877092
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -855,42 +852,26 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-8340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313168#comment-16313168
]
ASF GitHub Bot commented on FLINK-8340:
---
Github user GJL commented on a diff in the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4594
---
[
https://issues.apache.org/jira/browse/FLINK-7517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313192#comment-16313192
]
ASF GitHub Bot commented on FLINK-7517:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313191#comment-16313191
]
ASF GitHub Bot commented on FLINK-7499:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313190#comment-16313190
]
ASF GitHub Bot commented on FLINK-7427:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4528
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4581
---
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5226#discussion_r159874411
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -183,93 +204,43 @@ public FlinkYarnSessionCli(String shortPrefix,
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5226#discussion_r159883795
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendPackageProgramTest.java
---
@@ -60,220 +59,178 @@ public static void init() {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5225#discussion_r159885568
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/AbstractCustomCommandLine.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313170#comment-16313170
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313183#comment-16313183
]
ASF GitHub Bot commented on FLINK-8339:
---
Github user GJL commented on a diff in the pull request:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5178
Merging this...
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159884153
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/MultiStreamStateHandle.java
---
@@ -1,104 +0,0 @@
-/*
--- End diff --
[
https://issues.apache.org/jira/browse/FLINK-8340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313167#comment-16313167
]
ASF GitHub Bot commented on FLINK-8340:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5226#discussion_r159883585
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendPackageProgramTest.java
---
@@ -60,220 +59,178 @@ public static void init() {
[
https://issues.apache.org/jira/browse/FLINK-8340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313166#comment-16313166
]
ASF GitHub Bot commented on FLINK-8340:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8376:
--
Description: After https://issues.apache.org/jira/browse/FLINK-8375
{{SpillableSubpartition}}
[
https://issues.apache.org/jira/browse/FLINK-8375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8375:
--
Description: {{PipelinedSubpartition}} doesn't need this extra
synchronization in
Piotr Nowojski created FLINK-8376:
-
Summary: Remove potentially unnecessary synchronization in
SpillableSubpartition
Key: FLINK-8376
URL: https://issues.apache.org/jira/browse/FLINK-8376
Project:
[
https://issues.apache.org/jira/browse/FLINK-8375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8375:
--
Description: {{PipelinedSubpartition}} doesn't need this extra
synchronization in
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313164#comment-16313164
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159883287
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
Piotr Nowojski created FLINK-8375:
-
Summary: Remove unnecessary synchronization in ResultPartition
Key: FLINK-8375
URL: https://issues.apache.org/jira/browse/FLINK-8375
Project: Flink
Issue
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5246
Various minor improvements to FileSystem and related classes
## What is the purpose of the change
Many small improvements, like
- harmonization of of `FileSystem.mkdirs()`
[
https://issues.apache.org/jira/browse/FLINK-8359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313158#comment-16313158
]
ASF GitHub Bot commented on FLINK-8359:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5238
Good fix, merging this...
---
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159866220
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -1483,11 +1482,6 @@ long
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313144#comment-16313144
]
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=16313147#comment-16313147
]
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=16313142#comment-16313142
]
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_r159865703
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -669,31 +676,14 @@ else if (current ==
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313154#comment-16313154
]
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=16313141#comment-16313141
]
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_r159865414
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/JobManagerTaskRestore.java
---
@@ -20,15 +20,18 @@
import
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313145#comment-16313145
]
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=16313153#comment-16313153
]
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=16313148#comment-16313148
]
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_r159880527
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
---
@@ -147,7 +147,7 @@ public void close() throws
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313157#comment-16313157
]
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=16313143#comment-16313143
]
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_r159861671
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
---
@@ -132,21
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313140#comment-16313140
]
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_r159877503
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateManager.java
---
@@ -0,0 +1,48 @@
+/*
+ *
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159860788
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1041,7
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313155#comment-16313155
]
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_r159865180
--- Diff:
flink-core/src/main/java/org/apache/flink/util/CloseableIterator.java ---
@@ -18,11 +18,38 @@
package org.apache.flink.util;
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159877880
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java
---
@@ -18,11 +18,14 @@
package
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159865241
--- Diff:
flink-core/src/main/java/org/apache/flink/util/CloseableIterable.java ---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159866648
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -669,31 +676,14 @@ else if (current ==
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159863616
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/BoltWrapperTest.java
---
@@ -375,11 +376,13 @@ public void
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159840075
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -831,11
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313146#comment-16313146
]
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_r159880011
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamFactory.java
---
@@ -43,9 +44,9 @@ CheckpointStateOutputStream
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159881015
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/MultiStreamStateHandle.java
---
@@ -1,104 +0,0 @@
-/*
--- End diff --
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313150#comment-16313150
]
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=16313156#comment-16313156
]
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=16313149#comment-16313149
]
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=16313151#comment-16313151
]
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=16313152#comment-16313152
]
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_r159836477
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -145,8 +145,8 @@
private volatile
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159840618
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -831,11
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159834127
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -145,8 +145,8 @@
private volatile
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5242
Wow, this is pretty good! Thanks a lot!
Addressing Fabian's comment and merging this. Want that merged very soon to
avoid future merge conflicts...
---
[
https://issues.apache.org/jira/browse/FLINK-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313125#comment-16313125
]
ASF GitHub Bot commented on FLINK-8362:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5243
I vaguely recall that there was a reason why we did not shade the
Elasticsearch connectors initially. Maybe a license issue. @zentol and
@tzulitai can you chime in here?
If we want to
[
https://issues.apache.org/jira/browse/FLINK-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313116#comment-16313116
]
ASF GitHub Bot commented on FLINK-8322:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5237
Thanks, looks good, merging this...
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5236
I am with Aljoscha here - the cost of making this information available in
the general case seems pretty high.
What is the use case that needs that feature - can that be implemented in a
[
https://issues.apache.org/jira/browse/FLINK-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313109#comment-16313109
]
ASF GitHub Bot commented on FLINK-6206:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5235
Can you elaborate why you want to change this?
This seems like a perfect regular information, not a case for a warning.
Warnings indicate that something is potentially not okay.
---
101 - 200 of 252 matches
Mail list logo
