[
https://issues.apache.org/jira/browse/FLINK-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jingzhang updated FLINK-6067:
-
Description:
{code}
val table1 = tEnv.scan( "tb1")
val table2 = tEnv.scan("tb2")
val result =
jingzhang created FLINK-6067:
Summary: ProjectNode and FilterNode cannot merge in Batch TableAPI
Key: FLINK-6067
URL: https://issues.apache.org/jira/browse/FLINK-6067
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927578#comment-15927578
]
fang yong commented on FLINK-6058:
--
Read default parallelism from ContextEnviroment sound
Kurt Young created FLINK-6066:
-
Summary: Separate logical and physical RelNode layer in Flink
Key: FLINK-6066
URL: https://issues.apache.org/jira/browse/FLINK-6066
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927556#comment-15927556
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927555#comment-15927555
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927551#comment-15927551
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927553#comment-15927553
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927552#comment-15927552
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927554#comment-15927554
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106344891
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106344518
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/BoundedProcessingOverWindowFunction.scala
---
@@ -0,0 +
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106344788
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106344697
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106344846
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106344831
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927543#comment-15927543
]
shijinkui commented on FLINK-5650:
--
[~Zentol], Your PR can work. flink-python UT cost one
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927536#comment-15927536
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106343179
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -130,32 +142,7
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927534#comment-15927534
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106343147
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -130,32 +142,7
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927530#comment-15927530
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106342776
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927520#comment-15927520
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3520
Hi @fhueske @godfreyhe, thanks for the review, i addressed most all your
comments.
@fhueske Except for letting `TableSourceScan` be aware of whether filter
has been pushed down. I'm not su
[
https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927494#comment-15927494
]
ASF GitHub Bot commented on FLINK-5978:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/3552
[FLINK-5978] Fix JM WebFrontend address ConfigOption is defined in Coâ¦
â¦nfigConstants
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the followi
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-5701.
Resolution: Fixed
Additionally fixed for 1.1.5 with
http://git-wip-us.apache.org/re
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927479#comment-15927479
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai closed the pull reques
Github user tzulitai closed the pull request at:
https://github.com/apache/flink/pull/3549
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927464#comment-15927464
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106336720
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -19,33 +19,124 @@ package or
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927457#comment-15927457
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106335718
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/FilterableTableSource.scala
---
@@ -0,0 +1,66 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927456#comment-15927456
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927453#comment-15927453
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106335709
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/RexProgramExtractor.scala
---
@@ -0,0 +1,184 @@
+/*
+ * Lice
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106335660
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/RexProgramExtractor.scala
---
@@ -0,0 +1,184 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927451#comment-15927451
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user WangTaoTheTonic commented on a
Github user WangTaoTheTonic commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r106335560
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CookieHandler.java
---
@@ -0,0 +1,130 @@
+/**
+ * Licensed t
Github user WangTaoTheTonic commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r106335331
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CookieHandler.java
---
@@ -0,0 +1,130 @@
+/**
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927446#comment-15927446
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user WangTaoTheTonic commented on a
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927442#comment-15927442
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106335062
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/rel/LogicalWindowAggregate.scala
---
@@ -18,8 +18,6 @@
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927441#comment-15927441
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3549
Thanks for the review!
Travis is green (local branch), with only test timeouts:
https://travis-ci.org/tzulitai/flink
Merging this ..
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-5048.
Resolution: Fixed
Fix Version/s: (was: 1.1.5)
> Kafka Consumer (0.9/0.10)
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927427#comment-15927427
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5048 at 3/16/17 3:43 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927427#comment-15927427
]
Tzu-Li (Gordon) Tai commented on FLINK-5048:
Agreed, let's resolve this issue
[
https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927411#comment-15927411
]
fang yong commented on FLINK-5978:
--
Hi Chesnay Schepler, glad to see an easy issue while
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106329219
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/PushFilterIntoBatchTableSourceScanRule.scala
---
@@ -0,0 +1
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106329225
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/PushFilterIntoStreamTableSourceScanRule.scala
---
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927379#comment-15927379
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106328751
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSourceTable.scala
---
@@ -25,6 +25,7 @@ import org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927380#comment-15927380
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106329099
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/RexProgramExtractor.scala
---
@@ -0,0 +1,184 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927377#comment-15927377
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927378#comment-15927378
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106329079
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/PushFilterIntoTableSourceScanRuleBase.scala
---
@@ -0,0 +1,9
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5650:
-
Labels: osx (was: )
> Flink-python tests executing cost too long time
> -
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927371#comment-15927371
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927368#comment-15927368
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user WangTaoTheTonic commented on th
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3486
Since not merged, I've turned them around. Sorry for the carelessness :(
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927355#comment-15927355
]
ASF GitHub Bot commented on FLINK-5498:
---
Github user lincoln-lil commented on the is
Github user lincoln-lil commented on the issue:
https://github.com/apache/flink/pull/3379
Part of integration tests will occasionally fail when submit this pr, and
I configured Travis CI for my repository then got a whole pass. see
https://travis-ci.org/lincoln-lil/flink/builds/2088
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927353#comment-15927353
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106327707
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/PushFilterIntoTableSourceScanRuleBase.scala
---
@@ -0,0 +1,9
[
https://issues.apache.org/jira/browse/FLINK-5883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927325#comment-15927325
]
ASF GitHub Bot commented on FLINK-5883:
---
Github user lincoln-lil commented on the is
Github user lincoln-lil commented on the issue:
https://github.com/apache/flink/pull/3392
Appreciated if someone can merge this pr
---
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
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927322#comment-15927322
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user hongyuhong commented on a diff
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106324953
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927319#comment-15927319
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927318#comment-15927318
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106324883
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/BatchTableSourceScan.scala
---
@@ -58,16 +60,24 @@ class Ba
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106324868
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -39,4 +39,6 @@ trait TableSource[T] {
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927308#comment-15927308
]
Bill Liu commented on FLINK-5668:
-
it still doesn't solve my problem. I want to start Flin
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927296#comment-15927296
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user zhijiangW commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927295#comment-15927295
]
ASF GitHub Bot commented on FLINK-5865:
---
Github user shixiaogang commented on the is
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3151
@tillrohrmann , just remind to review my modifications for your free time,
because this would block my next pull request of heartbeat between
`TaskManager` and `ResourceManager`. Thank you!
---
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3380
I prefer to throw more detailed exceptions e.g.
`IncompatibleTypeSerializerException`, `StateAccessException` and
`StateNotFoundException`. They all are extended from `FlinkRuntimeException`.
U
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106322568
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala
---
@@ -42,63 +41,40 @@ class DataSetCalc
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927290#comment-15927290
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927277#comment-15927277
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106321885
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/ProjectableTableSource.scala
---
@@ -24,7 +24,7 @@ package org.apache.
[
https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison closed FLINK-6026.
-
Resolution: Not A Bug
> Return type of flatMap with lambda function not correctly resolved
> -
[
https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927065#comment-15927065
]
Luke Hutchison commented on FLINK-6026:
---
Makes sense. I was wondering if there was s
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927063#comment-15927063
]
Ivan Mushketyk commented on FLINK-3414:
---
Hi [~dawidwys]
I don't have time to work o
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3414:
-
Assignee: Dawid Wysakowicz (was: Ivan Mushketyk)
> Add Scala API for CEP's pattern defin
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3523
Can we slightly adapt the test to target more the typical use case:
- Original job has some stateless ops (no uid), and some stateful ones
(with uid)
- Create a modified job that has t
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926831#comment-15926831
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926820#comment-15926820
]
Robert Metzger commented on FLINK-5048:
---
I'm not aware of any user on 1.1 affected b
[
https://issues.apache.org/jira/browse/FLINK-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926812#comment-15926812
]
Stephan Ewen commented on FLINK-5962:
-
Fixed in 1.2 via 9d59e008d8849cdfe2daf302e25145
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/0a501e9f7f56baba2905002b74746998458db007#commitcomment-21337504
In
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java:
In
[
https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926785#comment-15926785
]
Stephan Ewen commented on FLINK-6044:
-
The {{read()}} / {{readFully()}} issue has occu
[
https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926779#comment-15926779
]
Stephan Ewen commented on FLINK-6044:
-
[~srichter] I think we should try and safeguard
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926772#comment-15926772
]
ASF GitHub Bot commented on FLINK-6018:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3534
This change may alter the format of savepoints, because it now forwards
type-registrations to the Kryo serializer, which it did not do before.
Since we announced savepoint compatibility,
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926770#comment-15926770
]
ASF GitHub Bot commented on FLINK-6018:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3534
There is also another method in `AbstractKeyedStateBackend`:
`getOrCreateKeyedState` which does not silently use an empty `ExecutionConfig`
but throws an exception. That method could also use the
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926768#comment-15926768
]
ASF GitHub Bot commented on FLINK-6018:
---
Github user StephanEwen commented on the is
1 - 100 of 535 matches
Mail list logo
