Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/2905
@StephanEwen yes, the client are both started and stopped in
ZookeeperHaServices.
---
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-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714372#comment-15714372
]
ASF GitHub Bot commented on FLINK-5190:
---
Github user shuai-xu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Shoshin updated FLINK-3133:
-
Assignee: (was: Alexander Shoshin)
> Introduce collect()/count()/print() methods in
Github user vipul1409 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2922#discussion_r90598293
--- Diff:
flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/MultiThreadedFlatMapFunction.java
---
@@ -0,0 +1,91 @@
GitHub user vipul1409 opened a pull request:
https://github.com/apache/flink/pull/2922
Initial try
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 into
[
https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714311#comment-15714311
]
Alexander Shoshin commented on FLINK-5159:
--
[~fhueske], thank you a lot for your help with this
[
https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714303#comment-15714303
]
Anton Solovev commented on FLINK-5188:
--
In each project that has dependency on
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713917#comment-15713917
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90583213
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableFunctionCall.scala
---
@@ -0,0 +1,110 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713905#comment-15713905
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2921#discussion_r90582677
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala
---
@@ -32,18 +31,20 @@ class
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713897#comment-15713897
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90582259
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/TableFunction.scala
---
@@ -0,0 +1,121 @@
+/*
+ * Licensed
Jark Wu created FLINK-5225:
--
Summary: Add interface to override parameter types of UDTF's eval
method
Key: FLINK-5225
URL: https://issues.apache.org/jira/browse/FLINK-5225
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5225:
---
Component/s: Table API & SQL
> Add interface to override parameter types of UDTF's eval method
>
Jark Wu created FLINK-5224:
--
Summary: Improve UDTF: emit rows directly instead of buffering them
Key: FLINK-5224
URL: https://issues.apache.org/jira/browse/FLINK-5224
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-5224:
--
Assignee: Jark Wu
> Improve UDTF: emit rows directly instead of buffering them
>
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5223:
---
Component/s: Table API & SQL
> Add documentation of UDTF in Table API & SQL
>
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5223:
---
Issue Type: Improvement (was: Bug)
> Add documentation of UDTF in Table API & SQL
>
Jark Wu created FLINK-5223:
--
Summary: Add documentation of UDTF in Table API & SQL
Key: FLINK-5223
URL: https://issues.apache.org/jira/browse/FLINK-5223
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713784#comment-15713784
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user beyond1920 commented on a diff in the pull
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2921#discussion_r90577312
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala
---
@@ -32,18 +31,20 @@
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713774#comment-15713774
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2921#discussion_r90576889
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala
---
@@ -32,18 +31,20 @@ class
MaGuowei created FLINK-5222:
---
Summary: Rename StateBackend interface to StateBinder
Key: FLINK-5222
URL: https://issues.apache.org/jira/browse/FLINK-5222
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Syinchwun Leo updated FLINK-5221:
-
Description:
When window OPERATOR making checkpoint like this:
class WindowStatistic extends
[
https://issues.apache.org/jira/browse/FLINK-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Syinchwun Leo updated FLINK-5221:
-
Description:
When window OPERATOR making checkpoint like this:
class WindowStatistic extends
Syinchwun Leo created FLINK-5221:
Summary: Checkpointed workless in Window Operator
Key: FLINK-5221
URL: https://issues.apache.org/jira/browse/FLINK-5221
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-5220:
-
Description: The jira is to do projection pushdown optimization. Please go
forward to the the design
zhangjing created FLINK-5220:
Summary: Flink SQL projection pushdown
Key: FLINK-5220
URL: https://issues.apache.org/jira/browse/FLINK-5220
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713697#comment-15713697
]
ASF GitHub Bot commented on FLINK-5185:
---
GitHub user beyond1920 opened a pull request:
GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/2921
[FLINK-5185] [Table API & SQL] Decouple BatchTableSourceScan with
TableSourceTable
The pr aims to decouple BatchTableSourceScan with TableSourceTable for
further optimization, e.g, projection
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713173#comment-15713173
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2762
Would be good if the TableSource could be used by providing parameters and
without extending it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2918
---
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
[
https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712981#comment-15712981
]
ASF GitHub Bot commented on FLINK-5214:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712978#comment-15712978
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2762
Are there any other cases when a user needs a custom conversion from a
`GenericRecord` to a `Row` instance?
`String -> String` will definitely work, but I also can think about a
generic
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-4541.
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via FLINK-5159
> Support for SQL NOT IN
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712941#comment-15712941
]
Fabian Hueske commented on FLINK-4541:
--
With FLINK-5159 being fixed, the query posted in this issue
[
https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5159.
Resolution: Implemented
Fix Version/s: 1.2.0
Implement with
[
https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712896#comment-15712896
]
ASF GitHub Bot commented on FLINK-5159:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2811
---
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
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2762
The `String -> String` mapping would be a name mapping of fields from the
`GenericRecord` to `Row` attributes. This would allow users to freely choose
the attribute names of a table which is
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712871#comment-15712871
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712827#comment-15712827
]
ASF GitHub Bot commented on FLINK-4898:
---
Github user EronWright commented on the issue:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/2766
@uce it would be nice to get this PR in, to counteract the growing
duplication of Netty code in the codebase.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712791#comment-15712791
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2917
It's a cool fix to help Flink run in container environments.
There is one concern I have with the code, though: Previously, we decided
explicitly to encode IP addresses in the Akka URLs,
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712755#comment-15712755
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2762
@fhueske Just a small question about your comment. You wrote:
"users should be able to provide a Schema and a String ->String to convert
aGenericRecordinto a Row"
What is String ->
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712739#comment-15712739
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90511221
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1891,8 +1891,8 @@ object JobManager {
//
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712722#comment-15712722
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90510382
--- Diff: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ---
@@ -309,6 +313,19 @@ public static ServerSocket
createSocketFromPorts(Iterator
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712711#comment-15712711
]
ASF GitHub Bot commented on FLINK-5218:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2920
@StefanRRichter There is one change of semantics that would be good to get
your input on: A checkpoint stream to which a `byte[0]` array was written is
now actually empty and returns a `null`
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712704#comment-15712704
]
ASF GitHub Bot commented on FLINK-5218:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2920
[FLINK-5218] [state backends] Eagerly close checkpoint streams on
cancellation
When a task is canceled during a checkpoint operation, the operation needs
to cancel fast.
This is a
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712693#comment-15712693
]
Stephan Ewen commented on FLINK-5218:
-
Fixed in 1.1.4 via 59f61bf6cb8351cec9369e2de39c6eeffbda10ea
>
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712655#comment-15712655
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r90505208
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/AvroDeserializationSchemaTest.java
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712650#comment-15712650
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712649#comment-15712649
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r90504858
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712647#comment-15712647
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r90504943
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowDeserializationSchema.java
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r90504878
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712646#comment-15712646
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r90504916
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowSerializationSchema.java
[
https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright closed FLINK-4826.
---
Resolution: Fixed
This is fixed in PR #2900.
> Add keytab based kerberos support for Mesos
[
https://issues.apache.org/jira/browse/FLINK-4918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright closed FLINK-4918.
---
Resolution: Fixed
This is fixed in PR #2900.
> Add SSL support to Mesos artifact server
>
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712593#comment-15712593
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712592#comment-15712592
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712590#comment-15712590
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712591#comment-15712591
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r90497004
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala
---
@@ -78,6 +78,69 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r90495217
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/In.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r90499247
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/InITCase.java
---
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r90496100
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala
---
@@ -78,6 +78,69 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712570#comment-15712570
]
ASF GitHub Bot commented on FLINK-5091:
---
Github user EronWright commented on a diff in the pull
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2915#discussion_r90498149
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -1372,6 +1381,12 @@
/** The environment variable
[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712488#comment-15712488
]
Flavio Pompermaier commented on FLINK-5122:
---
Hi @static-max,
we've closed our PR to add the
[
https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712467#comment-15712467
]
ASF GitHub Bot commented on FLINK-5158:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2873
Thanks for the review @uce. I have addressed your comments.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712445#comment-15712445
]
ASF GitHub Bot commented on FLINK-4554:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712446#comment-15712446
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2910
Thanks for the review @StephanEwen & @uce. Will address your comment with
the malformed job id.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2919
[FLINK-4554] [table] Add support for array types
This PR adds array support for the Table API and SQL. It adds support for
both primitive arrays and object arrays. It adds literals, element access,
[
https://issues.apache.org/jira/browse/FLINK-5216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5216.
---
> CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint
> start rather then
[
https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712443#comment-15712443
]
ASF GitHub Bot commented on FLINK-5214:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2918
[FLINK-5214] Clean up checkpoint data in case of a failing checkpoint
operation
Adds exception handling to the stream operators for the snapshotState
method. In case of an
exception while
[
https://issues.apache.org/jira/browse/FLINK-5216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5216.
-
Resolution: Fixed
Fixed in
- 1.1.4 via e475eb2d9705b8948ce862f25adf91e25a4948b0
- 1.2.0 via
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712364#comment-15712364
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90479434
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -451,6 +452,28 @@ object
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90478025
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -334,18 +337,33 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712354#comment-15712354
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712251#comment-15712251
]
ASF GitHub Bot commented on FLINK-5209:
---
Github user zentol commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2908#discussion_r90469083
--- Diff: flink-libraries/flink-cep-scala/pom.xml ---
@@ -93,6 +93,8 @@ under the License.
+
+src/main/scala
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2902
Looks good to merge, +1 :)
---
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
1 - 100 of 210 matches
Mail list logo
