Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4581#discussion_r148533217
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
---
@@ -192,21 +198,39 @@ public void t
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4581#discussion_r148532507
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
---
@@ -192,21 +198,39 @@ public void t
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235755#comment-16235755
]
Nico Kruber commented on FLINK-4228:
I was working a bit with the initial PR and have
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7951.
Resolution: Invalid
It appears that the problem was not that we don't explicitly load the
{{HdfsCon
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235751#comment-16235751
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user tillrohrmann closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235750#comment-16235750
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4926
Alright, thanks for the infos @steveloughran.
After an offline discussion with @StephanEwen, we decided that we should
probably not try to explicitly load a Hadoop configuration file fro
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/4926
---
[
https://issues.apache.org/jira/browse/FLINK-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235734#comment-16235734
]
ASF GitHub Bot commented on FLINK-7778:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4927
Very nice, thanks!
Merging this...
---
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/4935#discussion_r148530767
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
@@ -245,
[
https://issues.apache.org/jira/browse/FLINK-7959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235711#comment-16235711
]
Fabian Hueske commented on FLINK-7959:
--
Yes, I think that's a good proposal.
> Split
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235700#comment-16235700
]
Fabian Hueske commented on FLINK-7942:
--
Julian's response on CALCITE-2023 suggests to
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235690#comment-16235690
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235689#comment-16235689
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148526210
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/Scheduler.java
---
@@ -133,32 +133,33 @@ public void shutdown() {
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148526103
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -1065,6 +1177,46 @@ private void sendUpdatePartition
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4912
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4913
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4914
---
[
https://issues.apache.org/jira/browse/FLINK-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil Kumar closed FLINK-7921.
-
> Flink downloads link redirect to spark downloads page
>
[
https://issues.apache.org/jira/browse/FLINK-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil Kumar resolved FLINK-7921.
---
Resolution: Cannot Reproduce
> Flink downloads link redirect to spark downloads page
> ---
Hai Zhou UTC+8 created FLINK-7964:
-
Summary: Add Apache Kafka 1.0.0 connector
Key: FLINK-7964
URL: https://issues.apache.org/jira/browse/FLINK-7964
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-7963:
--
Description:
Hi guys, I've got an idea of a little improvement for testing flink jobs.
All my j
[
https://issues.apache.org/jira/browse/FLINK-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-7963:
--
Description:
Hi guys, I've got an idea of a little improvement for testing flink jobs.
All my j
Rinat Sharipov created FLINK-7963:
-
Summary: Add ability to call trigger savepoint on flink cluster
shutdown
Key: FLINK-7963
URL: https://issues.apache.org/jira/browse/FLINK-7963
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235598#comment-16235598
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user steveloughran commented on the
Github user steveloughran commented on the issue:
https://github.com/apache/flink/pull/4926
creating YarnConfiguration & HdfsConfiguration through some dynamic
classloading is enough to force in these files & configs underneath your own
Configurations. You shouldn't be reading in all
[
https://issues.apache.org/jira/browse/FLINK-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235566#comment-16235566
]
Anil Kumar commented on FLINK-7921:
---
[~greghogan] http url is also redirecting to proper
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7838.
---
Resolution: Fixed
Release Note:
Resolved issues on our side. There is still pending dead
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7838.
-
> Kafka011ProducerExactlyOnceITCase do not finish
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235556#comment-16235556
]
ASF GitHub Bot commented on FLINK-7838:
---
Github user pnowojski commented on the issu
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4915
Fine for me, thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7732.
-
> Invalid offset to commit in Kafka
> -
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235554#comment-16235554
]
ASF GitHub Bot commented on FLINK-7732:
---
Github user pnowojski commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7732.
---
Resolution: Fixed
> Invalid offset to commit in Kafka
> -
>
>
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4928
Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235551#comment-16235551
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4926
Thanks for the review @steveloughran, @StephanEwen and @aljoscha.
If I understood it correctly, then we shouldn't upload the configuration
files from the client and instead try to find t
[
https://issues.apache.org/jira/browse/FLINK-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235547#comment-16235547
]
ASF GitHub Bot commented on FLINK-7745:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4758#discussion_r148499675
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -53,9 +64,89 @@ public void verifyAllBu
[
https://issues.apache.org/jira/browse/FLINK-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235545#comment-16235545
]
ASF GitHub Bot commented on FLINK-7745:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4758#discussion_r148499521
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -53,9 +64,89 @@ public void verifyAllBu
[
https://issues.apache.org/jira/browse/FLINK-7960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235539#comment-16235539
]
ASF GitHub Bot commented on FLINK-7960:
---
Github user GJL commented on the issue:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/4933
LGTM ð
Tests didn't fail after ~1000 local executions.
---
[
https://issues.apache.org/jira/browse/FLINK-7960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235534#comment-16235534
]
ASF GitHub Bot commented on FLINK-7960:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4933#discussion_r148498481
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -844,7 +844,7 @@ else if (current == CANCELING || current ==
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4928
---
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235480#comment-16235480
]
ASF GitHub Bot commented on FLINK-7732:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235479#comment-16235479
]
ASF GitHub Bot commented on FLINK-7784:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4910
---
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235481#comment-16235481
]
ASF GitHub Bot commented on FLINK-7838:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4915
---
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235477#comment-16235477
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4916
Thanks a lot for your review @StephanEwen and @sihuazhou. I've addressed
all your comments @StephanEwen.
Next thing I'll do is to rebase onto the latest master and if Travis gives
gree
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4915
I've added a commit to rename the 011 producer integration test to
`ITCase`. Please let me know if you disagree with that @pnowojski @GJL.
---
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235473#comment-16235473
]
ASF GitHub Bot commented on FLINK-7838:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235468#comment-16235468
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148482755
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -1065,6 +1177,46 @@ private void sendUpdatePartitio
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235458#comment-16235458
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148479985
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java
---
@@ -476,14 +482,13 @@ else if (numSources < para
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235445#comment-16235445
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148477247
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java
---
@@ -476,14 +482,13 @@ else if (numSources < para
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235435#comment-16235435
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235436#comment-16235436
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148474569
--- Diff: flink-runtime/src/test/resources/log4j-test.properties ---
@@ -16,7 +16,7 @@
# limitations under the License.
##
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148474674
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/Scheduler.java
---
@@ -133,32 +133,33 @@ public void shutdown() {
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235434#comment-16235434
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148474427
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -1065,6 +1177,46 @@ private void sendUpdatePartitio
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235429#comment-16235429
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148473906
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -1065,6 +1177,46 @@ private void sendUpdatePartitio
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235426#comment-16235426
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148473363
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -220,14 +233,54 @@ public long getGlobalModVersion(
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235427#comment-16235427
]
ASF GitHub Bot commented on FLINK-7153:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4916#discussion_r148473280
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -126,9 +134,11 @@
/** A future that complet
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-7866:
-
Assignee: Sihua Zhou
> Weigh list of preferred locations for scheduling
> ---
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235403#comment-16235403
]
Till Rohrmann commented on FLINK-7866:
--
Sure, go ahead.
> Weigh list of preferred lo
[
https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235291#comment-16235291
]
Akanksha edited comment on FLINK-6767 at 11/2/17 7:03 AM:
--
Hi I a
[
https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235291#comment-16235291
]
Akanksha commented on FLINK-6767:
-
Hi I am using flink 1.2.1
I am still facing this issue
201 - 279 of 279 matches
Mail list logo
