[
https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-7435:
-
Assignee: Kostas Kloudas
> FsStateBackend with incremental backup enable does not work
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132839934
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/conversion/CRowToJavaTupleMapRunner.scala
---
@@ -16,32 +16,32 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132834552
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132840719
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -719,33 +715,47 @@ abstract class
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132841043
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124929#comment-16124929
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125010#comment-16125010
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4525
`MutableObjectIterator#next` allows/requires a `null` result: "@return The
object or null if the iterator is exhausted.". The documentation
could be improved, e.g. in `MergeIterator` the returned
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132842811
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -719,33 +715,47 @@ abstract class
Github user zohar-mizrahi commented on a diff in the pull request:
https://github.com/apache/flink/pull/3838#discussion_r132842489
--- Diff:
flink-libraries/flink-streaming-python/src/test/java/org/apache/flink/streaming/python/api/PythonStreamBinderTest.java
---
@@ -0,0 +1,100
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7378:
Description:
Currently the number of network buffers in {{LocalBufferPool}} for
{{SingleInputGate}} is
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124908#comment-16124908
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124909#comment-16124909
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124910#comment-16124910
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124911#comment-16124911
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124914#comment-16124914
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zohar-mizrahi commented on a diff in the pull
Github user zohar-mizrahi commented on a diff in the pull request:
https://github.com/apache/flink/pull/3838#discussion_r132841381
--- Diff: flink-libraries/flink-streaming-python/pom.xml ---
@@ -0,0 +1,104 @@
+
+http://maven.apache.org/POM/4.0.0;
[
https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124875#comment-16124875
]
Kostas Kloudas commented on FLINK-7435:
---
The problem here seems to be on the {{copy()}} method of
Github user zohar-mizrahi commented on a diff in the pull request:
https://github.com/apache/flink/pull/3838#discussion_r132843982
--- Diff:
flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/environment/PythonStreamExecutionEnvironment.java
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124952#comment-16124952
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zohar-mizrahi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-7378:
Summary: Create a fix size (non rebalancing) buffer pool type for the
floating buffers (was: Implement the
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124831#comment-16124831
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132833668
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/OutputRowtimeProcessFunction.scala
---
@@ -0,0 +1,62 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125083#comment-16125083
]
sunjincheng edited comment on FLINK-7358 at 8/13/17 11:30 PM:
--
[~fhueske]
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132863952
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/ProctimeSqlFunction.scala
---
@@ -22,12 +22,12 @@ import
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125053#comment-16125053
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user fhueske commented on a diff in the pull
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4511
Thank you for merging it
---
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
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4511
---
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-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125068#comment-16125068
]
ASF GitHub Bot commented on FLINK-7396:
---
Github user zjureel commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125142#comment-16125142
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in the pull
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4534
[FLINK-7358][table]Add implicitly converts support for User-defined function
In this PR i had Add implicitly converts support for User-defined function.
* Update the udfs document.
*
[
https://issues.apache.org/jira/browse/FLINK-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125091#comment-16125091
]
ASF GitHub Bot commented on FLINK-7358:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125145#comment-16125145
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , I have submitted the updates:
- Create the fix size `LocalBufferPool` for floating buffers
- Assign the exclusive buffers for `InputChannel` directly
- The proposed
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125061#comment-16125061
]
ASF GitHub Bot commented on FLINK-7337:
---
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/4532#discussion_r132854814
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/OutputRowtimeProcessFunction.scala
---
@@ -0,0 +1,62 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-7439:
---
Component/s: Table API & SQL
> Support variable arguments for UDTF
> ---
>
>
Jark Wu created FLINK-7439:
--
Summary: Support variable arguments for UDTF
Key: FLINK-7439
URL: https://issues.apache.org/jira/browse/FLINK-7439
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125182#comment-16125182
]
Xingcan Cui commented on FLINK-6233:
Hi [~fhueske], thanks for the previous work by you and yuhong,
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132867483
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -340,6 +362,65 @@ public void resetNFAChanged() {
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125189#comment-16125189
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dianfu commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125252#comment-16125252
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
hmmm... I was deploying our Flink job with this change. The Flink job
failed to start, and log reports:
```
The implementation of the RichSinkFunction is not serializable. The object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132854238
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125069#comment-16125069
]
ASF GitHub Bot commented on FLINK-7396:
---
Github user zjureel closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125083#comment-16125083
]
sunjincheng commented on FLINK-7358:
[~fhueske] Yes, Agree with you. I had open the PR in calcite. And
[
https://issues.apache.org/jira/browse/FLINK-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125083#comment-16125083
]
sunjincheng edited comment on FLINK-7358 at 8/13/17 11:30 PM:
--
[~fhueske]
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-7439:
---
Summary: Support variable arguments for UDTF in SQL (was: Support variable
arguments for UDTF)
> Support
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-7439:
---
Description:
Currently, both UDF and UDAF support variable parameters, but UDTF not.
FLINK-5882 supports
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125262#comment-16125262
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4473
@bowenli86 I think the test you posted above is failing because the
provided `KinesisSerializationSchema` is not serializable. It is an anonymous
class, which would contain a reference to the
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4473
@bowenli86 on the other hand, in the constructors of
`FlinkKinesisProducer`, we probably should add eager safe checks on the
serializability of the provided `KinesisSerializationSchema` and have
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125270#comment-16125270
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
@tzulitai Thanks Gordan for the quick response! You are right, I set the
schema in unit test to be static and it passes.
For my Flink job. When I build it against Flink 1.3.0, it can run
GitHub user zhuganghuaonnet opened a pull request:
https://github.com/apache/flink/pull/4535
Eventhubs-support read from and write to Azure eventhubs
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community
[
https://issues.apache.org/jira/browse/FLINK-1234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125243#comment-16125243
]
ASF GitHub Bot commented on FLINK-1234:
---
GitHub user zhuganghuaonnet opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125264#comment-16125264
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4473
@bowenli86 what is it failing on? AFAIK, the only serialization changes in
1.3.2 compared to 1.3.0 are serialization of some specific `TypeSerializer`s.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125272#comment-16125272
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124928#comment-16124928
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zohar-mizrahi commented on a diff in the pull
60 matches
Mail list logo
