[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4347:
--
Summary: Implement SlotManager core for new ResourceManager (was:
Implement SlotManager for new Resourc
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426031#comment-15426031
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r75260223
--- Diff:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/util/TestMeter.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426108#comment-15426108
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2300
I am fine with either solution to the double-check locking issue: making
the variable volatile, or eagerly creating the map.
Pick the one you prefer, and then this should be good to merge
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75269835
--- Diff: flink-dist/pom.xml ---
@@ -113,8 +113,13 @@ under the License.
flink-metrics-jmx
${project.version}
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426113#comment-15426113
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75269975
--- Diff: flink-mesos/pom.xml ---
@@ -0,0 +1,294 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426114#comment-15426114
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75270753
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/cli/FlinkMesosSessionCli.java
---
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426118#comment-15426118
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75271531
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed to
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75271636
--- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/Utils.java ---
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426120#comment-15426120
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426122#comment-15426122
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75272075
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426125#comment-15426125
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426126#comment-15426126
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75272248
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
---
@@ -0,0 +1,205 @@
+/*
+ * Licensed to
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75274022
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -0,0 +1,618 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426135#comment-15426135
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75275043
--- Diff: flink-mesos/pom.xml ---
@@ -0,0 +1,294 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426140#comment-15426140
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426147#comment-15426147
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75275735
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosConfigKeys.java
---
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426153#comment-15426153
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75276016
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426161#comment-15426161
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75276925
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ * Licensed
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2366
Reading the code once again, just few doubts/questions
->If a save point is triggered and that is happening with in the duration
of the 'MINIMUM_TIME_BETWEEN_CHECKPOINTS' we still throw back a
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426167#comment-15426167
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426173#comment-15426173
]
Aljoscha Krettek commented on FLINK-4341:
-
The regression was introduced in commit
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75279529
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426188#comment-15426188
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426196#comment-15426196
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75280315
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ * Licensed
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
@twalthr @wuchong
Could you please review one more time? This PR is blocking another similar
PR.
The test failure does not seem to have anything to do with the new code.
---
If your proje
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426199#comment-15426199
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426201#comment-15426201
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2366
Savepoints are excepted form the concurrent checkpoints and time between
checkpoints limitation. These checks run only if the triggered checkpoint is
not a savepoint (in the triggerCheckpoint(...
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75281657
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/RegisteredMesosWorkerNode.scala
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2366
Ya. So may be this code
`if (lastTriggeredCheckpoint + minPauseBetweenCheckpoints > timestamp) {`
The if block should also go inside the previous 'if' condition that checks
for !savePoint,
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426207#comment-15426207
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426208#comment-15426208
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user ramkrish86 commented on the iss
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75282003
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426210#comment-15426210
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2366
You are right, this was an oversight on my side. This check should also be
within the `if (!isSavepoint())` block. Thanks for reviewing this.
Do you want to create a fix for that?
---
I
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426212#comment-15426212
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user StephanEwen commented on the is
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2305
+1 for this approach.
On Thu, Aug 18, 2016 at 6:59 AM, Jark wrote:
> I'm ok with the with(...) approach. In addition, we should create a JIRA
> under [FLINK-3957]
> "Bre
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426215#comment-15426215
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
@mxm @zentol @kl0u Could you please give it another review?
---
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
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426214#comment-15426214
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user tillrohrmann commented on the i
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2366
Yes. I can do it. Thanks.
Is it better to raise a JIRA for that for accounting or just raise a PR
with the same issue ID?
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426219#comment-15426219
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user ramkrish86 commented on the iss
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75282731
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java
---
@@ -0,0 +1,87 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426220#comment-15426220
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2366
JIRA issue never hurts. But in this case, it could piggy-bag on the
previous issue. Your choice ;-)
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426222#comment-15426222
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4341:
Fix Version/s: 1.1.2
1.2.0
> Checkpoint state size grows unbounded when task para
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426223#comment-15426223
]
Stephan Ewen commented on FLINK-4341:
-
Thanks, [~aljoscha] for debugging this. [~rmetz
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426223#comment-15426223
]
Stephan Ewen edited comment on FLINK-4341 at 8/18/16 10:20 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4341:
Component/s: (was: Core)
Streaming Connectors
> Checkpoint state size grows unb
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75283539
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
---
@@ -0,0 +1,290 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4341:
Description:
**Prevously reported as "Checkpoint state size grows unbounded when task
parallelism n
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4341:
Priority: Blocker (was: Critical)
> Checkpoint state size grows unbounded when task parallelism not
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4341:
Summary: Kinesis connector does not emit maximum watermark properly (was:
Checkpoint state size gro
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75283689
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426226#comment-15426226
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426227#comment-15426227
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75283918
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426230#comment-15426230
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426232#comment-15426232
]
Tzu-Li (Gordon) Tai commented on FLINK-4341:
I can take a look at fixing this
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426231#comment-15426231
]
Robert Metzger commented on FLINK-4341:
---
The reason why the Kinesis consumer is not
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426232#comment-15426232
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4341 at 8/18/16 10:28 AM:
--
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75284993
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/SchedulerProxy.java
---
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426238#comment-15426238
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75285550
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/SchedulerProxy.java
---
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Fo
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75285623
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/SchedulerProxy.java
---
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426241#comment-15426241
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75285727
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/scheduler/TaskSchedulerBuilder.java
---
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426244#comment-15426244
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426242#comment-15426242
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Stephan Ewen created FLINK-4421:
---
Summary: Make clocks and time measurements monotonous
Key: FLINK-4421
URL: https://issues.apache.org/jira/browse/FLINK-4421
Project: Flink
Issue Type: Improvem
Stephan Ewen created FLINK-4422:
---
Summary: Convert all time interval measurements to
System.nanoTime()
Key: FLINK-4422
URL: https://issues.apache.org/jira/browse/FLINK-4422
Project: Flink
Issu
Stephan Ewen created FLINK-4423:
---
Summary: Introduce a Clock utility for monotonous system timestamps
Key: FLINK-4423
URL: https://issues.apache.org/jira/browse/FLINK-4423
Project: Flink
Issue
GitHub user ramkrish86 opened a pull request:
https://github.com/apache/flink/pull/2385
FLINK-4322 (addendum)Issue with savepoint considering the time interval
like that of checkâ¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the followin
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426317#comment-15426317
]
ASF GitHub Bot commented on FLINK-4322:
---
GitHub user ramkrish86 opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426319#comment-15426319
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2244
Could we move `CsvTableSinkTest` to `TableSinkITCase` or just remove
`CsvTableSinkTest` ? I think `TableSinkITCase` has tested `CsvTableSink` with
default delimiter and custom delimiter.
---
If y
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75295468
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java
---
@@ -0,0 +1,304 @@
+/*
+ * Licensed to the Apache Software Fo
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75295536
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java
---
@@ -0,0 +1,304 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426327#comment-15426327
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426329#comment-15426329
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75296348
--- Diff: flink-mesos/src/main/resources/log4j.properties ---
@@ -0,0 +1,27 @@
+##
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426336#comment-15426336
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426339#comment-15426339
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75296757
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala
---
@@ -0,0 +1,174 @@
+/*
+ * Licensed to the
Github user pm-pushpendra-jaiswal commented on the issue:
https://github.com/apache/flink/pull/357
Hi @aljoscha
Still getting this warning on compiling for accessing a of type
Map[String,Any]
Type Any has no fields that are visible from Scala Type analysis. Falling
back to J
[
https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426344#comment-15426344
]
ASF GitHub Bot commented on FLINK-1458:
---
Github user pm-pushpendra-jaiswal commented
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2350#discussion_r75297857
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -179,7 +195,16 @@ publ
1 - 100 of 334 matches
Mail list logo
