[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351667#comment-16351667
]
ASF GitHub Bot commented on FLINK-7856:
---
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/5397#discussion_r165835719
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835514
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351666#comment-16351666
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351660#comment-16351660
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351662#comment-16351662
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351663#comment-16351663
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351661#comment-16351661
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351664#comment-16351664
]
ASF GitHub Bot commented on FLINK-7856:
---
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/5397#discussion_r165835488
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -358,6 +361,18 @@ public void start() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835486
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -313,6 +325,13 @@ public JobMaster(
.orEl
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835482
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,184 @@
+/*
+ * Licensed to th
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835483
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -867,6 +889,25 @@ public void heartbeatFromResourceManager(final
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835481
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351658#comment-16351658
]
ASF GitHub Bot commented on FLINK-8555:
---
GitHub user Xpray opened a pull request:
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/5409
[FLINK-8555][TableAPI & SQL] Fix TableFunction varargs length exceed 254
## What is the purpose of the change
*Support TableFunction parameters exceeds 254 with Varargs for SQL*
Ruidong Li created FLINK-8555:
-
Summary: Fix TableFunction varargs length exceeds 254 for SQL
Key: FLINK-8555
URL: https://issues.apache.org/jira/browse/FLINK-8555
Project: Flink
Issue Type: Impr
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165834978
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351656#comment-16351656
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tweise commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351646#comment-16351646
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tweise commented on a diff in t
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/5408
[hotfix][docs] Fix typos in windows document
Hotfix typos in Windows Document.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yew1eb/flink 201802
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165834292
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
@@ -214,
Ted Yu created FLINK-8554:
-
Summary: Upgrade AWS SDK
Key: FLINK-8554
URL: https://issues.apache.org/jira/browse/FLINK-8554
Project: Flink
Issue Type: Improvement
Reporter: Ted Yu
AWS SD
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16304163#comment-16304163
]
Ted Yu edited comment on FLINK-4534 at 2/4/18 4:23 AM:
---
Can this get
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16307281#comment-16307281
]
Ted Yu edited comment on FLINK-6105 at 2/4/18 3:09 AM:
---
In
flink-co
[
https://issues.apache.org/jira/browse/FLINK-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351594#comment-16351594
]
Bowen Li commented on FLINK-8514:
-
[~rmetzger] What do you think, Robert? Since you are PM
[
https://issues.apache.org/jira/browse/FLINK-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8514:
Description:
I propose moving flink-connector-wikiedits to Apache Bahir given its low
popularity
was:I
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351580#comment-16351580
]
Ph.Duveau commented on FLINK-8468:
--
Also added the ability to disable queue creation on s
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ph.Duveau updated FLINK-8468:
-
Description: Make the connector to take advantage of AMQP features by
adding a constructor and an interfac
Bowen Li created FLINK-8553:
---
Summary: switch flink-metrics-datadog to async mode
Key: FLINK-8553
URL: https://issues.apache.org/jira/browse/FLINK-8553
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351405#comment-16351405
]
Xingcan Cui commented on FLINK-8538:
Hi [~twalthr], thanks for opening this.
I just g
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5406
@zentol thanks for your attention to this PR, I had updated this PR
according to your comments.
---
32 matches
Mail list logo
