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&focusedCommentId=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 Da
Github user vipul1409 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2922#discussion_r90598402
--- Diff:
flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/MultiThreadedFlatMapFunction.java
---
@@ -0,0 +1,91 @@
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 acco
[
https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714311#comment-15714311
]
Alexander Shoshin commented on FLINK-5159:
--
[~fhueske], thank you a lot for your
[
https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714303#comment-15714303
]
Anton Solovev commented on FLINK-5188:
--
In each project that has dependency on {{org.
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15713917#comment-15713917
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
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 the
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15713905#comment-15713905
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user wuchong commented on a diff in
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 B
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15713897#comment-15713897
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
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 Type
[
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: Impr
[
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
Re
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15713784#comment-15713784
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user beyond1920 commented on a diff
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 @@ clas
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15713774#comment-15713774
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user wuchong commented on a diff in
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 B
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 Win
[
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 Wind
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 docum
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
Compone
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15713697#comment-15713697
]
ASF GitHub Bot commented on FLINK-5185:
---
GitHub user beyond1920 opened a pull reques
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 pu
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 GitHu
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 enab
[
https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712981#comment-15712981
]
ASF GitHub Bot commented on FLINK-5214:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712978#comment-15712978
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on the issu
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 convert
[
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 operat
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712941#comment-15712941
]
Fabian Hueske commented on FLINK-4541:
--
With FLINK-5159 being fixed, the query posted
[
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 dbe70732434ff1396e1829080cd14f26b
[
https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712896#comment-15712896
]
ASF GitHub Bot commented on FLINK-5159:
---
Github user asfgit closed the pull request
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 enab
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 generate
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15712827#comment-15712827
]
ASF GitHub Bot commented on FLINK-4898:
---
Github user EronWright commented on the iss
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
reply
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712791#comment-15712791
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on the is
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&focusedCommentId=15712755#comment-15712755
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on the issu
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 -> Str
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712739#comment-15712739
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on a diff
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 {
// par
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712722#comment-15712722
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on a diff
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&focusedCommentId=15712711#comment-15712711
]
ASF GitHub Bot commented on FLINK-5218:
---
Github user StephanEwen commented on the is
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` sta
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712704#comment-15712704
]
ASF GitHub Bot commented on FLINK-5218:
---
GitHub user StephanEwen opened a pull reque
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 forw
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712693#comment-15712693
]
Stephan Ewen commented on FLINK-5218:
-
Fixed in 1.1.4 via 59f61bf6cb8351cec9369e2de39c
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712655#comment-15712655
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff i
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&focusedCommentId=15712650#comment-15712650
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712649#comment-15712649
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff i
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&focusedCommentId=15712647#comment-15712647
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff i
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&focusedCommentId=15712646#comment-15712646
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on a diff i
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 environmen
[
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&focusedCommentId=15712593#comment-15712593
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712592#comment-15712592
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712590#comment-15712590
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712591#comment-15712591
]
ASF GitHub Bot commented on FLINK-4565:
---
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/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 ScalarOpera
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 Apa
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 the
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 ScalarOpera
[
https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712570#comment-15712570
]
ASF GitHub Bot commented on FLINK-5091:
---
Github user EronWright commented on a diff
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 name
[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712488#comment-15712488
]
Flavio Pompermaier commented on FLINK-5122:
---
Hi @static-max,
we've closed our PR
[
https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712467#comment-15712467
]
ASF GitHub Bot commented on FLINK-5158:
---
Github user tillrohrmann commented on the i
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 n
[
https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15712446#comment-15712446
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user tillrohrmann commented on the i
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 G
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 checkpoin
[
https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712443#comment-15712443
]
ASF GitHub Bot commented on FLINK-5214:
---
GitHub user tillrohrmann opened a pull requ
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 b1
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712364#comment-15712364
]
ASF GitHub Bot commented on FLINK-4469:
---
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/2653#discussion_r90479434
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -451,6 +452,28 @@ object Expression
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&focusedCommentId=15712354#comment-15712354
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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
1 - 100 of 211 matches
Mail list logo
