Github user mproch commented on the issue:
https://github.com/apache/flink/pull/2498
@StephanEwen can I retrigger this or whatever?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this featur
[
https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581389#comment-15581389
]
ASF GitHub Bot commented on FLINK-4619:
---
Github user mproch commented on the issue:
Kurt Young created FLINK-4839:
-
Summary: JobManager handle TaskManager's slot offering
Key: FLINK-4839
URL: https://issues.apache.org/jira/browse/FLINK-4839
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581206#comment-15581206
]
ASF GitHub Bot commented on FLINK-4838:
---
GitHub user manuzhang opened a pull request
GitHub user manuzhang opened a pull request:
https://github.com/apache/flink/pull/2645
[FLINK-4838] remote STREAM keyword in StreamSQLExample
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If y
Manu Zhang created FLINK-4838:
-
Summary: remove STREAM keyword in StreamSQLExample
Key: FLINK-4838
URL: https://issues.apache.org/jira/browse/FLINK-4838
Project: Flink
Issue Type: Bug
C
GitHub user sbcd90 opened a pull request:
https://github.com/apache/flink/pull/2644
[FLINK-4837] flink-streaming-akka source connector
This PR is created to propose the idea of having a `flink-streaming-akka
source connector`.
The source connector can be used to receive me
[
https://issues.apache.org/jira/browse/FLINK-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581175#comment-15581175
]
ASF GitHub Bot commented on FLINK-4837:
---
GitHub user sbcd90 opened a pull request:
Subhobrata Dey created FLINK-4837:
-
Summary: flink-streaming-akka source connector
Key: FLINK-4837
URL: https://issues.apache.org/jira/browse/FLINK-4837
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581104#comment-15581104
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2580
Merging this once tests turn green.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581097#comment-15581097
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83573944
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,85 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581083#comment-15581083
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83573419
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,186 @@
[
https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581039#comment-15581039
]
ASF GitHub Bot commented on FLINK-4547:
---
Github user beyond1920 closed the pull requ
Github user beyond1920 closed the pull request at:
https://github.com/apache/flink/pull/2455
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581018#comment-15581018
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83571326
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,186 @@
[
https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian reassigned FLINK-4627:
--
Assignee: Neelesh Srinivas Salian
> Use Flink's PropertiesUtil in Kines
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian reassigned FLINK-4659:
--
Assignee: Neelesh Srinivas Salian
> Potential resource leak due to uncl
[
https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-4753.
--
Resolution: Not A Bug
> Kafka 0.8 connector's Periodic Offset Committer should synchroni
Github user tzulitai closed the pull request at:
https://github.com/apache/flink/pull/2604
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is en
[
https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580926#comment-15580926
]
ASF GitHub Bot commented on FLINK-4753:
---
Github user tzulitai closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580925#comment-15580925
]
ASF GitHub Bot commented on FLINK-4753:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580923#comment-15580923
]
ASF GitHub Bot commented on FLINK-4652:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2604
@rmetzger No worries, it's okay ;) Closing this now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have thi
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2635
Thanks for fixing this. +1, looks good to me.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this featu
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580919#comment-15580919
]
Ted Yu commented on FLINK-4659:
---
Please go ahead.
> Potential resource leak due to unclosed
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2643
[hotfix] Treat taskManager's rpc address and location separately
I forgot that rpc address and the address from TaskManagerLocation are not
the same thing, we should use rpc address to communicate
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580868#comment-15580868
]
ASF GitHub Bot commented on FLINK-3999:
---
GitHub user nssalian opened a pull request:
GitHub user nssalian opened a pull request:
https://github.com/apache/flink/pull/2642
[FLINK-3999]: Rename the `running` flag in the drivers to `canceled`
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerat
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580858#comment-15580858
]
Neelesh Srinivas Salian commented on FLINK-4659:
I can work on this one [~
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580842#comment-15580842
]
ASF GitHub Bot commented on FLINK-4792:
---
GitHub user nssalian opened a pull request:
GitHub user nssalian opened a pull request:
https://github.com/apache/flink/pull/2641
[FLINK-4792] [Docs] Update documentation - FlinkML/QuickStart Guide
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerati
[
https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young resolved FLINK-4351.
---
Resolution: Fixed
resolved by a19cae3b07963776c07c0aae7bee806004f59429
> JobManager handle TaskManage
[
https://issues.apache.org/jira/browse/FLINK-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young resolved FLINK-4689.
---
Resolution: Fixed
resolved by e91b82d3c868e18611064f905b345906f1414f84
> Implement a simple slot prov
[
https://issues.apache.org/jira/browse/FLINK-4836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580584#comment-15580584
]
Stephan Ewen commented on FLINK-4836:
-
Part one implemented in the flip-6 feature bran
[
https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4835.
---
> Implement standalone High Availability Services
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4835.
-
Resolution: Implemented
Implemented in flip-6 feature branch
> Implement standalone High Availabi
Stephan Ewen created FLINK-4836:
---
Summary: Implement Mini Cluster
Key: FLINK-4836
URL: https://issues.apache.org/jira/browse/FLINK-4836
Project: Flink
Issue Type: New Feature
Componen
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4657.
---
> Implement HighAvailabilityServices based on zookeeper
>
Stephan Ewen created FLINK-4835:
---
Summary: Implement standalone High Availability Services
Key: FLINK-4835
URL: https://issues.apache.org/jira/browse/FLINK-4835
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4657:
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-4834
> Implement HighAvailabilityServ
Stephan Ewen created FLINK-4834:
---
Summary: Implement unified High Availability Services Abstraction
Key: FLINK-4834
URL: https://issues.apache.org/jira/browse/FLINK-4834
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2345.
-
Resolution: Unresolved
This needs more concrete suggestions
> Zero Configuration Cluster Setup
>
[
https://issues.apache.org/jira/browse/FLINK-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2345.
---
> Zero Configuration Cluster Setup
>
>
> Key: FLINK-2345
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580345#comment-15580345
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r83556947
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkTypeFactory.scala
---
@@ -79,14 +83,27 @@ class FlinkTypeFactory(typeSys
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580335#comment-15580335
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r83556835
--- Diff: docs/dev/table_api.md ---
@@ -1656,6 +1656,29 @@ temporalOverlaps(TIMEPOINT, TEMPORAL, TIMEPOINT,
TEMPORAL)
+
[
https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580160#comment-15580160
]
ASF GitHub Bot commented on FLINK-3931:
---
Github user skrishnappa commented on the is
Github user skrishnappa commented on the issue:
https://github.com/apache/flink/pull/2518
Have included few more test cases to handle ssl failure scenarios.
Also rebased the PR to the latest master
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15580157#comment-15580157
]
ASF GitHub Bot commented on FLINK-3931:
---
Github user skrishnappa commented on a diff
Github user skrishnappa commented on a diff in the pull request:
https://github.com/apache/flink/pull/2518#discussion_r83553892
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java
---
@@ -0,0 +1,284 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-4351:
-
Assignee: Kurt Young
> JobManager handle TaskManager's registration
> ---
[
https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4351:
--
Summary: JobManager handle TaskManager's registration (was: interaction
between new JobManager and new
[
https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4351:
--
Description:
was:
1. Receive slot offer from TaskExecutor， ack it or reject it
2. Release slot allo
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15579933#comment-15579933
]
Vasia Kalavri commented on FLINK-4129:
--
I think having two HITS examples could be con
[
https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15579877#comment-15579877
]
Vasia Kalavri commented on FLINK-1091:
--
Hi [~neelesh77],
I'm not working on this. I'v
[
https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1091:
-
Assignee: (was: Vasia Kalavri)
> Allow joins with the solution set using key selectors
> -
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4357.
Resolution: Fixed
Done via FLINK-4360
> Implement TaskManager side of slot allocation from Resource
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4357:
Assignee: Till Rohrmann (was: Zhijiang Wang)
> Implement TaskManager side of slot allocati
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4358.
Resolution: Fixed
Done via FLINK-4738
> Implement TaskManager deployment task into slot
> -
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4360.
Resolution: Fixed
Added via 2486d3787b0d45a6220d3dcc96ca665986c47837
> Implement TaskManager regist
[
https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15579610#comment-15579610
]
ASF GitHub Bot commented on FLINK-4343:
---
Github user tillrohrmann closed the pull re
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2640
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature i
[
https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15579608#comment-15579608
]
ASF GitHub Bot commented on FLINK-4343:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2640
Failing test case is unrelated. Will merge the PR into the flip-6 branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
69 matches
Mail list logo
