[GitHub] flink pull request #3627: Release 0.4 alpha.0

GitHub user fisherbj opened a pull request: https://github.com/apache/flink/pull/3627 Release 0.4 alpha.0 Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items

[jira] [Assigned] (FLINK-6201) move python example files from resources to the examples

[ https://issues.apache.org/jira/browse/FLINK-6201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui reassigned FLINK-6201: Assignee: shijinkui > move python example files from resources to the examples >

[jira] [Updated] (FLINK-6201) move python example files from resources to the examples

[ https://issues.apache.org/jira/browse/FLINK-6201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-6201: - Priority: Trivial (was: Major) > move python example files from resources to the examples >

[jira] [Updated] (FLINK-6201) move python example files from resources to the examples

[ https://issues.apache.org/jira/browse/FLINK-6201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-6201: - Summary: move python example files from resources to the examples (was: move python example files to the

[jira] [Created] (FLINK-6201) move python example files to the examples dir

shijinkui created FLINK-6201: Summary: move python example files to the examples dir Key: FLINK-6201 URL: https://issues.apache.org/jira/browse/FLINK-6201 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-5498) Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944427#comment-15944427 ] lincoln.lee edited comment on FLINK-5498 at 3/28/17 2:41 AM: - Yes, it's a good

[jira] [Commented] (FLINK-5498) Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944427#comment-15944427 ] lincoln.lee commented on FLINK-5498: Yes, it's a good idea using two {code}Row{code} fields in a

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r108320480 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -86,12 +90,79 @@ abstract class

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r108320419 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala --- @@ -27,52 +27,73 @@ import

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r108319900 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala --- @@ -27,52 +27,73 @@ import

[jira] [Commented] (FLINK-6192) reuse zookeeer client created by CuratorFramework

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

[GitHub] flink issue #3617: [FLINK-6192]reuse zookeeper client created by CuratorFram...

Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3617 Glad we have same idea :) @tillrohrmann I'll mark the JIRA duplicated now and close this PR as soon as you open the new one. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r108318532 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -131,8 +202,10 @@ abstract class

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r108318419 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -86,12 +90,79 @@ abstract class

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r108318278 --- Diff: flink-core/src/test/java/org/apache/flink/types/RowTest.java --- @@ -21,6 +21,7 @@ import org.junit.Test; import static

[jira] [Updated] (FLINK-6200) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6200: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-4557 > Add event time OVER RANGE

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r108314395 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala --- @@ -112,7

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

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

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

[ https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944327#comment-15944327 ] Guowei Ma commented on FLINK-5892: -- hi [~Zentol] I am discussing the proposal with [~srichter]. I think I

[jira] [Created] (FLINK-6200) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

sunjincheng created FLINK-6200: -- Summary: Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-6200 URL: https://issues.apache.org/jira/browse/FLINK-6200 Project: Flink

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944049#comment-15944049 ] Fabian Hueske commented on FLINK-5829: -- I just had a chat with [~wheat9] and we came to the

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943960#comment-15943960 ] Fabian Hueske commented on FLINK-5829: -- I think we could implement our own internal default schema

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943938#comment-15943938 ] Haohui Mai commented on FLINK-5829: --- Unfortunately it seems that it is infeasible to inherit and forward

[jira] [Commented] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

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

[GitHub] flink issue #3598: [FLINK-6103] LocalFileSystem rename() uses File.renameTo(...

Github user fpompermaier commented on the issue: https://github.com/apache/flink/pull/3598 Does the current exception handling address your comments @StephanEwen? --- 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

[jira] [Updated] (FLINK-6196) Support dynamic schema in Table Function

[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6196: -- Component/s: Table API & SQL > Support dynamic schema in Table Function >

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

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

[GitHub] flink issue #3607: [FLINK-5654] - Add processing time OVER RANGE BETWEEN x P...

Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3607 @sunjincheng121 @fhueske @stefanobortoli I rebased and created the tests. Please have a look --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Created] (FLINK-6199) Single outstanding Async I/O operation per key

Jamie Grier created FLINK-6199: -- Summary: Single outstanding Async I/O operation per key Key: FLINK-6199 URL: https://issues.apache.org/jira/browse/FLINK-6199 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

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

[GitHub] flink issue #3625: [FLINK-5785] Add an Imputer for preparing data

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3625 Regarding the license: Every (non-binary) file in the flink repository must have the apache license at the very top of the file. Simply take a look at an existing scala class and you'll see what i

[jira] [Updated] (FLINK-5913) Example drivers

[ https://issues.apache.org/jira/browse/FLINK-5913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5913: -- Description: Replace existing and create new algorithm {{Driver}} implementations for each of the

[jira] [Commented] (FLINK-5912) Inputs for CSV and graph generators

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

[GitHub] flink pull request #3626: [FLINK-5912] [gelly] Inputs for CSV and graph gene...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3626 [FLINK-5912] [gelly] Inputs for CSV and graph generators Create Input classes for reading graphs from CSV as well as for each of the graph generators. Inputs are tested in driver

[jira] [Commented] (FLINK-6192) reuse zookeeer client created by CuratorFramework

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

[GitHub] flink issue #3617: [FLINK-6192]reuse zookeeper client created by CuratorFram...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3617 Thanks for your contribution @WangTaoTheTonic. Your observation of the problem is correct. Actually I'm also working on refactoring the usage of the ZooKeeper based leader election

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

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

[GitHub] flink pull request #3625: [FLINK-5785] Add an Imputer for preparing data

GitHub user p4nna opened a pull request: https://github.com/apache/flink/pull/3625 [FLINK-5785] Add an Imputer for preparing data Provides an Imputer for sparse DataSets of Vectors. Adds missing values with the mean, median or most frequent value of each vector resp. dimension

[GitHub] flink pull request #3620: [FLINK-5785] Add an Imputer for preparing data

Github user p4nna closed the pull request at: https://github.com/apache/flink/pull/3620 --- 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-5785) Add an Imputer for preparing data

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

[GitHub] flink issue #3620: [FLINK-5785] Add an Imputer for preparing data

Github user p4nna commented on the issue: https://github.com/apache/flink/pull/3620 What does that mean and how could I fix it? --- 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-5785) Add an Imputer for preparing data

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

[jira] [Created] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

Kostas Kloudas created FLINK-6198: - Summary: Update the documentation of the CEP library to include all the new features. Key: FLINK-6198 URL: https://issues.apache.org/jira/browse/FLINK-6198

[jira] [Commented] (FLINK-6197) Add support for iterative conditions.

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

[GitHub] flink pull request #3624: [FLINK-6197] [cep] Add support for iterative condi...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/3624 [FLINK-6197] [cep] Add support for iterative conditions. So far, the where clause only supported simple FilterFunction conditions. With this, we add support for conditions where an event is

[jira] [Created] (FLINK-6197) Add support for iterative conditions.

Kostas Kloudas created FLINK-6197: - Summary: Add support for iterative conditions. Key: FLINK-6197 URL: https://issues.apache.org/jira/browse/FLINK-6197 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

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

[GitHub] flink issue #3620: [FLINK-5785] Add an Imputer for preparing data

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3620 It appears that all files are lacking the apache license: `Too many files with unapproved license: 4 See RAT report in: /home/travis/build/apache/flink/target/rat.txt` --- If your project

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

GitHub user clarkyzl opened a pull request: https://github.com/apache/flink/pull/3623 [FLINK-6196] [table] Support dynamic schema in Table Function Type: Improvement Priority: Major Components: table, udtf Problem Definition: Support dynamic schema in Table Function

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943360#comment-15943360 ] Wei-Che Wei commented on FLINK-5982: Hi [~till.rohrmann], I prefer not to pass only {{Environment}}

[jira] [Commented] (FLINK-6136) Separate EmbeddedNonHaServices and NonHaServices

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

[GitHub] flink pull request #3622: [FLINK-6136] Separate EmbeddedHaServices and Stand...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3622 [FLINK-6136] Separate EmbeddedHaServices and StandaloneHaServices This PR introduces a standalone high availability services implementation which can be used in a distributed setting with

[jira] [Created] (FLINK-6196) Support dynamic schema in Table Function

Zhuoluo Yang created FLINK-6196: --- Summary: Support dynamic schema in Table Function Key: FLINK-6196 URL: https://issues.apache.org/jira/browse/FLINK-6196 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error

[ https://issues.apache.org/jira/browse/FLINK-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6169. --- Resolution: Not A Problem > yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error >

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

Github user senorcarbone commented on the issue: https://github.com/apache/flink/pull/1668 sweet! thanks @StefanRRichter --- 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-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/1668 For raw operator state, override `AbstractStreamOperator::snapshotState(StateSnapshotContext context)` inside your operator. Your implementation calls to super, then it can obtain the raw

[jira] [Commented] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error

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

[GitHub] flink pull request #3608: FLINK-6169 yarnClient should be stopped in Abstrac...

Github user tedyu closed the pull request at: https://github.com/apache/flink/pull/3608 --- 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-6043) Display time when exceptions/root cause of failure happened

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

[GitHub] flink issue #3583: [FLINK-6043] [web] Display exception timestamp

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3583 Of course it wouldn't be the end of the world to display an inconsistent timestamp, it just doesn't make sense for them to be different though. The root exception display is only meant to highlight

[jira] [Updated] (FLINK-6195) Move gelly-examples jar from opt to examples

[ https://issues.apache.org/jira/browse/FLINK-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6195: -- Component/s: (was: Gelly) Build System > Move gelly-examples jar from opt to

[jira] [Commented] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

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

[GitHub] flink pull request #3601: [WIP [FLINK-6042] [web] Display exception history

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3601 --- 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-5982) Refactor AbstractInvokable and StatefulTask

[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943286#comment-15943286 ] Stephan Ewen commented on FLINK-5982: - I think that is actually simpler to shoot yourself in the foot

[jira] [Created] (FLINK-6195) Move gelly-examples jar from opt to examples

Greg Hogan created FLINK-6195: - Summary: Move gelly-examples jar from opt to examples Key: FLINK-6195 URL: https://issues.apache.org/jira/browse/FLINK-6195 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943273#comment-15943273 ] Till Rohrmann commented on FLINK-5982: -- True, we can also throw an {{IllegalStateException}}. I was

[jira] [Commented] (FLINK-6043) Display time when exceptions/root cause of failure happened

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

[GitHub] flink issue #3583: [FLINK-6043] [web] Display exception timestamp

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3583 It's inconsistent, that's all I'm saying. Passing an ErrorInfo instead of a Throwable is also useful (probably even required) for FLINK-6042 since it allows us to attach meta data to the

[jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-3320: --- Assignee: Dawid Wysakowicz > Add not operator to CEP's pattern API >

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943257#comment-15943257 ] Fabian Hueske commented on FLINK-6082: -- I think the semantics of the query in the example are not

[jira] [Commented] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error

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

[GitHub] flink pull request #3608: FLINK-6169 yarnClient should be stopped in Abstrac...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3608#discussion_r108166257 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -507,12 +507,14 @@ protected YarnClusterClient

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[GitHub] flink pull request #1668: [FLINK-3257] Add Exactly-Once Processing Guarantee...

Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/1668#discussion_r108166093 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java --- @@ -17,100 +17,164 @@

[GitHub] flink issue #3583: [FLINK-6043] [web] Display exception timestamp

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3583 Wouldn't it be ok, if the timestamps differed slightly? I mean the EG root cause timestamp is the time when the EG was failed, whereas the `Execution` related timestamp says when the failure at

[jira] [Commented] (FLINK-6043) Display time when exceptions/root cause of failure happened

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

[jira] [Commented] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943234#comment-15943234 ] Till Rohrmann commented on FLINK-1750: -- Alright. Thanks for letting me know :-) > Add canonical

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

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

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3001 Hi @tzulitai Ok, I see. Thanks for your reminder. =) --- 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

[GitHub] flink pull request #3620: [FLINK-5785] Add an Imputer for preparing data

GitHub user p4nna opened a pull request: https://github.com/apache/flink/pull/3620 [FLINK-5785] Add an Imputer for preparing data Provides an imputer method which adds missing values to a sparse DataSet of vectors. Those can be filled with the mean, the median or the most frequent

[jira] [Commented] (FLINK-6165) Implement internal continuity for looping states.

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

[GitHub] flink pull request #3621: [FLINK-6165] [cep] Implement internal continuity f...

GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3621 [FLINK-6165] [cep] Implement internal continuity for looping states. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943222#comment-15943222 ] Anna Beer commented on FLINK-5785: -- [~Zentol] Thank you for the detailed description, hope I've done it

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

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

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943212#comment-15943212 ] Stephan Ewen commented on FLINK-4319: - Flink on Kubernetes works today already. We need FLIP-6 only

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3001 Hi @tony810430! Sorry for the long pause on this PR. After some back and forth offline discussions with others on how exactly we want to proceed with this, we decided to stick with using

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943198#comment-15943198 ] shijinkui commented on FLINK-4319: -- Flink on Kubernetes, do we have some schedule? > Rework Cluster

[jira] [Commented] (FLINK-6141) Add buffering service for stream operators

[ https://issues.apache.org/jira/browse/FLINK-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943182#comment-15943182 ] Stephan Ewen commented on FLINK-6141: - I don't think I have capacity to help out here before the 1.3

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943184#comment-15943184 ] Chesnay Schepler commented on FLINK-5785: - [~beera] You've opened the PR against your own fork of

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

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

[jira] [Commented] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

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

  1   2   >