[
https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9040:
-
Assignee: Sihua Zhou
> JobVertex#setMaxParallelism does not valid argument
>
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5725
Thank your trying to help improve Flink.
I think, however, this patch is not necessary. The method does not require
synchronization, it should be correct as it is.
---
[
https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407737#comment-16407737
]
ASF GitHub Bot commented on FLINK-7343:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5729
Sweet, nice to see this fixed.
Code looks good, +1 to merge!
---
Chesnay Schepler created FLINK-9040:
---
Summary: JobVertex#setMaxParallelism does not valid argument
Key: FLINK-9040
URL: https://issues.apache.org/jira/browse/FLINK-9040
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407732#comment-16407732
]
ASF GitHub Bot commented on FLINK-9020:
---
Github user florianschmidt1994 commented on the issue:
Github user florianschmidt1994 commented on the issue:
https://github.com/apache/flink/pull/5717
Thanks @zentol! I addressed your comments and will squash if approved
---
[
https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407726#comment-16407726
]
Till Rohrmann commented on FLINK-9010:
--
Does your Yarn cluster has enough resources to run this
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5717#discussion_r176032646
--- Diff: flink-end-to-end-tests/parent-child-classloading-test/pom.xml ---
@@ -0,0 +1,107 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
[
https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407724#comment-16407724
]
ASF GitHub Bot commented on FLINK-9020:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407705#comment-16407705
]
ASF GitHub Bot commented on FLINK-8975:
---
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/5733#discussion_r176029439
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407703#comment-16407703
]
ASF GitHub Bot commented on FLINK-9026:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5734#discussion_r176029020
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -292,6 +292,13 @@ public void start() throws
[
https://issues.apache.org/jira/browse/FLINK-9028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9028.
--
Resolution: Fixed
Fixed via
master:
38aa863d5a710b283b5c9b2eb9225d6fb9cc0c70
[
https://issues.apache.org/jira/browse/FLINK-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt reassigned FLINK-8980:
--
Assignee: Florian Schmidt
> End-to-end test: BucketingSink
>
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407700#comment-16407700
]
ASF GitHub Bot commented on FLINK-8975:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407698#comment-16407698
]
ASF GitHub Bot commented on FLINK-9028:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407697#comment-16407697
]
ASF GitHub Bot commented on FLINK-9022:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9022.
--
Resolution: Fixed
Fixed via
master: f9df13c5058f194a5c686b9b753345d9226fc87a
1.5.0:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5733#discussion_r176028721
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5726
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5716
---
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407695#comment-16407695
]
ASF GitHub Bot commented on FLINK-9026:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407696#comment-16407696
]
ASF GitHub Bot commented on FLINK-9026:
---
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/5734#discussion_r176028213
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -265,7 +265,11 @@ class TaskManager(
case t:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5734#discussion_r176028191
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -292,6 +292,13 @@ public void start() throws Exception
Florian Schmidt created FLINK-9039:
--
Summary: Broken link to Hadoop Setup Guide in docs
Key: FLINK-9039
URL: https://issues.apache.org/jira/browse/FLINK-9039
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407692#comment-16407692
]
ASF GitHub Bot commented on FLINK-8975:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407691#comment-16407691
]
ASF GitHub Bot commented on FLINK-8975:
---
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/5733#discussion_r176027636
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5733#discussion_r176027456
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407688#comment-16407688
]
ASF GitHub Bot commented on FLINK-9026:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407686#comment-16407686
]
ASF GitHub Bot commented on FLINK-9026:
---
GitHub user sihuazhou opened a pull request:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5734
CC: @tillrohrmann
---
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5734
[FLINK-9026][Metrics] Close the TaskManagerMetricGroup when the
TaskExecutor is shut down
## What is the purpose of the change
We should close the `TaskManagerMetricGroup` when the
[
https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407683#comment-16407683
]
Fabian Hueske commented on FLINK-9031:
--
Adding relevant information from the mail thread:
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407670#comment-16407670
]
ASF GitHub Bot commented on FLINK-8975:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407669#comment-16407669
]
ASF GitHub Bot commented on FLINK-8975:
---
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/5733#discussion_r176020327
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5733#discussion_r176019938
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9038.
Resolution: Duplicate
> YARNSessionCapacitySchedulerITCase fails on travis
>
[
https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407641#comment-16407641
]
Till Rohrmann commented on FLINK-9038:
--
I thin this one is a duplicate of FLINK-8899 or vice versa.
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407636#comment-16407636
]
ASF GitHub Bot commented on FLINK-8756:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hitesh Tiwari closed FLINK-8909.
Resolution: Not A Problem
> pyflink.sh not working with yarn
>
>
>
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5573
Changes look good @yanghua. Merging this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9038:
Description: https://travis-ci.org/apache/flink/jobs/355821305
>
Chesnay Schepler created FLINK-9038:
---
Summary: YARNSessionCapacitySchedulerITCase fails on travis
Key: FLINK-9038
URL: https://issues.apache.org/jira/browse/FLINK-9038
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407633#comment-16407633
]
Hitesh Tiwari commented on FLINK-8909:
--
Thanks,
Configured `python.dc.tmp.dir` and it worked for
[
https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9038:
Description:
https://travis-ci.org/apache/flink/jobs/355821305
{code}
est
[
https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8899:
-
Priority: Major (was: Minor)
> Submitting YARN job with FLIP-6 may lead to
>
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407621#comment-16407621
]
ASF GitHub Bot commented on FLINK-8975:
---
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/5733#discussion_r176011796
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -0,0 +1,102 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407618#comment-16407618
]
Nico Kruber commented on FLINK-8899:
It should, however, also not be in "minor" priority as this may
[
https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407616#comment-16407616
]
ASF GitHub Bot commented on FLINK-8975:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5733
[FLINK-8975] [test] Add resume from savepoint end-to-end test
## What is the purpose of the change
This pull request adds an end-to-end test that verifies resuming a job from
a savepoint.
[
https://issues.apache.org/jira/browse/FLINK-8519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-8519.
--
Resolution: Invalid
Thanks [~yew1eb] for the clarification. Let me close this jira ticket then.
>
[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-8979:
--
Assignee: Tzu-Li (Gordon) Tai
> Extend Kafka end-to-end tests to run with
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407601#comment-16407601
]
Till Rohrmann commented on FLINK-9026:
--
I think it is often better to close/unregister resources in
Stephan Ewen created FLINK-9037:
---
Summary: Test flake Kafka09ITCase#testCancelingEmptyTopic
Key: FLINK-9037
URL: https://issues.apache.org/jira/browse/FLINK-9037
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407588#comment-16407588
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176006260
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java
---
@@ -77,18 +80,22 @@
/** The serializer for
[
https://issues.apache.org/jira/browse/FLINK-9029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407582#comment-16407582
]
Mohammad Abareghi commented on FLINK-9029:
--
[~StephanEwen] Yes. Security is OFF.
I'll try to
[
https://issues.apache.org/jira/browse/FLINK-9029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohammad Abareghi updated FLINK-9029:
-
Description:
*Environment*
* Flink-1.4.2
* Hadoop 2.6.0-cdh5.13.0 with 4 nodes in
201 - 264 of 264 matches
Mail list logo
