[jira] [Created] (FLINK-4839) JobManager handle TaskManager's slot offering

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

[jira] [Commented] (FLINK-4838) remove STREAM keyword in StreamSQLExample

[ https://issues.apache.org/jira/browse/FLINK-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581206#comment-15581206 ] ASF GitHub Bot commented on FLINK-4838: --- GitHub user manuzhang opened a pull request:

[GitHub] flink pull request #2645: [FLINK-4838] remote STREAM keyword in StreamSQLExa...

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

[jira] [Created] (FLINK-4838) remove STREAM keyword in StreamSQLExample

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

[GitHub] flink pull request #2644: [FLINK-4837] flink-streaming-akka source connector

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

[jira] [Commented] (FLINK-4837) flink-streaming-akka source connector

[ https://issues.apache.org/jira/browse/FLINK-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581175#comment-15581175 ] ASF GitHub Bot commented on FLINK-4837: --- GitHub user sbcd90 opened a pull request:

[jira] [Created] (FLINK-4837) flink-streaming-akka source connector

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

[jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581104#comment-15581104 ] ASF GitHub Bot commented on FLINK-4723: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #2580: [FLINK-4723] [kafka-connector] Unify committed offsets to...

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

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581097#comment-15581097 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

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 @@ +/* + *

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581083#comment-15581083 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

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 @@

[jira] [Commented] (FLINK-4547) when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode

[ https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581039#comment-15581039 ] ASF GitHub Bot commented on FLINK-4547: --- Github user beyond1920 closed the pull request at:

[GitHub] flink pull request #2455: [FLINK-4547] [cluster management] when call connec...

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

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581018#comment-15581018 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a diff in the pull

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

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 @@

[jira] [Assigned] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

[ 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

[jira] [Assigned] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()

[ 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

[jira] [Closed] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock

[ 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

[GitHub] flink pull request #2604: [FLINK-4753] [kafka] PeriodicOffsetCommitter shoul...

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

[jira] [Commented] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock

[ https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580926#comment-15580926 ] ASF GitHub Bot commented on FLINK-4753: --- Github user tzulitai closed the pull request at:

[jira] [Commented] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock

[ https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580925#comment-15580925 ] ASF GitHub Bot commented on FLINK-4753: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-4652) Don't pass credentials explicitly to AmazonClient - use credentials provider instead

[ https://issues.apache.org/jira/browse/FLINK-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580923#comment-15580923 ] ASF GitHub Bot commented on FLINK-4652: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #2604: [FLINK-4753] [kafka] PeriodicOffsetCommitter should synch...

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

[GitHub] flink issue #2635: [FLINK-4652] [streaming connectors] Automatically refresh...

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

[jira] [Commented] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()

[ https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580919#comment-15580919 ] Ted Yu commented on FLINK-4659: --- Please go ahead. > Potential resource leak due to unclosed InputStream in

[GitHub] flink pull request #2643: [hotfix] Treat taskManager's rpc address and locat...

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

[jira] [Commented] (FLINK-3999) Rename the `running` flag in the drivers to `canceled`

[ https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580868#comment-15580868 ] ASF GitHub Bot commented on FLINK-3999: --- GitHub user nssalian opened a pull request:

[GitHub] flink pull request #2642: [FLINK-3999]: Rename the `running` flag in the dri...

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

[jira] [Commented] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()

[ https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580858#comment-15580858 ] Neelesh Srinivas Salian commented on FLINK-4659: I can work on this one [~tedyu], if no

[jira] [Commented] (FLINK-4792) Update documentation - FlinkML/QuickStart Guide

[ https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580842#comment-15580842 ] ASF GitHub Bot commented on FLINK-4792: --- GitHub user nssalian opened a pull request:

[GitHub] flink pull request #2641: [FLINK-4792] [Docs] Update documentation - FlinkML...

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

[jira] [Resolved] (FLINK-4351) JobManager handle TaskManager's registration

[ 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

[jira] [Resolved] (FLINK-4689) Implement a simple slot provider for the new job manager

[ 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

[jira] [Commented] (FLINK-4836) Implement Mini Cluster

[ https://issues.apache.org/jira/browse/FLINK-4836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580584#comment-15580584 ] Stephan Ewen commented on FLINK-4836: - Part one implemented in the flip-6 feature branch > Implement

[jira] [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 closed FLINK-4835. --- > Implement standalone High Availability Services > --- > >

[jira] [Resolved] (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

[jira] [Created] (FLINK-4836) Implement Mini Cluster

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

[jira] [Closed] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

[ 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 >

[jira] [Created] (FLINK-4835) Implement standalone High Availability Services

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:

[jira] [Updated] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

[ 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

[jira] [Created] (FLINK-4834) Implement unified High Availability Services Abstraction

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

[jira] [Resolved] (FLINK-2345) Zero Configuration Cluster Setup

[ 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 >

[jira] [Closed] (FLINK-2345) 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

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580345#comment-15580345 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

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

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580335#comment-15580335 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

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) +

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580160#comment-15580160 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on the issue:

[GitHub] flink issue #2518: [FLINK-3931] Implement Transport Encryption (SSL/TLS)

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

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15580157#comment-15580157 ] ASF GitHub Bot commented on FLINK-3931: --- Github user skrishnappa commented on a diff in the pull

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

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

[jira] [Assigned] (FLINK-4351) JobManager handle TaskManager's registration

[ 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 >

[jira] [Updated] (FLINK-4351) 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

[jira] [Updated] (FLINK-4351) 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: -- Description: was: 1. Receive slot offer from TaskExecutor， ack it or reject it 2. Release slot

[jira] [Commented] (FLINK-4129) HITSAlgorithm should test for element-wise convergence

[ https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15579933#comment-15579933 ] Vasia Kalavri commented on FLINK-4129: -- I think having two HITS examples could be confusing to users.

[jira] [Commented] (FLINK-1091) Allow joins with the solution set using key selectors

[ https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15579877#comment-15579877 ] Vasia Kalavri commented on FLINK-1091: -- Hi [~neelesh77], I'm not working on this. I've unassigned the

[jira] [Updated] (FLINK-1091) Allow joins with the solution set using key selectors

[ 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 >

[jira] [Closed] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager

[ 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

[jira] [Assigned] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager

[ 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

[jira] [Closed] (FLINK-4358) Implement TaskManager deployment task into slot

[ 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 >

[jira] [Closed] (FLINK-4360) Implement TaskManager registration slot at JobManager

[ 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

[jira] [Commented] (FLINK-4343) Implement new TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15579610#comment-15579610 ] ASF GitHub Bot commented on FLINK-4343: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink pull request #2640: [FLINK-4343] [tm] Implement TM -> JM registration ...

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

[jira] [Commented] (FLINK-4343) Implement new TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15579608#comment-15579608 ] ASF GitHub Bot commented on FLINK-4343: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2640: [FLINK-4343] [tm] Implement TM -> JM registration logic

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