[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407454#comment-16407454
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user sihuazhou commented on a diff i
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 the
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=16407403#comment-16407403
]
Sihua Zhou commented on FLINK-9026:
---
Hi [~till.rohrmann] I'm a bit confused about "We sh
[
https://issues.apache.org/jira/browse/FLINK-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407387#comment-16407387
]
ASF GitHub Bot commented on FLINK-9022:
---
Github user sihuazhou commented on the issu
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&focusedCommentId=16407315#comment-16407315
]
ASF GitHub Bot commented on FLINK-9011:
---
Github user yanghua commented on a diff in
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&focusedCommentId=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&focusedCommentId=16407020#comment-16407020
]
ASF GitHub Bot commented on FLINK-9034:
---
GitHub user StephanEwen opened a pull reque
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 transform
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406975#comment-16406975
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user StephanEwen commented on the is
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 `cre
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 Type:
[
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 Typ
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406943#comment-16406943
]
Stephan Ewen commented on FLINK-8715:
-
[~aljoscha] I think you are right, the problem
[
https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406938#comment-16406938
]
ASF GitHub Bot commented on FLINK-8856:
---
Github user StephanEwen closed the pull req
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&focusedCommentId=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 woul
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406934#comment-16406934
]
Stephan Ewen commented on FLINK-8707:
-
Thanks for all the additional data.
My first t
[
https://issues.apache.org/jira/browse/FLINK-9029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406901#comment-16406901
]
Stephan Ewen commented on FLINK-9029:
-
Hmm, interesting. And security is OFF as you me
[
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: 60e05c05f3fb
[
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: 6657aa2090b6
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406792#comment-16406792
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user asfgit closed the pull request
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&focusedCommentId=16406679#comment-16406679
]
ASF GitHub Bot commented on FLINK-9011:
---
Github user yew1eb commented on a diff in t
[
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 FencingToke
[
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: 6eb91a1006590e6806ec0e6c381fca41
[
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: f3389638eed8
[
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: 071dedcb769d
[
https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406648#comment-16406648
]
ASF GitHub Bot commented on FLINK-8801:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406647#comment-16406647
]
ASF GitHub Bot commented on FLINK-9019:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406649#comment-16406649
]
ASF GitHub Bot commented on FLINK-8942:
---
Github user asfgit closed the pull request
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_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 @@
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 @@
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406610#comment-16406610
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
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 Str
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&focusedCommentId=16406602#comment-16406602
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406606#comment-16406606
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
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&focusedCommentId=16406607#comment-16406607
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406605#comment-16406605
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406612#comment-16406612
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406609#comment-16406609
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406608#comment-16406608
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406615#comment-16406615
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406601#comment-16406601
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406611#comment-16406611
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406604#comment-16406604
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406614#comment-16406614
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406616#comment-16406616
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406600#comment-16406600
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406613#comment-16406613
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406603#comment-16406603
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
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&focusedCommentId=16406599#comment-16406599
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406597#comment-16406597
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
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 t
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406598#comment-16406598
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
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_r175812472
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -176,10 +176,40 @@ function s3_delete {
https://${bucket}.s3.amazonaws.com/${s3_f
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406596#comment-16406596
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a dif
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 Str
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 {
https://${bucket}.s3.amazonaws.com/${s3_f
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 {
https://${bucket}.s3.amazonaws.com/${s3_f
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://${bucket}.s3.amazonaws.com/${s3_f
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406584#comment-16406584
]
ASF GitHub Bot commented on FLINK-6924:
---
Github user walterddr commented on the issu
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&focusedCommentId=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&focusedCommentId=16406559#comment-16406559
]
ASF GitHub Bot commented on FLINK-8903:
---
Github user walterddr commented on a diff i
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: Impr
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&focusedCommentId=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&focusedCommentId=16406501#comment-16406501
]
Andrew Roberts commented on FLINK-7811:
---
Any updates on this? Is this still likely t
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 wrote:
> hi
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406499#comment-16406499
]
ASF GitHub Bot commented on FLINK-8756:
---
Github user tillrohrmann commented on the i
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 Ty
[
https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406493#comment-16406493
]
Till Rohrmann commented on FLINK-8899:
--
Agreed this is not a blocker for 1.5.
> Subm
1 - 100 of 340 matches
Mail list logo
