[
https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529428#comment-16529428
]
ASF GitHub Bot commented on FLINK-9377:
---
GitHub user tzulitai opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9377:
--
Labels: pull-request-available (was: )
> Remove writing serializers as part of the checkpoint
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/6235
[FLINK-9377] [core] Remove serializers from checkpointed state meta infos
## What is the purpose of the change
This PR is the first step towards a smoother state evolution experience.
I
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529406#comment-16529406
]
Jeff Zhang commented on FLINK-9698:
---
Could anyone let me know why flink require case cl
Jeff Zhang created FLINK-9698:
-
Summary: "case class must be static and globally accessible" is
too constrained
Key: FLINK-9698
URL: https://issues.apache.org/jira/browse/FLINK-9698
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529329#comment-16529329
]
ASF GitHub Bot commented on FLINK-9337:
---
Github user cricket007 commented on the is
Github user cricket007 commented on the issue:
https://github.com/apache/flink/pull/5995
What about implementing a `KeyedDeserializationSchema` for Avro?
---
[
https://issues.apache.org/jira/browse/FLINK-9670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu closed FLINK-9670.
-
Resolution: Invalid
> Introduce slot manager factory
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529321#comment-16529321
]
ASF GitHub Bot commented on FLINK-9567:
---
Github user Clark closed the pull requ
Github user Clark closed the pull request at:
https://github.com/apache/flink/pull/6192
---
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529282#comment-16529282
]
ASF GitHub Bot commented on FLINK-9688:
---
Github user snuyanzin commented on a diff
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6223#discussion_r199366673
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -,6 +,53 @@ class ScalarF
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529278#comment-16529278
]
ASF GitHub Bot commented on FLINK-9688:
---
Github user yanghua commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9688:
--
Labels: pull-request-available (was: )
> ATAN2 Sql Function support
>
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6223#discussion_r199365966
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -,6 +,53 @@ class ScalarFun
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6234#discussion_r199365531
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -224,23 +226,26 @@ private boolean isFinalState(ComputationState s
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529276#comment-16529276
]
ASF GitHub Bot commented on FLINK-9431:
---
Github user yanghua commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529266#comment-16529266
]
ASF GitHub Bot commented on FLINK-9696:
---
Github user snuyanzin commented on the iss
Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/6233
Hello @hequn8128! Thank you for your review and comments.
About PR template - I did changes based on proposed #5811. Please let me
know if it is acceptable or not.
About `rowToString` agree.
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529265#comment-16529265
]
ASF GitHub Bot commented on FLINK-9696:
---
Github user snuyanzin commented on a diff
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6233#discussion_r199364538
--- Diff:
flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliUtilsTest.java
---
@@ -0,0 +1,108 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529264#comment-16529264
]
ASF GitHub Bot commented on FLINK-9696:
---
Github user snuyanzin commented on a diff
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6233#discussion_r199364581
--- Diff:
flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliUtilsTest.java
---
@@ -0,0 +1,108 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9456.
Resolution: Fixed
Fixed via
1.6.0:
89cfeaa882f9e68df2bd215563622b48c29a9ec9
50c0ea8c9fe17278d45aba4
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529253#comment-16529253
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6132
---
[
https://issues.apache.org/jira/browse/FLINK-9633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529134#comment-16529134
]
ASF GitHub Bot commented on FLINK-9633:
---
Github user sihuazhou commented on the iss
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6194
@yanghua Thanks for the review, I rebased the PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9431:
--
Labels: pull-request-available (was: )
> Introduce TimeEnd State to flink cep
> --
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529124#comment-16529124
]
ASF GitHub Bot commented on FLINK-9431:
---
GitHub user Aitozi opened a pull request:
GitHub user Aitozi opened a pull request:
https://github.com/apache/flink/pull/6234
[FLINK-9431]Introduce time bounded condition to cep
## What is the purpose of the change
In cep the event is now driving the transformation of the NFA, I think the
time factor should also be
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6194
+1, there is a conflicting file~ cc @sihuazhou
---
[
https://issues.apache.org/jira/browse/FLINK-9633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529123#comment-16529123
]
ASF GitHub Bot commented on FLINK-9633:
---
Github user yanghua commented on the issue
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r199352237
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -1029,6 +1029,29 @@ object temporalOverla
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529122#comment-16529122
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user walterddr commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529121#comment-16529121
]
ASF GitHub Bot commented on FLINK-9654:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6206
hi @zsolt-donca I have seen the Travis build error log, the failed reason
is not because of your code. This PR looks good, but if you can add a test for
`isAnonymousClass` method, that would be bette
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonid Ishimnikov updated FLINK-9695:
-
Description: It would be useful to have an option to forcefully pull Docker
images for ta
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529103#comment-16529103
]
ASF GitHub Bot commented on FLINK-9669:
---
Github user liurenjie1024 closed the pull
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529102#comment-16529102
]
ASF GitHub Bot commented on FLINK-9669:
---
Github user liurenjie1024 commented on the
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu closed FLINK-9669.
-
Resolution: Invalid
> Introduce task manager assignment store
> ---
>
Github user liurenjie1024 commented on the issue:
https://github.com/apache/flink/pull/6214
@tillrohrmann This is from my initial design, and since the design has
changed, we can close this now.
---
Github user liurenjie1024 closed the pull request at:
https://github.com/apache/flink/pull/6214
---
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r199349619
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -1029,6 +1029,29 @@ object temporalOverla
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529099#comment-16529099
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529096#comment-16529096
]
ASF GitHub Bot commented on FLINK-9696:
---
Github user hequn8128 commented on the iss
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6233
Hi @snuyanzin , thanks for your PR. The code looks good and the
`deepToString()` function returns result correctly. I could not spot any issues
with the implementation. To make the PR better, I thi
Github user elbaulp commented on the issue:
https://github.com/apache/flink/pull/6219
@tillrohrmann You're welcome :-)
---
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529025#comment-16529025
]
vinoyang commented on FLINK-9682:
-
seems a feasible suggestion, what do you think about t
[
https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529023#comment-16529023
]
vinoyang commented on FLINK-9511:
-
Hi [~azagrebin] the defined TtlConfig stored in flink-
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529020#comment-16529020
]
vinoyang commented on FLINK-9221:
-
[~joshlemer] I think we should not add this method to
52 matches
Mail list logo
