[
https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548808#comment-16548808
]
ASF GitHub Bot commented on FLINK-7251:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203605524
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -545,15 +543,15 @@ public IntervalJoined(
[
https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548797#comment-16548797
]
ASF GitHub Bot commented on FLINK-9875:
---
Github user tison1 commented on the issue:
Github user tison1 commented on the issue:
https://github.com/apache/flink/pull/6353
Fix unstable case, the problem is code below, that may assign `constraints`
to a long array and then to a short array, which cause out of index exception.
to solve it we could init `constraints` in
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548759#comment-16548759
]
zhangminglei commented on FLINK-4534:
-
Hi, [~gjy] Can we use a lightweight synchronization mechanism
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548748#comment-16548748
]
ASF GitHub Bot commented on FLINK-9675:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
Hi, @hequn8128 I will create another jira for ```new InputStreamReader```
refactor issue. What do you think ?
---
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548735#comment-16548735
]
Stephen Jason commented on FLINK-9236:
--
Yes, but I can't find [~jiayichao] in the name list.
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephen Jason reassigned FLINK-9236:
Assignee: Stephen Jason
> Use Apache Parent POM 19
>
>
>
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6367#discussion_r203588835
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
---
@@ -959,6 +959,29 @@ class DataStream[T](stream:
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephen Jason reassigned FLINK-9236:
Assignee: (was: Stephen Jason)
> Use Apache Parent POM 19
>
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548718#comment-16548718
]
ASF GitHub Bot commented on FLINK-9850:
---
Github user hequn8128 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548715#comment-16548715
]
jiayichao commented on FLINK-9236:
--
hi [~Stephen Jason]Stephen Jason, Could you give this issue to me
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9675:
Description:
They rely on finalizers (before Java 11), which create unnecessary GC load.
The
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548677#comment-16548677
]
ASF GitHub Bot commented on FLINK-9675:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
Thank you very much! @hequn8128 ! I will take a look.
---
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548670#comment-16548670
]
vinoyang commented on FLINK-9735:
-
Will process this issue soon.
> Potential resource leak in
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548654#comment-16548654
]
ASF GitHub Bot commented on FLINK-9849:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6365
Thanks @yanghua you are right! I just want waiting the travis ending. then
give the old and new version's dependency tree.
---
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548629#comment-16548629
]
ASF GitHub Bot commented on FLINK-9061:
---
Github user mdaxini commented on the issue:
Github user mdaxini commented on the issue:
https://github.com/apache/flink/pull/6302
@indrc
In addition to removing the additional dependency, I think there should be
a test for validating the randomness of the chose algorithm, and to make sure
there are no conflicts. For
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9236:
--
Description:
Flink is still using Apache Parent POM 18. Apache Parent POM 19 is out.
This will also fix
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540754#comment-16540754
]
Ted Yu edited comment on FLINK-9735 at 7/19/18 12:37 AM:
-
Short term, we should
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6259
@dawidwys
in last commit, I did extend `SchemaCoder` to have `getSchemaId` as you
suggested.
---
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548595#comment-16548595
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user medcv commented on the issue:
Github user tison1 commented on the issue:
https://github.com/apache/flink/pull/6364
Thanks! LGTM
cc @zentol
---
Github user tison1 commented on the issue:
https://github.com/apache/flink/pull/6360
@shuai-xu
It makes sense.
The message that TM has successfully allocated slot might lost in transport.
When slot manager receives a slot status report which says one slot has
allocation
[
https://issues.apache.org/jira/browse/FLINK-9884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548559#comment-16548559
]
ASF GitHub Bot commented on FLINK-9884:
---
Github user tison1 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548479#comment-16548479
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6259
@dawidwys For second issue I am looking at other Schema registries and
trying to extend `SchemaCoder`
---
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548425#comment-16548425
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6259
@dawidwys Thanks!
As far as I dog on Confluent code, their api needs `subject` to retrieve
the Schema Id and version and it should be provided by consumer.
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-9891:
-
Assignee: Shuyi Chen
> Flink cluster is not shutdown in YARN mode when Flink client is stopped
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548207#comment-16548207
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user dawidwys commented on the issue:
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/6259
@medcv the new commit does not address any of my previous comments or I
don't understand something.
---
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548150#comment-16548150
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6259
@dawidwys I update the PR, please review
the usage would be like this
` ConfluentRegistryAvroSerializationSchema.forSpecific(User.class, subject,
schemaRegistryUrl)`
as Confluent
Sergey Krasovskiy created FLINK-9891:
Summary: Flink cluster is not shutdown in YARN mode when Flink
client is stopped
Key: FLINK-9891
URL: https://issues.apache.org/jira/browse/FLINK-9891
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Krasovskiy updated FLINK-9891:
-
Description:
We are not using session mode and detached mode. The command to run Flink
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548029#comment-16548029
]
ASF GitHub Bot commented on FLINK-9849:
---
Github user yanghua commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548031#comment-16548031
]
ASF GitHub Bot commented on FLINK-9849:
---
Github user yanghua commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548030#comment-16548030
]
ASF GitHub Bot commented on FLINK-9849:
---
Github user yanghua commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548027#comment-16548027
]
ASF GitHub Bot commented on FLINK-9849:
---
Github user yanghua commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548028#comment-16548028
]
ASF GitHub Bot commented on FLINK-9849:
---
Github user yanghua commented on a diff in the pull
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6365#discussion_r203439890
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
---
@@ -87,22 +90,22 @@ public void
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6365#discussion_r203440989
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
---
@@ -87,22 +90,22 @@ public void
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6365#discussion_r203438579
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -81,7 +85,9 @@ private HTable createTable()
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6365#discussion_r203439523
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
---
@@ -87,22 +90,22 @@ public void
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6365#discussion_r203439859
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
---
@@ -87,22 +90,22 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548019#comment-16548019
]
ASF GitHub Bot commented on FLINK-9675:
---
Github user hequn8128 commented on the issue:
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6335
Hi @zhangminglei ,
Good catch! Maybe the Reader may also need to be adapted, making `new
InputStreamReader` to `Channels.newReader`. I find a benchmark about File
InputStream and Reader
[
https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548014#comment-16548014
]
ASF GitHub Bot commented on FLINK-9878:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6355#discussion_r203437995
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ---
@@ -160,4 +160,41 @@
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548008#comment-16548008
]
ASF GitHub Bot commented on FLINK-9860:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6363
+1
---
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548004#comment-16548004
]
ASF GitHub Bot commented on FLINK-9850:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6367
@tillrohrmann and @zentol I see the Python DataStream API methods do not
match DataStream Java API methods (missed some API methods), Shall we add those
missed API into `PythonDataStream`? If yes,
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547991#comment-16547991
]
ASF GitHub Bot commented on FLINK-9860:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6363#discussion_r203432013
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyLeakDetectionResource.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-9889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9889:
Summary: create .bat script to start Flink task manager (was: .bat script
to start Flink task manager)
>
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547969#comment-16547969
]
ASF GitHub Bot commented on FLINK-9860:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547968#comment-16547968
]
ASF GitHub Bot commented on FLINK-9860:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547967#comment-16547967
]
ASF GitHub Bot commented on FLINK-9860:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6363#discussion_r203422176
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyLeakDetectionResource.java
---
@@ -0,0 +1,84 @@
+/*
+ *
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6363#discussion_r203414529
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -220,4 +224,5 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6363#discussion_r203414700
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyLeakDetectionResource.java
---
@@ -0,0 +1,84 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547965#comment-16547965
]
ASF GitHub Bot commented on FLINK-9850:
---
GitHub user yanghua opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9850:
--
Labels: pull-request-available (was: )
> Add a string to the print method to identify output
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6367
[FLINK-9850] Add a string to the print method to identify output for
DataStream
## What is the purpose of the change
*This pull request adds a string to the print method to identify output
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547934#comment-16547934
]
Gary Yao commented on FLINK-4534:
-
[~yuzhih...@gmail.com] Synchronization bears a performance penalty.
[
https://issues.apache.org/jira/browse/FLINK-9815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547936#comment-16547936
]
ASF GitHub Bot commented on FLINK-9815:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6352
yay travis is green.
---
[
https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547929#comment-16547929
]
ASF GitHub Bot commented on FLINK-9869:
---
Github user tison1 commented on the issue:
Github user tison1 commented on the issue:
https://github.com/apache/flink/pull/6345
OK. This PR is about performance improvement. I will try to give out a
benchmark, but since it is inspired by our own batch table tasks, it might take
time to give one. Though since this PR
[
https://issues.apache.org/jira/browse/FLINK-9886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547917#comment-16547917
]
ASF GitHub Bot commented on FLINK-9886:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547920#comment-16547920
]
ASF GitHub Bot commented on FLINK-9886:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9886:
--
Labels: pull-request-available (was: )
> Build SQL jars with every build
>
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6366
CC @zentol
---
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/6366
[FLINK-9886] [sql-client] Build SQL jars with every build
## What is the purpose of the change
This enables the building of the SQL jars by default. This solves a couple
of issues:
[
https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547909#comment-16547909
]
ASF GitHub Bot commented on FLINK-9878:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6355#discussion_r203405530
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ---
@@ -160,4 +160,41 @@
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9575.
--
Resolution: Fixed
Fixed via
master:
e984168e2eca59c08da90bd5feeac458eaa91bed
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547890#comment-16547890
]
ASF GitHub Bot commented on FLINK-9860:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6363#discussion_r203398509
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -50,6 +55,24 @@
private static final
Gary Yao created FLINK-9890:
---
Summary: Remove obsolete Class ResourceManagerConfiguration
Key: FLINK-9890
URL: https://issues.apache.org/jira/browse/FLINK-9890
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547868#comment-16547868
]
ASF GitHub Bot commented on FLINK-9575:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6322
---
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9849:
--
Labels: pull-request-available (was: )
> Upgrade hbase version to 2.0.1 for hbase connector
>
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547862#comment-16547862
]
ASF GitHub Bot commented on FLINK-9849:
---
GitHub user zhangminglei opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6365
[FLINK-9849] [hbase] Hbase upgrade
## What is the purpose of the change
Upgrade hbase version to 2.0.1 for hbase connector
You can merge this pull request into a Git repository
GitHub user xueyumusic opened a pull request:
https://github.com/apache/flink/pull/6364
[hotfix] typo for SqlExecutionException msg
fix typo in SqlExecutionException msg in ExecutionContext.java
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547853#comment-16547853
]
ASF GitHub Bot commented on FLINK-9862:
---
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/6351#discussion_r203382388
--- Diff:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/SemanticsCheckMapper.java
---
@@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6351#discussion_r203380952
--- Diff:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
---
[
https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547848#comment-16547848
]
ASF GitHub Bot commented on FLINK-9862:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547846#comment-16547846
]
ASF GitHub Bot commented on FLINK-9185:
---
Github user StephenJeson commented on a diff in the pull
Github user StephenJeson commented on a diff in the pull request:
https://github.com/apache/flink/pull/5894#discussion_r203378828
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PrioritizedOperatorSubtaskState.java
---
@@ -281,10 +281,15 @@ public
[
https://issues.apache.org/jira/browse/FLINK-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547837#comment-16547837
]
ASF GitHub Bot commented on FLINK-9858:
---
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/6361#discussion_r203377098
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -240,6 +240,15 @@ function start_cluster {
done
}
+function
[
https://issues.apache.org/jira/browse/FLINK-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9832.
---
Resolution: Won't Fix
Fix Version/s: (was: 1.5.2)
(was:
1 - 100 of 313 matches
Mail list logo
