[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407454#comment-16407454
]
ASF GitHub Bot commented on FLINK-9034:
---
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/5732#discussion_r175983599
--- 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-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407407#comment-16407407
]
ASF GitHub Bot commented on FLINK-6924:
---
Github user buptljy commented on the issue:
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5638
@walterddr What else should I do for this PR ?
---
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407403#comment-16407403
]
Sihua Zhou commented on FLINK-9026:
---
Hi [~till.rohrmann] I'm a bit confused about "We should unregister
[
https://issues.apache.org/jira/browse/FLINK-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407387#comment-16407387
]
ASF GitHub Bot commented on FLINK-9022:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5716
Strange...the Travis failed and the failed is related to
`YarnClusterDescriptorTest`, but it seems not related to this PR...
---
[
https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407315#comment-16407315
]
ASF GitHub Bot commented on FLINK-9011:
---
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/5712#discussion_r175969652
--- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ---
@@ -351,16 +351,16 @@ static ContainerLaunchContext
createTaskExecutorContext(
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407123#comment-16407123
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5706
Thanks for the feedback everybody!
Will merge the PR tomorrow.
---
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407020#comment-16407020
]
ASF GitHub Bot commented on FLINK-9034:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5732
[FLINK-9034] [FLINK-9035] [core] Fix state descriptors
## What is the purpose of the change
Fixes two issue with the `StateDescriptors` that are used to obtain state
access in
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406975#comment-16406975
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5624
Don't we control the calls on `FileSystem` that we make as part of the YARN
upload? Can't we simply avoid all operations that are not strongly consistent?
For example if we strictly only use
Stephan Ewen created FLINK-9036:
---
Summary: Add default value via suppliers
Key: FLINK-9036
URL: https://issues.apache.org/jira/browse/FLINK-9036
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-9035:
---
Summary: State Descriptors have broken hashCode() and equals()
Key: FLINK-9035
URL: https://issues.apache.org/jira/browse/FLINK-9035
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-9034:
---
Assignee: Stephan Ewen
> State Descriptors drop TypeInformation on serialization
>
Stephan Ewen created FLINK-9034:
---
Summary: State Descriptors drop TypeInformation on serialization
Key: FLINK-9034
URL: https://issues.apache.org/jira/browse/FLINK-9034
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406943#comment-16406943
]
Stephan Ewen commented on FLINK-8715:
-
[~aljoscha] I think you are right, the problem is potentially
[
https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406938#comment-16406938
]
ASF GitHub Bot commented on FLINK-8856:
---
Github user StephanEwen closed the pull request at:
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/5658
---
[
https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406935#comment-16406935
]
ASF GitHub Bot commented on FLINK-8620:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5580
Ok, to unblock this, I would suggest to add the new functionality under a
different name, support only adding a single file (and also verify that the
path passed in is a single file). @dawidwys
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406934#comment-16406934
]
Stephan Ewen commented on FLINK-8707:
-
Thanks for all the additional data.
My first thoughts are that
[
https://issues.apache.org/jira/browse/FLINK-9029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406901#comment-16406901
]
Stephan Ewen commented on FLINK-9029:
-
Hmm, interesting. And security is OFF as you mentioned?
Can
[
https://issues.apache.org/jira/browse/FLINK-8701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8701:
Assignee: Chesnay Schepler
> Migrate SavepointMigrationTestBase to MiniClusterResource
>
[
https://issues.apache.org/jira/browse/FLINK-8701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8701.
--
Resolution: Fixed
Fixed via
master: 0231460259b410f42dd4933cb3ae993450bf1694
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8881.
--
Resolution: Fixed
Fixed via
master: 95d4c0170339585cb4876c4bafc1c2a42c44be3c
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406792#comment-16406792
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5701
---
Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5712#discussion_r175842877
--- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ---
@@ -351,16 +351,16 @@ static ContainerLaunchContext
createTaskExecutorContext(
[
https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406679#comment-16406679
]
ASF GitHub Bot commented on FLINK-9011:
---
Github user yew1eb commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8887:
Assignee: Till Rohrmann (was: vinoyang)
> ClusterClient.getJobStatus can throw
[
https://issues.apache.org/jira/browse/FLINK-9019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9019.
--
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
master:
[
https://issues.apache.org/jira/browse/FLINK-8942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8942.
--
Resolution: Fixed
Fixed via
master: f9fbbc3a137276cab4b8abf272199f1cd4633d29
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8801.
--
Resolution: Fixed
Fixed via
master: c90a757b29f168144b1bae99df532911ae682e63
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406648#comment-16406648
]
ASF GitHub Bot commented on FLINK-8801:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406647#comment-16406647
]
ASF GitHub Bot commented on FLINK-9019:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406649#comment-16406649
]
ASF GitHub Bot commented on FLINK-8942:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5602
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5723
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5699
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175828711
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175825995
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175825436
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175826508
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175825728
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406610#comment-16406610
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r175831034
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175828150
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175827727
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175832543
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java ---
@@ -107,4 +131,12 @@ public int getAttemptNumber() {
public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175828193
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175820558
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406602#comment-16406602
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r175826610
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406606#comment-16406606
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406612#comment-16406612
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406609#comment-16406609
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406608#comment-16406608
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406615#comment-16406615
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406601#comment-16406601
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406611#comment-16406611
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406604#comment-16406604
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406607#comment-16406607
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406605#comment-16406605
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406614#comment-16406614
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406616#comment-16406616
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406600#comment-16406600
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406613#comment-16406613
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406603#comment-16406603
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r175817052
--- Diff:
flink-end-to-end-tests/test-scripts/test_local_recovery_and_scheduling.sh ---
@@ -0,0 +1,111 @@
+#!/usr/bin/env bash
+
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406597#comment-16406597
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406599#comment-16406599
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r175812472
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -176,10 +176,40 @@ function s3_delete {
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406598#comment-16406598
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r175810393
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java ---
@@ -31,12 +31,35 @@
private final String taskName;
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175817764
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/NopTaskLocalStateStoreImpl.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406596#comment-16406596
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r175826404
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175811121
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java ---
@@ -107,4 +131,12 @@ public int getAttemptNumber() {
public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175812511
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -176,10 +176,40 @@ function s3_delete {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175812319
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -176,10 +176,40 @@ function s3_delete {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r175812117
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -176,10 +176,40 @@ function s3_delete {
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406584#comment-16406584
]
ASF GitHub Bot commented on FLINK-6924:
---
Github user walterddr commented on the issue:
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/5638
Thanks for the explanation @buptljy. Yeah if that's the case the only way
to validate is via ITCase, it might be an overkill in this situation though.
---
[
https://issues.apache.org/jira/browse/FLINK-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406577#comment-16406577
]
ASF GitHub Bot commented on FLINK-9033:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/5731
[FLINK-9033][config] Replace usages of deprecated
TASK_MANAGER_NUM_TASK_SLOTS
## What is the purpose of the change
The deprecated ConfigConstants#TASK_MANAGER_NUM_TASK_SLOTS is still used a
[
https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406559#comment-16406559
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r175825522
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala
---
@@ -103,6 +106,22 @@
Hai Zhou created FLINK-9033:
---
Summary: Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS
Key: FLINK-9033
URL: https://issues.apache.org/jira/browse/FLINK-9033
Project: Flink
Issue Type:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5573
@tillrohrmann thanks for your reply, it's a misoperation, I have done
rollback and refactored the code based on your suggestion. Please check the
change again.
---
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406509#comment-16406509
]
ASF GitHub Bot commented on FLINK-8756:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-9032:
Component/s: Configuration
> Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE
>
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406501#comment-16406501
]
Andrew Roberts commented on FLINK-7811:
---
Any updates on this? Is this still likely to make it into
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5573
Not sure what exactly happened but you can always go back to an earlier
point via the reflog and then a git hard reset.
On Tue, Mar 20, 2018 at 4:11 PM, vinoyang
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406499#comment-16406499
]
ASF GitHub Bot commented on FLINK-8756:
---
Github user tillrohrmann commented on the issue:
Hai Zhou created FLINK-9032:
---
Summary: Deprecate
ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE
Key: FLINK-9032
URL: https://issues.apache.org/jira/browse/FLINK-9032
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406493#comment-16406493
]
Till Rohrmann commented on FLINK-8899:
--
Agreed this is not a blocker for 1.5.
> Submitting YARN job
1 - 100 of 339 matches
Mail list logo
