Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2112
-1. I haven't looked very deeply at the actual code but let me share some
thoughts:
I was under the impression that the core of this issue was to implement at
least 1 Histogram that does not
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333578#comment-15333578
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-3231:
---
Fix Version/s: 1.1.0
> Handle Kinesis-side resharding in Kinesis streaming consumer
>
[
https://issues.apache.org/jira/browse/FLINK-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4020:
---
Fix Version/s: 1.1.0
> Remove shard list querying from Kinesis consumer constructor
>
[
https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4018:
---
Fix Version/s: 1.1.0
> Configurable idle time between getRecords requests to Kinesis s
[
https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-4040:
--
Fix Version/s: 1.1.0
> Same env.java.opts is applied for TM , JM and ZK
> --
[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4019:
---
Fix Version/s: 1.1.0
> Expose approximateArrivalTimestamp through the KinesisDeseriali
[
https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-4038:
--
Fix Version/s: 1.1.0
> Impossible to set more than 1 JVM argument in env.java.opts
> ---
[
https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-4039:
--
Fix Version/s: 1.1.0
> G1 garbage collector only set if no custom jvm arguments
> --
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333658#comment-15333658
]
Robert Metzger commented on FLINK-4021:
---
[~uce], is this an issue that should go int
[
https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333671#comment-15333671
]
Robert Metzger commented on FLINK-2155:
---
I'm removing the target 1.1. release for th
[
https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2155:
--
Fix Version/s: (was: 1.1.0)
> Add an additional checkstyle validation for illegal imports
>
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2821:
--
Fix Version/s: (was: 1.1.0)
> Change Akka configuration to allow accessing actors from diffe
[
https://issues.apache.org/jira/browse/FLINK-3588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3588:
--
Fix Version/s: (was: 1.1.0)
> Add a streaming (exactly-once) JDBC connector
> --
[
https://issues.apache.org/jira/browse/FLINK-3588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3588:
--
Issue Type: New Feature (was: Improvement)
> Add a streaming (exactly-once) JDBC connector
> --
[
https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2917:
--
Fix Version/s: (was: 1.1.0)
> Make non-copying behaviour default for stream operator
> -
[
https://issues.apache.org/jira/browse/FLINK-3662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3662:
--
Fix Version/s: (was: 1.1.0)
> Bump Akka version to 2.4.x for Scala 2.11.x
>
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3674:
--
Fix Version/s: (was: 1.1.0)
> Add an interface for EventTime aware User Function
> -
[
https://issues.apache.org/jira/browse/FLINK-3661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3661:
--
Fix Version/s: (was: 1.1.0)
> Make Scala 2.11.x the default Scala version
>
[
https://issues.apache.org/jira/browse/FLINK-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3720:
--
Fix Version/s: (was: 1.1.0)
> Add warm starts for models
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333677#comment-15333677
]
Robert Metzger commented on FLINK-3827:
---
[~till.rohrmann] What's the status here. Do
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3864:
--
Component/s: YARN Client
> Yarn tests don't check for prohibited strings in log output
> ---
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333680#comment-15333680
]
Robert Metzger commented on FLINK-3864:
---
Have you started working on this?
Will this
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4021:
---
Fix Version/s: (was: 1.1.0)
> Problem of setting autoread for netty channel when more tasks sharin
[
https://issues.apache.org/jira/browse/FLINK-3894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3894:
--
Fix Version/s: (was: 1.1.0)
> Remove Program Packaging via Plans
> -
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333683#comment-15333683
]
Ufuk Celebi commented on FLINK-4021:
No, cleared the fix version.
> Problem of settin
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3871:
--
Fix Version/s: (was: 1.1.0)
> Add Kafka TableSource with Avro serialization
> --
[
https://issues.apache.org/jira/browse/FLINK-3895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3895:
--
Fix Version/s: (was: 1.1.0)
> Remove Docs for Program Packaging via Plans
>
Aljoscha Krettek created FLINK-4082:
---
Summary: Add Setting for LargeRecordHandler
Key: FLINK-4082
URL: https://issues.apache.org/jira/browse/FLINK-4082
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3933.
---
Resolution: Fixed
This has been merged in
https://github.com/apache/flink/commit/92e1c82cc545
[
https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3933:
--
Component/s: Streaming Connectors
> Add an auto-type-extracting DeserializationSchema
>
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333692#comment-15333692
]
Robert Metzger commented on FLINK-3950:
---
[~Zentol] is this in the scope of the 1.1 r
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2113
[FLINK-4082] Add Setting for enabling/disabling LargeRecordHandler
By default this is set to disabled because there are known issues when
users specify a custom TypeInformation.
R: @til
[
https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333700#comment-15333700
]
Robert Metzger commented on FLINK-3395:
---
The PR opened by Stephan has the wrong issu
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2112
We decided to add the histogram metric, because users requested this
feature. The important thing is that the histograms are not used by the runtime
per default, because they indeed don't come f
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333703#comment-15333703
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333702#comment-15333702
]
ASF GitHub Bot commented on FLINK-4082:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333701#comment-15333701
]
Robert Metzger commented on FLINK-3995:
---
There is a pull request for this one, with
[
https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333705#comment-15333705
]
Robert Metzger commented on FLINK-4009:
---
Do we want to include this into the 1.1. re
[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333708#comment-15333708
]
Robert Metzger commented on FLINK-4019:
---
I think its okay to keep these two things s
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3874:
--
Fix Version/s: (was: 1.1.0)
> Add a Kafka TableSink with JSON serialization
> --
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3873:
--
Fix Version/s: (was: 1.1.0)
> Add a Kafka TableSink with Avro serialization
> --
[
https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3875:
--
Fix Version/s: (was: 1.1.0)
> Add a TableSink for Elasticsearch
> --
[
https://issues.apache.org/jira/browse/FLINK-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333712#comment-15333712
]
Robert Metzger commented on FLINK-3890:
---
This will be addressed by https://github.co
GitHub user thormanrd opened a pull request:
https://github.com/apache/flink/pull/2114
FLINT-3839 Added the extraction of jar files from a URL spec that is â¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consi
[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3967:
--
Fix Version/s: (was: 1.1.0)
> Provide RethinkDB Sink for Flink
> ---
[
https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333725#comment-15333725
]
ASF GitHub Bot commented on FLINK-3714:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333740#comment-15333740
]
Robert Metzger commented on FLINK-4038:
---
Can you work on FLINK-4038 - FLINK-4040 unt
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2093#discussion_r67339362
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
---
@@ -917,6 +929,465 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333740#comment-15333740
]
Robert Metzger edited comment on FLINK-4038 at 6/16/16 1:12 PM:
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333746#comment-15333746
]
ASF GitHub Bot commented on FLINK-4017:
---
GitHub user GEOFBOT opened a pull request:
GitHub user GEOFBOT opened a pull request:
https://github.com/apache/flink/pull/2115
[FLINK-4017] [py] Add Aggregation support to Python API
Adds Aggregation support in the Python API accessible through
`.aggregate()` and `.agg_and()`. (I was unable to use `.and()` in Python
becaus
Stefan Richter created FLINK-4083:
-
Summary: Use ClosureCleaner for Join where and equalTo
Key: FLINK-4083
URL: https://issues.apache.org/jira/browse/FLINK-4083
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333747#comment-15333747
]
Stefan Richter commented on FLINK-4083:
---
Same problem.
> Use ClosureCleaner for Joi
[
https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4083:
--
Comment: was deleted
(was: Same problem.)
> Use ClosureCleaner for Join where and equalTo
> ---
[
https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4083:
--
Description:
When specifying a key selector in the where or equalTo clause of a Join, the
closu
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2093
Could you please update the tests to add elements to `expectedOutput` in
line with the `processElement` and `processWatermark` calls on the test
harness. In the existing tests I did this and it make
[
https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333749#comment-15333749
]
ASF GitHub Bot commented on FLINK-3714:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333752#comment-15333752
]
Robert Metzger commented on FLINK-3924:
---
I'm assigning this to myself
> Remove prot
[
https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3924:
-
Assignee: Robert Metzger
> Remove protobuf shading from Kinesis connector
> -
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2114
Thank you for your contribution. There is a typo in the pull request title.
its important that its correct so that our jira picks up the pull request.
Please also check out our contribution guide
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2116
[FLINK-4078] [java, DataSet] Introduce missing calls to closure cleaner
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into c
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333789#comment-15333789
]
ASF GitHub Bot commented on FLINK-4078:
---
GitHub user StefanRRichter opened a pull re
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67345484
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala ---
@@ -356,6 +357,40 @@ class GroupedDataSet[T: ClassTag](
}
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67345503
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala ---
@@ -356,6 +357,40 @@ class GroupedDataSet[T: ClassTag](
}
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333792#comment-15333792
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333793#comment-15333793
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333799#comment-15333799
]
ASF GitHub Bot commented on FLINK-3650:
---
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/1856#discussion_r67346072
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/SelectByMinFunction.scala
---
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4067:
--
Assignee: Ufuk Celebi
> Add version header to savepoints
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333801#comment-15333801
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333822#comment-15333822
]
Gyula Fora commented on FLINK-4038:
---
I feel that these issues are rather easy to solve o
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67345907
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/SelectByMaxFunction.scala
---
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333824#comment-15333824
]
Gyula Fora commented on FLINK-4038:
---
Should I open a discussion thread on the mailing li
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67349089
--- Diff:
flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala
---
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333839#comment-15333839
]
ASF GitHub Bot commented on FLINK-3650:
---
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/1856#discussion_r67349578
--- Diff:
flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala
---
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333840#comment-15333840
]
ASF GitHub Bot commented on FLINK-3650:
---
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/1856#discussion_r67350850
--- Diff:
flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala
---
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333853#comment-15333853
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user fhueske commented on a diff in
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/1856
Hi @ramkrish86, PR looks quite good now. I had only a few minor comments.
After those are fixed, the PR should be good to merge.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-4019:
--
Assignee: Tzu-Li (Gordon) Tai
> Expose approximateArrivalTimestamp through the
[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333858#comment-15333858
]
Tzu-Li (Gordon) Tai commented on FLINK-4019:
Ok. I'll add this then along with
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333861#comment-15333861
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user fhueske commented on the issue:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2117
[FLINK-4083] [java,DataSet] Introduce closure cleaning in Join.where(â¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333870#comment-15333870
]
ASF GitHub Bot commented on FLINK-4083:
---
GitHub user StefanRRichter opened a pull re
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2085
I tried your code again on my testing machine and everything that didn't
work at my last tests is now fixed.
I also quickly scanned the newly added commits.
I think the pull request is g
[
https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333907#comment-15333907
]
ASF GitHub Bot commented on FLINK-3937:
---
Github user rmetzger commented on the issue
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2041
Will be merging 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
enabled and wi
[
https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333928#comment-15333928
]
ASF GitHub Bot commented on FLINK-3317:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-3317.
Resolution: Fixed
Added via 57ef6c315ee7aa467d922dd4d1213dfd8bc74fb0
> Add timeout handler to CEP o
[
https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333934#comment-15333934
]
ASF GitHub Bot commented on FLINK-3317:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2041
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1771
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3311.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Resolved in http://git-wip-us.apache.org/repos/a
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3332.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Resolved in http://git-wip-us.apache.org/repos/a
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333947#comment-15333947
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user asfgit closed the pull request
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2102
After introducing `RexExecutor` which make `ReduceExpressionRules` taking
effect , many errors occurred.
1. The `cannot translate call AS($t0, $t1)` is a Calcite bug I think, and I
create
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333991#comment-15333991
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong commented on the issue:
Github user thormanrd commented on the issue:
https://github.com/apache/flink/pull/2114
Corrected the typo. Gotta add FLINK to my dictionary.
---
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 hav
101 - 200 of 223 matches
Mail list logo
