Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r167537059
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferBlocker.java
---
@@ -0,0 +1,61 @@
+/*
+ * Licensed to
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r167557594
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -18,1426 +18,40 @@
package
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r167535311
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
---
@@ -18,1426 +18,40 @@
package
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r167537474
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferBlocker.java
---
@@ -0,0 +1,61 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360758#comment-16360758
]
vinoyang commented on FLINK-8459:
-
Hi [~till.rohrmann] , my idea is like yours in a way, refer to the
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360725#comment-16360725
]
Xingcan Cui commented on FLINK-8538:
Thanks for the comments, [~twalthr] and [~fhueske]. Yes, the
[
https://issues.apache.org/jira/browse/FLINK-8517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8517:
Fix Version/s: 1.4.2
> StaticlyNestedIterationsITCase.testJobWithoutObjectReuse unstable on
[
https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8336:
Fix Version/s: 1.4.2
> YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test
[
https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8408:
Fix Version/s: 1.4.2
> YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on
[
https://issues.apache.org/jira/browse/FLINK-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8337:
Fix Version/s: 1.4.2
> GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8402:
Fix Version/s: 1.4.2
> HadoopS3FileSystemITCase.testDirectoryListing fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8521:
Fix Version/s: 1.4.2
> FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8623:
Fix Version/s: 1.4.2
> ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics
[
https://issues.apache.org/jira/browse/FLINK-8520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8520:
Fix Version/s: 1.4.2
> CassandraConnectorITCase.testCassandraTableSink unstable on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8621:
Fix Version/s: 1.4.2
> PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed
[
https://issues.apache.org/jira/browse/FLINK-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8512:
Fix Version/s: 1.4.2
> HAQueryableStateFsBackendITCase unstable on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360701#comment-16360701
]
ASF GitHub Bot commented on FLINK-8475:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5461
[FLINK-8475][config][docs] Integrate Mesos options
## What is the purpose of the change
This PR integrates the Mesos `ConfigOptions` into the configuration docs
generator.
## Brief
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360691#comment-16360691
]
ASF GitHub Bot commented on FLINK-7713:
---
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/5442#discussion_r167542881
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360686#comment-16360686
]
ASF GitHub Bot commented on FLINK-7711:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360685#comment-16360685
]
ASF GitHub Bot commented on FLINK-7711:
---
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/5455#discussion_r167542075
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java
---
@@ -0,0 +1,156 @@
+/*
+ * Licensed
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5455#discussion_r167541843
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360675#comment-16360675
]
ASF GitHub Bot commented on FLINK-7711:
---
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/5455#discussion_r167540798
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java
---
@@ -0,0 +1,156 @@
+/*
+ * Licensed
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5460
[FLINK-8475][config][docs] Integrate Algorithm options
## What is the purpose of the change
This PR ports the runtime algorithm ConfigConstants to `ConfigOptions` and
integrates them into
[
https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360666#comment-16360666
]
ASF GitHub Bot commented on FLINK-8475:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360663#comment-16360663
]
ASF GitHub Bot commented on FLINK-8475:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5459
[FLINK-8475][config][docs] Integrate FS options
## What is the purpose of the change
This PR ports the fileystem ConfigConstants to `ConfigOptions` and
integrates them into the
[
https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8630:
Priority: Blocker (was: Major)
> To support JSON schema to TypeInformation conversion
>
[
https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8630:
Fix Version/s: 1.5.0
> To support JSON schema to TypeInformation conversion
>
[
https://issues.apache.org/jira/browse/FLINK-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8172.
-
Resolution: Fixed
The issue was superseded by https://issues.apache.org/jira/browse/FLINK-8178
[
https://issues.apache.org/jira/browse/FLINK-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360646#comment-16360646
]
Chesnay Schepler commented on FLINK-7952:
-
I question the value of having this counter as part of
[
https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-8630:
---
Assignee: Timo Walther
> To support JSON schema to TypeInformation conversion
>
[
https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8042:
Issue Type: Improvement (was: Bug)
> Retry individual failover-strategy for some time
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360630#comment-16360630
]
Fabian Hueske commented on FLINK-8538:
--
Hi, I agree with [~twalthr]. This looks mostly good, but we
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360627#comment-16360627
]
ASF GitHub Bot commented on FLINK-7711:
---
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/5455#discussion_r167528319
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java
---
@@ -0,0 +1,156 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8411:
Priority: Blocker (was: Critical)
> HeapListState#add(null) will wipe out entire list
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8411:
Issue Type: Improvement (was: Bug)
> HeapListState#add(null) will wipe out entire list
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360614#comment-16360614
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360612#comment-16360612
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360615#comment-16360615
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360613#comment-16360613
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360616#comment-16360616
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360617#comment-16360617
]
ASF GitHub Bot commented on FLINK-7713:
---
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/5442#discussion_r167522151
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167525322
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167520629
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360611#comment-16360611
]
Piotr Nowojski commented on FLINK-8625:
---
I have found one more thing. After fixing the current
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167523546
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167523095
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -0,0 +1,147 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167525118
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
[
https://issues.apache.org/jira/browse/FLINK-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8614:
Priority: Blocker (was: Critical)
> Enable Flip-6 per default
> -
[
https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8621:
Priority: Blocker (was: Critical)
>
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360606#comment-16360606
]
Timo Walther commented on FLINK-8538:
-
Thanks for working on this [~xccui]. I had a quick look at it.
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8623:
Priority: Blocker (was: Critical)
>
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360577#comment-16360577
]
Till Rohrmann commented on FLINK-8212:
--
Hi [~mingleizhang], I think the proper way to solve this
[
https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360573#comment-16360573
]
Till Rohrmann commented on FLINK-8459:
--
Hi [~yanghua], thanks for working on this issue? How do you
[
https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5763:
Fix Version/s: (was: 1.5.0)
1.6.0
> Make savepoints self-contained
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360559#comment-16360559
]
Xingcan Cui commented on FLINK-8538:
Hi [~twalthr] and [~fhueske], I committed a WIP branch to my
[
https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360533#comment-16360533
]
mingleizhang commented on FLINK-8625:
-
Thanks [~pnowojski] We can improve the performance and reduce
[
https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8617.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360511#comment-16360511
]
ASF GitHub Bot commented on FLINK-8617:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5438
---
[
https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360506#comment-16360506
]
ASF GitHub Bot commented on FLINK-8617:
---
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/5438#discussion_r167503729
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -351,7 +351,7 @@ object
[
https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360501#comment-16360501
]
ASF GitHub Bot commented on FLINK-8626:
---
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/5443#discussion_r167502561
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/JobVertexBackPressureHandlerTest.java
---
@@ -57,7 +57,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360492#comment-16360492
]
ASF GitHub Bot commented on FLINK-8626:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360493#comment-16360493
]
ASF GitHub Bot commented on FLINK-8626:
---
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/5443#discussion_r167501726
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/JobVertexBackPressureHandlerTest.java
---
@@ -57,7 +57,7 @@ public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5443#discussion_r167501690
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java
---
@@ -143,7 +143,7 @@
private
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360482#comment-16360482
]
ASF GitHub Bot commented on FLINK-8212:
---
GitHub user zhangminglei opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5458
[FLINK-8212] [network] Pull EnvironmentInformation out of TaskManagerâ¦
## What is the purpose of the change
Pull EnvironmentInformation out of TaskManagerServices
## Brief
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360480#comment-16360480
]
Aljoscha Krettek commented on FLINK-8543:
-
Also, I think it would help to have the stack trace at
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360477#comment-16360477
]
Aljoscha Krettek commented on FLINK-8543:
-
And was there a failure/restore cycle before that error
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360470#comment-16360470
]
Aljoscha Krettek commented on FLINK-8543:
-
There is no other failure or anything suspicious in the
[
https://issues.apache.org/jira/browse/FLINK-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8343:
Assignee: Till Rohrmann
> Add support for job cluster deployment
>
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5383
Changes look good to me. Thanks for the fix @pnowojski. Merging this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7714:
---
Assignee: Gary Yao (was: Fang Yong)
> Port JarPlanHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7712:
---
Assignee: Gary Yao (was: Fang Yong)
> Port JarDeleteHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7715:
---
Assignee: Gary Yao (was: Fang Yong)
> Port JarRunHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360414#comment-16360414
]
Piotr Nowojski commented on FLINK-8560:
---
[~phoenixjiangnan] why would we have to keep all of the
201 - 285 of 285 matches
Mail list logo
