[
https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347836#comment-15347836
]
ramkrishna.s.vasudevan commented on FLINK-3397:
---
[~uce]
Your thoughts here?
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347835#comment-15347835
]
Simone Robutti commented on FLINK-1873:
---
I opened a PR for FLINK-3920 with the rest
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347577#comment-15347577
]
Geoffrey Mon commented on FLINK-4098:
-
Thanks for the {{sys.stdout.flush()}} tip. Afte
[
https://issues.apache.org/jira/browse/FLINK-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347564#comment-15347564
]
Jark Wu commented on FLINK-4109:
[~vkalavri] [~chengxiang li] [~rmetzger] what do you thi
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 which
[
https://issues.apache.org/jira/browse/FLINK-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15347222#comment-15347222
]
vishnu viswanath commented on FLINK-3962:
-
I am getting this exception in Local ex
[
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: FLINK-38
[
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 filesyste
[
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
Proje
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&focusedCommentId=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
4113
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346899#comment-15346899
]
Greg Hogan commented on FLINK-3879:
---
[~vkalavri] here are the timings I get on an AWS c4
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346881#comment-15346881
]
Chesnay Schepler commented on FLINK-4098:
-
At that point it is completely normal f
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 there'
[
https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15346793#comment-15346793
]
ASF GitHub Bot commented on FLINK-4110:
---
Github user tzulitai commented on a diff in
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 an
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&focusedCommentId=15346750#comment-15346750
]
ASF GitHub Bot commented on FLINK-4110:
---
Github user tzulitai commented on a diff in
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 i
[
https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 deployIntern
[
https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346726#comment-15346726
]
ASF GitHub Bot commented on FLINK-1946:
---
Github user zentol commented on a diff in t
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 i
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346713#comment-15346713
]
Geoffrey Mon commented on FLINK-4098:
-
After adding some more print statements in diff
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&focusedCommentId=15346712#comment-15346712
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user zentol commented on a diff in t
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&focusedCommentId=15346686#comment-15346686
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user tillrohrmann commented on a dif
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 o
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346669#comment-15346669
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user asfgit closed the pull request
[
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
a
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346664#comment-15346664
]
Geoffrey Mon commented on FLINK-4098:
-
Maybe it would be simpler to implement iteratio
[
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&focusedCommentId=15346638#comment-15346638
]
Chesnay Schepler commented on FLINK-4112:
-
Does this entail removing the SuppressR
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346634#comment-15346634
]
Chesnay Schepler commented on FLINK-4098:
-
print statements should appear in the t
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346611#comment-15346611
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user zentol commented on a diff in t
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&focusedCommentId=15346600#comment-15346600
]
Geoffrey Mon edited comment on FLINK-4098 at 6/23/16 3:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-4098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346600#comment-15346600
]
Geoffrey Mon commented on FLINK-4098:
-
Here's a jobmanager log for a simple Python ite
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346598#comment-15346598
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user zentol commented on a diff in t
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&focusedCommentId=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&focusedCommentId=15346547#comment-15346547
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user tillrohrmann commented on the i
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 up
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346545#comment-15346545
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user tillrohrmann commented on a dif
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&focusedCommentId=15346541#comment-15346541
]
ASF GitHub Bot commented on FLINK-4074:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346488#comment-15346488
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user tillrohrmann commented on the i
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 is
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346486#comment-15346486
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user tillrohrmann commented on a dif
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 @@
+/*
+ * Lice
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&focusedCommentId=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&focusedCommentId=15346484#comment-15346484
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user tillrohrmann commented on a dif
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&focusedCommentId=15346476#comment-15346476
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user tillrohrmann commented on a dif
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 wi
[
https://issues.apache.org/jira/browse/FLINK-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346469#comment-15346469
]
ASF GitHub Bot commented on FLINK-4074:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346461#comment-15346461
]
ASF GitHub Bot commented on FLINK-4087:
---
Github user tillrohrmann commented on a dif
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&focusedCommentId=15346459#comment-15346459
]
ASF GitHub Bot commented on FLINK-4087:
---
Github user tillrohrmann commented on a dif
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&focusedCommentId=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 merg
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 (multiplica
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 wi
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&focusedCommentId=15346404#comment-15346404
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346399#comment-15346399
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on the i
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&focusedCommentId=15346395#comment-15346395
]
Vasia Kalavri commented on FLINK-3965:
--
The functionality is much needed in my opinio
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346364#comment-15346364
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on a diff in
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&focusedCommentId=15346360#comment-15346360
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346356#comment-15346356
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on a diff in
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&focusedCommentId=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 y
[
https://issues.apache.org/jira/browse/FLINK-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 appe
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&focusedCommentId=15346322#comment-15346322
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on a dif
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 == JobSta
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346319#comment-15346319
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346318#comment-15346318
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on a dif
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.
###
1 - 100 of 178 matches
Mail list logo
