Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3693#discussion_r110361292
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala
---
@@ -0,0 +1,117 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960614#comment-15960614
]
ASF GitHub Bot commented on FLINK-6257:
---
GitHub user sunjincheng121 opened a pull re
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3697
[FLINK-6257][table]Optimize test cases
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes
[
https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960585#comment-15960585
]
ASF GitHub Bot commented on FLINK-6090:
---
GitHub user hequn8128 opened a pull request
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/3696
[FLINK-6090] [table] Add RetractionRule at the stage of decoration
Add RetractionRules at the stage of decoration. These rules can derive
NeedRetraction property and accumulating mode. There are t
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960578#comment-15960578
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110358881
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -18,69 +18,51 @@
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960577#comment-15960577
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3524
@StephanEwen I have updated the PR, making the following changes:
1. Add a method called `discardSharedStatesOnFail()` in
`CompositeStateHandle`. This method is called when the pending checkp
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960575#comment-15960575
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960574#comment-15960574
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3495#discussion_r110357627
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigGroup.java ---
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Apache Software Founda
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3495#discussion_r110357533
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigOption.java ---
@@ -137,6 +153,28 @@ public boolean hasDeprecatedKeys() {
[
https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960572#comment-15960572
]
ASF GitHub Bot commented on FLINK-5545:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3695
Thanks @KurtYoung!
+1 to merge
---
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 a
[
https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960563#comment-15960563
]
ASF GitHub Bot commented on FLINK-5545:
---
GitHub user KurtYoung opened a pull request
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/3695
[FLINK-5545] [table] Remove FlinkAggregateExpandDistinctAggregatesRulâ¦
â¦e after bumping Calcite to v1.12.
You can merge this pull request into a Git repository by running:
$ git pull htt
[
https://issues.apache.org/jira/browse/FLINK-6278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey updated FLINK-6278:
--
Attachment: threaddump.txt
> After "FATAL" message in logs taskmanager still working
> -
Andrey created FLINK-6278:
-
Summary: After "FATAL" message in logs taskmanager still working
Key: FLINK-6278
URL: https://issues.apache.org/jira/browse/FLINK-6278
Project: Flink
Issue Type: Bug
A
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin reassigned FLINK-4604:
---
Assignee: Anton Mushin (was: Dmytro Shkvyra)
> Add support for standard deviation/variance
>
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmytro Shkvyra reassigned FLINK-4604:
-
Assignee: Dmytro Shkvyra (was: Anton Mushin)
> Add support for standard deviation/varian
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960516#comment-15960516
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user shaoxuan-wang commented on a di
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110345902
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -18,69 +18,51 @@
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960507#comment-15960507
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user shaoxuan-wang commented on a di
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110344806
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -403,6 +403,41 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960505#comment-15960505
]
hongyuhong commented on FLINK-6233:
---
Hi [~fhueske], the reason i think we need to keep t
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960493#comment-15960493
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960490#comment-15960490
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960495#comment-15960495
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960494#comment-15960494
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960492#comment-15960492
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110342700
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -792,6 +792,20 @@ object AggregateU
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960491#comment-15960491
]
ASF GitHub Bot commented on FLINK-6240:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110341342
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -18,69 +18,51 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110340880
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -403,6 +403,41 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110342899
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala
---
@@ -75,4 +75,13 @@ abstract cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110341810
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -18,69 +18,51 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110340764
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -403,6 +403,41 @@ class CodeGenerator(
Andrey created FLINK-6277:
-
Summary: RuntimeException in logs during normal shutdown
Key: FLINK-6277
URL: https://issues.apache.org/jira/browse/FLINK-6277
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960472#comment-15960472
]
ASF GitHub Bot commented on FLINK-6240:
---
GitHub user shaoxuan-wang opened a pull req
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3694
[FLINK-6240] [table] codeGen dataStream aggregates that use
AggregateAggFunction
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following che
[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960455#comment-15960455
]
ASF GitHub Bot commented on FLINK-6271:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3686#discussion_r110338259
--- Diff:
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java
---
@@ -162,11 +162,11 @@ public void
testJDB
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960451#comment-15960451
]
ASF GitHub Bot commented on FLINK-6012:
---
GitHub user haohui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960452#comment-15960452
]
ASF GitHub Bot commented on FLINK-6271:
---
Github user fpompermaier commented on a dif
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/3686#discussion_r110337693
--- Diff:
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java
---
@@ -162,11 +162,11 @@ public void
t
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3693
[FLINK-6012] [table] Support WindowStart / WindowEnd functions in streaming
SQL
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/haohui/flink FLI
[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960448#comment-15960448
]
ASF GitHub Bot commented on FLINK-6271:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6012:
--
Summary: Support WindowStart / WindowEnd functions in streaming SQL (was:
Support WindowStart / WindowE
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3686#discussion_r110337050
--- Diff:
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java
---
@@ -162,11 +162,11 @@ public void
testJDB
[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960447#comment-15960447
]
ASF GitHub Bot commented on FLINK-6271:
---
Github user zentol commented on a diff in t
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3686
The approach is good though, once we sort out the formatting we're good to
go imo.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960440#comment-15960440
]
ASF GitHub Bot commented on FLINK-6271:
---
Github user fpompermaier commented on the i
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/3686
Is it ok...? Could this be merged?
---
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
enab
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960438#comment-15960438
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3495
That's a neat idea to re-use them. Let's make this part of the PR though.
You aren't limited to flink-core, you just have to put the plugin into
other modules as well. You would have to to the
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960437#comment-15960437
]
Fabian Hueske commented on FLINK-6233:
--
Hi [~Yuhong_kyo],
a join does not give any g
[
https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960426#comment-15960426
]
Chesnay Schepler commented on FLINK-6276:
-
As far as i know the TypeHint must not
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960425#comment-15960425
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/3495
Ad second comment: My intention was to include the generated tables into
markdown using command like:
`{% include generated/high_availability_configuration.html %}`
This way it is possib
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960418#comment-15960418
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3495#discussion_r110332767
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigGroup.java ---
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960407#comment-15960407
]
Luke Hutchison commented on FLINK-6276:
---
[~Zentol] how does my code throw away more
[
https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960378#comment-15960378
]
Chesnay Schepler commented on FLINK-6276:
-
I believe the problem is the your gener
[
https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960378#comment-15960378
]
Chesnay Schepler edited comment on FLINK-6276 at 4/7/17 7:01 AM:
---
101 - 165 of 165 matches
Mail list logo
