[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347577#comment-15347577
]
Geoffrey Mon commented on FLINK-4098:
-
Thanks for the {{sys.stdout.flush()}} tip. After adding more
[
https://issues.apache.org/jira/browse/FLINK-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347564#comment-15347564
]
Jark Wu commented on FLINK-4109:
[~vkalavri] [~chengxiang li] [~rmetzger] what do you think ?
> Change
GitHub user jfg9 opened a pull request:
https://github.com/apache/flink/pull/2157
[FLINK-4115] FsStateBackend filesystem verification can cause classpath
exceptions
There are two changes to FsStateBackend to avoid classpath exceptions when
submitting a job from a Flink client
[
https://issues.apache.org/jira/browse/FLINK-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347390#comment-15347390
]
ASF GitHub Bot commented on FLINK-4115:
---
GitHub user jfg9 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347222#comment-15347222
]
vishnu viswanath commented on FLINK-3962:
-
I am getting this exception in Local execution aswell.
[
https://issues.apache.org/jira/browse/FLINK-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3898:
--
Fix Version/s: 1.1.0
> Adamic-Adar Similarity
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Forman-Gornall updated FLINK-4115:
---
Component/s: (was: Core)
Local Runtime
> FsStateBackend
[
https://issues.apache.org/jira/browse/FLINK-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Forman-Gornall updated FLINK-4115:
---
Description:
In the constructor of FsStateBackend, the FileSystem for the checkpoint
Josh Forman-Gornall created FLINK-4115:
--
Summary: FsStateBackend filesystem verification can cause
classpath exceptions
Key: FLINK-4115
URL: https://issues.apache.org/jira/browse/FLINK-4115
Chris Hogue created FLINK-4114:
--
Summary: Need a way to manage multiple named, long-lived jobs on a
single YARN cluster in an automated manner
Key: FLINK-4114
URL: https://issues.apache.org/jira/browse/FLINK-4114
[
https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347023#comment-15347023
]
ASF GitHub Bot commented on FLINK-4113:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2156
[FLINK-4113] [runtime] Always copy first value in ChainedAllReduceDriver
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346899#comment-15346899
]
Greg Hogan commented on FLINK-3879:
---
[~vkalavri] here are the timings I get on an AWS c4.2xlarge using
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346881#comment-15346881
]
Chesnay Schepler commented on FLINK-4098:
-
At that point it is completely normal for the java side
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346830#comment-15346830
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2131
@rmetzger tagging just to make sure you're notified of this PR :)
When will you be free to review? Just for my own time allocation for when
to continue working on the Kinesis connector. If
[
https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346794#comment-15346794
]
ASF GitHub Bot commented on FLINK-4110:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346793#comment-15346793
]
ASF GitHub Bot commented on FLINK-4110:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2153
This will be very helpful! LGTM.
---
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
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2153#discussion_r68276459
--- Diff:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/test/java/TestSkeleton.java
---
@@ -0,0 +1,184 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346750#comment-15346750
]
ASF GitHub Bot commented on FLINK-4110:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2153#discussion_r68272113
--- Diff:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/test/java/TestSkeleton.java
---
@@ -0,0 +1,184 @@
+/*
+
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2147
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346735#comment-15346735
]
ASF GitHub Bot commented on FLINK-1946:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2147#discussion_r68269922
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -750,13 +751,16 @@ protected YarnClusterClient
[
https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346726#comment-15346726
]
ASF GitHub Bot commented on FLINK-1946:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2151
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346713#comment-15346713
]
Geoffrey Mon commented on FLINK-4098:
-
After adding some more print statements in different places, I
Greg Hogan created FLINK-4113:
-
Summary: Always copy first value in ChainedAllReduceDriver
Key: FLINK-4113
URL: https://issues.apache.org/jira/browse/FLINK-4113
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346712#comment-15346712
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2134#discussion_r68268650
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/AbstractMetricGroup.java
---
@@ -146,7 +147,16 @@ public Counter counter(int name) {
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346686#comment-15346686
]
ASF GitHub Bot commented on FLINK-4093:
---
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/2134#discussion_r68265180
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/AbstractMetricGroup.java
---
@@ -146,7 +147,16 @@ public Counter counter(int name) {
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-3800.
Resolution: Fixed
Fixed via 6420c1c264ed3ce0c32ba164c2cdb85ccdccf265
> ExecutionGraphs can become
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2096
---
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-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346669#comment-15346669
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Geoffrey Mon updated FLINK-4098:
Comment: was deleted
(was: Maybe it would be simpler to implement iterations in Python similar to
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346664#comment-15346664
]
Geoffrey Mon commented on FLINK-4098:
-
Maybe it would be simpler to implement iterations in Python
[
https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4061:
--
Priority: Major (was: Blocker)
> about flink jdbc connect oracle db exists a crital bug
>
[
https://issues.apache.org/jira/browse/FLINK-4112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346638#comment-15346638
]
Chesnay Schepler commented on FLINK-4112:
-
Does this entail removing the SuppressRestartException
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346634#comment-15346634
]
Chesnay Schepler commented on FLINK-4098:
-
print statements should appear in the taskmanager.out
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346611#comment-15346611
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2134#discussion_r68256978
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/AbstractMetricGroup.java
---
@@ -146,7 +147,16 @@ public Counter counter(int name) {
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346600#comment-15346600
]
Geoffrey Mon edited comment on FLINK-4098 at 6/23/16 3:26 PM:
--
I wasn't sure
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346600#comment-15346600
]
Geoffrey Mon commented on FLINK-4098:
-
Here's a jobmanager log for a simple Python iteration program
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346598#comment-15346598
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2134#discussion_r68255328
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/AbstractMetricGroup.java
---
@@ -146,7 +147,16 @@ public Counter counter(int name) {
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346584#comment-15346584
]
ASF GitHub Bot commented on FLINK-3319:
---
GitHub user thormanrd opened a pull request:
GitHub user thormanrd opened a pull request:
https://github.com/apache/flink/pull/2155
[FLINK-3319] Added Or function for where clause in CEP Pattern
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346547#comment-15346547
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2134
The changes look good to me. +1 for merging. Good work @zentol. I only had
a question concerning the use of generic parameters which is not really
necessary, imo.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346545#comment-15346545
]
ASF GitHub Bot commented on FLINK-4093:
---
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/2134#discussion_r68248549
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/AbstractMetricGroup.java
---
@@ -146,7 +147,16 @@ public Counter counter(int name) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2105#discussion_r68247987
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -118,40 +120,38 @@ public MetricRegistry(Configuration config) {
[
https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346541#comment-15346541
]
ASF GitHub Bot commented on FLINK-4074:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346488#comment-15346488
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2110
Excellent work @aljoscha. Great fix for the problem and it's also really
nice that we could get rid of the IT case :-) +1 for merging after addressing
my minor comments.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346486#comment-15346486
]
ASF GitHub Bot commented on FLINK-3974:
---
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/2110#discussion_r68241018
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/ChainingITCase.java
---
@@ -0,0 +1,354 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2105#discussion_r68238993
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -118,40 +120,38 @@ public MetricRegistry(Configuration config) {
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346465#comment-15346465
]
ASF GitHub Bot commented on FLINK-4062:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346484#comment-15346484
]
ASF GitHub Bot commented on FLINK-3974:
---
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/2110#discussion_r68240257
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -386,4 +402,23 @@ public void close() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2110#discussion_r68239970
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java
---
@@ -0,0 +1,51 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346476#comment-15346476
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user tillrohrmann commented on a diff in the pull
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2154
[FLINK-4062] Update Windowing Documentation
R: @uce and @kl0u for review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
[
https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346469#comment-15346469
]
ASF GitHub Bot commented on FLINK-4074:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346461#comment-15346461
]
ASF GitHub Bot commented on FLINK-4087:
---
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/2145#discussion_r68238504
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java ---
@@ -73,10 +86,61 @@ public JMXReporter() {
//
[
https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346459#comment-15346459
]
ASF GitHub Bot commented on FLINK-4087:
---
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/2145#discussion_r68238384
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java ---
@@ -265,4 +329,72 @@ public Object getValue() {
[
https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346457#comment-15346457
]
ASF GitHub Bot commented on FLINK-4110:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2153
[FLINK-4110] Add testing skeleton to quickstart
With this change, our quickstart archetypes will also contain some sample
code for bringing up an embedded server for testing purposes.
You can
GitHub user chobeat opened a pull request:
https://github.com/apache/flink/pull/2152
[FLINK-3920] Distributed Linear Algebra: block-based matrix
Second part of the distributed linear algebra contribution. This PR
introduces block-partitioned matrices, operations on them
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346435#comment-15346435
]
ASF GitHub Bot commented on FLINK-3920:
---
GitHub user chobeat opened a pull request:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2096
Will be merging this PR.
---
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
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2096
Thanks for your thorough review @uce.
- We have talked offline concerning the status in the web interface and it
turned out to be not a problem since the jobs are directly removed from
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346404#comment-15346404
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346399#comment-15346399
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on the issue:
Till Rohrmann created FLINK-4112:
Summary: Replace SuppressRestartException with disabling
RestartStrategy
Key: FLINK-4112
URL: https://issues.apache.org/jira/browse/FLINK-4112
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346395#comment-15346395
]
Vasia Kalavri commented on FLINK-3965:
--
The functionality is much needed in my opinion. My concern is
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346364#comment-15346364
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2124#discussion_r68227329
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java
---
@@ -27,10 +27,12 @@
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346360#comment-15346360
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346356#comment-15346356
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2124#discussion_r68227049
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/WindowAssignerContext.java
---
@@ -0,0 +1,37 @@
+/*
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2124#discussion_r68226912
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/MockRuntimeContext.java
---
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346340#comment-15346340
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2110
@tillrohrmann I pushed a commit that removes the per-operator object-reuse
setting, refactors broadcasting and direct outputs and changes the ITCase to a
test case. Happy reviewing. ð
---
If
[
https://issues.apache.org/jira/browse/FLINK-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346325#comment-15346325
]
ASF GitHub Bot commented on FLINK-4046:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2095
Agreed. I had the same thought regarding checking for any final state right
after posting this. ;) +1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply
Jark Wu created FLINK-4111:
--
Summary: Flink Table & SQL doesn't work in very simple example
Key: FLINK-4111
URL: https://issues.apache.org/jira/browse/FLINK-4111
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346322#comment-15346322
]
ASF GitHub Bot commented on FLINK-3800:
---
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/2096#discussion_r68222088
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -1029,21 +1061,25 @@ else if (current ==
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346319#comment-15346319
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346318#comment-15346318
]
ASF GitHub Bot commented on FLINK-3800:
---
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/2096#discussion_r68221836
--- Diff: docs/internals/job_scheduling.md ---
@@ -74,7 +74,28 @@ Besides the vertices, the ExecutionGraph also contains
the {% gh_link /flink-run
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2096#discussion_r68221848
--- Diff: flink-runtime/src/test/resources/log4j-test.properties ---
@@ -16,7 +16,7 @@
# limitations under the License.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2095
---
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-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346317#comment-15346317
]
ASF GitHub Bot commented on FLINK-4046:
---
Github user asfgit closed the pull request at:
1 - 100 of 176 matches
Mail list logo
