[jira] [Commented] (FLINK-4047) Fix documentation about determinism of KeySelectors

[ https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391342#comment-15391342 ] Neelesh Srinivas Salian commented on FLINK-4047: Hi [~fhueske], could I work on this JIRA?

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391343#comment-15391343 ] Neelesh Srinivas Salian commented on FLINK-2032: Hi, [~fhueske], checking if this issue is

[jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files.

[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391284#comment-15391284 ] Neelesh Srinivas Salian commented on FLINK-992: --- Shall I begin to work on this if no one else

[jira] [Commented] (FLINK-2042) Increase font size for stack figure on website home

[ https://issues.apache.org/jira/browse/FLINK-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391283#comment-15391283 ] Neelesh Srinivas Salian commented on FLINK-2042: Hi [~StephanEwen], is this still needed

[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=15391282#comment-15391282 ] ASF GitHub Bot commented on FLINK-4226: --- Github user nssalian commented on the issue:

[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=15391281#comment-15391281 ] ASF GitHub Bot commented on FLINK-4226: --- Github user nssalian closed the pull request at:

[GitHub] flink issue #2291: [FLINK-4226] Typo: Define Keys using Field Expressions ex...

Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2291 Thanks @gallenvara. I'll close in favor of #2261 --- 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

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

Github user nssalian closed the pull request at: https://github.com/apache/flink/pull/2291 --- 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-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=15391269#comment-15391269 ] ASF GitHub Bot commented on FLINK-4226: --- Github user gallenvara commented on the issue:

[GitHub] flink issue #2291: [FLINK-4226] Typo: Define Keys using Field Expressions ex...

Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2291 Hi @nssalian , welcome to join the community. :) This PR may be duplicate to [#2261](https://github.com/apache/flink/pull/2261) for the same issue. --- If your project is set up for it,

[jira] [Commented] (FLINK-4180) Create a batch SQL example

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

[GitHub] flink issue #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL and Strea...

Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2274 LGTM after the nits. But I would request someone else have a pass over it before moving forward since I am new to the code. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-4180) Create a batch SQL example

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

[jira] [Commented] (FLINK-4180) Create a batch SQL example

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

[GitHub] flink pull request #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL an...

Github user nssalian commented on a diff in the pull request: https://github.com/apache/flink/pull/2274#discussion_r71998373 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamTableExample.scala --- @@ -0,0 +1,56 @@ +/* + * Licensed

[GitHub] flink pull request #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL an...

Github user nssalian commented on a diff in the pull request: https://github.com/apache/flink/pull/2274#discussion_r71998370 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/StreamSQLExample.scala --- @@ -0,0 +1,60 @@ +/* + * Licensed

[jira] [Commented] (FLINK-4180) Create a batch SQL example

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

[GitHub] flink pull request #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL an...

Github user nssalian commented on a diff in the pull request: https://github.com/apache/flink/pull/2274#discussion_r71998367 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/examples/java/JavaSQLExample.java --- @@ -0,0 +1,70 @@ +/* + * Licensed to the

[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=15391200#comment-15391200 ] Neelesh Srinivas Salian commented on FLINK-4226: Put in a fix. Requesting review. > Typo:

[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=15391196#comment-15391196 ] ASF GitHub Bot commented on FLINK-4226: --- GitHub user nssalian opened a pull request:

[GitHub] flink pull request #2291: FLINK-4226: Define Keys using Field Expressions ex...

GitHub user nssalian opened a pull request: https://github.com/apache/flink/pull/2291 FLINK-4226: Define Keys using Field Expressions example should use wi… Description: val wordCounts = words.keyBy("word").reduce(/*window specification*/) Should be: val wordCounts =

[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=15391103#comment-15391103 ] ramkrishna.s.vasudevan commented on FLINK-3397: --- [~uce] bq.I fear though that these changes

[jira] [Commented] (FLINK-4180) Create a batch SQL example

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

[GitHub] flink issue #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL and Strea...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2274 @smarthi Thanks for reviewing. I have addressed the typo. --- 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