[GitHub] flink pull request #2261: [FLINK-4226] Typo: Define Keys using Field Express...

GitHub user ASRagab opened a pull request: https://github.com/apache/flink/pull/2261 [FLINK-4226] Typo: Define Keys using Field Expressions example should use window and not reduce You can merge this pull request into a Git repository by running: $ git pull https://github.co

[jira] [Commented] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce

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

[jira] [Created] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce

Ahmad Ragab created FLINK-4226: -- Summary: Typo: Define Keys using Field Expressions example should use window and not reduce Key: FLINK-4226 URL: https://issues.apache.org/jira/browse/FLINK-4226 Project:

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380873#comment-15380873 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- Thanks for the valuable fee

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380840#comment-15380840 ] ASF GitHub Bot commented on FLINK-4222: --- Github user chadnickbok commented on the is

[GitHub] flink issue #2260: [FLINK-4222] Allow Kinesis configuration to get credentia...

Github user chadnickbok commented on the issue: https://github.com/apache/flink/pull/2260 We haven't yet tested this - I was getting a head-start on opening the pull request because I didn't realize you'd be so responsive! Plan is to migrate some code over to the latest master

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user chadnickbok commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71068329 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java --- @@ -50,8 +

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380839#comment-15380839 ] ASF GitHub Bot commented on FLINK-4222: --- Github user chadnickbok commented on a diff

[jira] [Created] (FLINK-4225) ML On Streaming Operating in Continuous and Micro Backed Mode

Suminda Dharmasena created FLINK-4225: - Summary: ML On Streaming Operating in Continuous and Micro Backed Mode Key: FLINK-4225 URL: https://issues.apache.org/jira/browse/FLINK-4225 Project: Flink

[jira] [Updated] (FLINK-4224) Exception after successful execution os job submitted through the web interface.

[ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4224: -- Description: When submitting the job below through the web interface to a local flink cluster:

[jira] [Updated] (FLINK-4224) Exception after successful execution os job submitted through the web interface.

[ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4224: -- Summary: Exception after successful execution os job submitted through the web interface. (was:

[jira] [Updated] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

[ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4224: -- Description: When submitting the job below through the web interface to a local flink cluster:

[jira] [Updated] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

[ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4224: -- Description: When submitting the job below through the web interface to a local flink cluster:

[jira] [Updated] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

[ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4224: -- Description: When submitting the job below through the web interface to a local flink cluster:

[jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

Kostas Kloudas created FLINK-4224: - Summary: Exception after successful execution when submitting job through the web interface. Key: FLINK-4224 URL: https://issues.apache.org/jira/browse/FLINK-4224 P

[jira] [Commented] (FLINK-1267) Add crossGroup operator

[ https://issues.apache.org/jira/browse/FLINK-1267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380688#comment-15380688 ] Greg Hogan commented on FLINK-1267: --- I will work on writing a FLIP for this feature. >

[jira] [Closed] (FLINK-3910) New self-join operator

[ https://issues.apache.org/jira/browse/FLINK-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3910. - Resolution: Duplicate > New self-join operator > -- > > Key: FLINK-391

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[GitHub] flink issue #2233: [FLINK-2125][streaming] Delimiter change from char to str...

Github user delding commented on the issue: https://github.com/apache/flink/pull/2233 Hi, I have updated the PR as @StephanEwen suggested, adding two new methods named socketTextStream that take string delimiter as parameter and delegating the old method to the new one --- If your p

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

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

[GitHub] flink issue #2260: [FLINK-4222] Allow Kinesis configuration to get credentia...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2260 @chadnickbok Thank you very much for opening a PR for this, I think this is definitely a good add to the connector's config options. Have you tested this new credential option in a AWS insta

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380587#comment-15380587 ] ASF GitHub Bot commented on FLINK-4222: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71062495 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java --- @@ -50,8 +50,

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380586#comment-15380586 ] ASF GitHub Bot commented on FLINK-4222: --- Github user chadnickbok commented on a diff

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user chadnickbok commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71062411 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java ---

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380582#comment-15380582 ] ASF GitHub Bot commented on FLINK-4222: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user chadnickbok commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71062384 --- Diff: docs/apis/streaming/connectors/kinesis.md --- @@ -26,7 +26,7 @@ specific language governing permissions and limitations under the License.

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380583#comment-15380583 ] ASF GitHub Bot commented on FLINK-4222: --- Github user chadnickbok commented on a diff

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71062382 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java ---

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380580#comment-15380580 ] ASF GitHub Bot commented on FLINK-4222: --- Github user chadnickbok commented on a diff

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user chadnickbok commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71062357 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java --- @@ -50,8 +

[jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380576#comment-15380576 ] ASF GitHub Bot commented on FLINK-4222: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2260#discussion_r71062324 --- Diff: docs/apis/streaming/connectors/kinesis.md --- @@ -26,7 +26,7 @@ specific language governing permissions and limitations under the License.