[
https://issues.apache.org/jira/browse/FLINK-2930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984849#comment-14984849
]
ASF GitHub Bot commented on FLINK-2930:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1304#issuecomment-152944847
This looks like a pretty big issue, actually.
+1 to merge this.
Might not be a release blocker, but if there is another RC, I would add
this.
---
If yo
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1305#issuecomment-152944197
Good stuff! Will need a day more to look through this, but this is a cool
way of doing stateful stream computation :-)
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984845#comment-14984845
]
ASF GitHub Bot commented on FLINK-2939:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1313#issuecomment-152943948
This goes a bit against the idea of REST. If you "GET" a certain URL, it
should not affect the state of the system you query.
If we want to make that action
Chengxiang Li created FLINK-2951:
Summary: Add Union operator to Table API.
Key: FLINK-2951
URL: https://issues.apache.org/jira/browse/FLINK-2951
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984810#comment-14984810
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on a d
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1214#discussion_r43600897
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java
---
@@ -36,28 +31,16 @@
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984807#comment-14984807
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-152934449
@mxm, since you already delegated job graph creation to the Client in one
of your commits, I've removed that from my commits. Rebasing required squashing
all comm
[
https://issues.apache.org/jira/browse/FLINK-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984741#comment-14984741
]
Stephan Ewen commented on FLINK-2929:
-
I think not purging on start is a good idea for
[
https://issues.apache.org/jira/browse/FLINK-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984707#comment-14984707
]
ASF GitHub Bot commented on FLINK-2939:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1313#issuecomment-152904731
Hovering over the cross reveals the word cancel.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984605#comment-14984605
]
Till Rohrmann commented on FLINK-2929:
--
I'm wondering how often it's the case that so
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984602#comment-14984602
]
ASF GitHub Bot commented on FLINK-2828:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1237#discussion_r43590351
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/FieldBacktracker.scala
---
@@ -0,0 +1,75 @@
+/*
GitHub user frett27 opened a pull request:
https://github.com/apache/flink/pull/1314
move the #!bash to first line, otherwise it do not work
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/frett27/flink patch-1
Alternatively you
[
https://issues.apache.org/jira/browse/FLINK-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984465#comment-14984465
]
ASF GitHub Bot commented on FLINK-2939:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1313#issuecomment-152847408
Thanks! Not sure users will see the "X" in the corner and understand it's
for cancelling jobs.
---
If your project is set up for it, you can reply to this email and have y
[
https://issues.apache.org/jira/browse/FLINK-2912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2912:
--
Description:
Here is related code in respondAsLeader():
{code}
final RandomAccessFile raf;
try {
r
[
https://issues.apache.org/jira/browse/FLINK-2913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2913:
--
Description:
{code}
ObjectOutputStream os = new ObjectOutputStream(outStream);
os.writeObject(state)
[
https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2914:
--
Description:
{code}
case CONNECTION_SUSPENDED:
LOG.warn("ZooKeeper connection SUSPENDED. Chang
[
https://issues.apache.org/jira/browse/FLINK-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984387#comment-14984387
]
ASF GitHub Bot commented on FLINK-2939:
---
GitHub user sachingoel0101 opened a pull re
GitHub user sachingoel0101 opened a pull request:
https://github.com/apache/flink/pull/1313
[FLINK-2939][web-dashboard] Add support to cancel jobs from the dashboard
Cancel button placement (open for discussion and/or any changes):
