Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/3523
Hm, doesnt seem to work for the first try. What I did is I updated the
client with the new jar based on your backport branch. Redeployed the job with
a savepoint (to get the new Flink version), took
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924869#comment-15924869
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user gyfora commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924834#comment-15924834
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user EronWright commented on the issue:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/2425
@StephanEwen keep in mind that Flink's current SSL support in Flink doesn't
achieve _mutual authentication_ - there's no client certificate there.With
SSL enabled, an untrusted client can
Ted Yu created FLINK-6052:
-
Summary: Potential null access in
ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()
Key: FLINK-6052
URL: https://issues.apache.org/jira/browse/FLINK-6052
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924751#comment-15924751
]
ASF GitHub Bot commented on FLINK-6000:
---
Github user dawidwys commented on the issue:
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/3506
@uce You replied to my message on mailing-list than maybe you could have a
look at this PR ;)
Recently another user reported it at SO:
Bowen Li created FLINK-6053:
---
Summary: Gauge should only take subclasses of Number, rather
than everything
Key: FLINK-6053
URL: https://issues.apache.org/jira/browse/FLINK-6053
Project: Flink
Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/3523
It also doesnt seem to work starting from a clean state and then savepoint
redeploy with changed topology so maybe I am really screwing up something
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6053:
Description:
Currently, Flink's Gauge is defined as
```java
public interface Gauge extends Metric {
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6053:
Description:
Currently, Flink's Gauge is defined as
```java
/**
* A Gauge is a {@link Metric} that
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924934#comment-15924934
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user gyfora commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925127#comment-15925127
]
ASF GitHub Bot commented on FLINK-5808:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3509#discussion_r106040063
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java
---
@@ -38,14 +38,10 @@
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-6040.
-
Resolution: Fixed
> DataStreamUserDefinedFunctionITCase occasionally fails
>
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925393#comment-15925393
]
Syinchwun Leo commented on FLINK-5756:
--
Is it possible that avoiding using merge() operation. I
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925423#comment-15925423
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user WangTaoTheTonic commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925441#comment-15925441
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user godfreyhe commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925442#comment-15925442
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user godfreyhe commented on a diff in the pull
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106073030
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/RexProgramExtractor.scala
---
@@ -0,0 +1,184 @@
+/*
+ *
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106072764
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/RexProgramExtractor.scala
---
@@ -0,0 +1,184 @@
+/*
+ *
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3486
@vijikarthi I've checked the [JDK
doc](http://docs.oracle.com/javase/8/docs/technotes/guides/security/StandardNames.html#ciphersuites)
and not found any notes about combination of ssl
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925359#comment-15925359
]
ASF GitHub Bot commented on FLINK-6040:
---
Github user KurtYoung commented on the issue:
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3530
looks good, merging
---
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
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925364#comment-15925364
]
Syinchwun Leo commented on FLINK-5756:
--
OK, this problem is not only influence the performance of UDF
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3535#discussion_r106065855
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -354,22 +354,27 @@
[
https://issues.apache.org/jira/browse/FLINK-5713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925371#comment-15925371
]
ASF GitHub Bot commented on FLINK-5713:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925393#comment-15925393
]
Syinchwun Leo edited comment on FLINK-5756 at 3/15/17 1:43 AM:
---
Is it
[
https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jingzhang updated FLINK-6036:
-
Description:
Now catalog only support CRUD at database and table level. But in some kind of
catalog, for
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-6039:
--
Component/s: Table API & SQL
> Row of TableFunction should support flexible number of fields
>
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925373#comment-15925373
]
ASF GitHub Bot commented on FLINK-6040:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3530
---
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-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jingzhang updated FLINK-6036:
-
Description:
Now catalog only support CRUD at database and table level. But in some kind of
catalog, for
[
https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jingzhang reassigned FLINK-6036:
Assignee: jingzhang
> Let catalog support partition
> -
>
>
sunjincheng created FLINK-6055:
--
Summary: Supported setting timers on a Non-Keyed Stream
Key: FLINK-6055
URL: https://issues.apache.org/jira/browse/FLINK-6055
Project: Flink
Issue Type: New
Sergio Esteves created FLINK-6054:
-
Summary: Add new state backend that dynamically stores data in
memory and external storage
Key: FLINK-6054
URL: https://issues.apache.org/jira/browse/FLINK-6054
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925257#comment-15925257
]
Bowen Li commented on FLINK-6053:
-
hm I found in Flink's Gauge class is used like this in
[
https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925575#comment-15925575
]
Xiaogang Shi commented on FLINK-6055:
-
I think it's very challenging because the storing and restoring
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923836#comment-15923836
]
Fabian Hueske commented on FLINK-6039:
--
Can you explain the semantics if the returned rows are too
[
https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923849#comment-15923849
]
Luke Hutchison commented on FLINK-6035:
---
The name parameter shouldn't be required, just as calling
[
https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6035:
--
Summary: Sinks need optional name parameter: .collect(name), .count(name)
(was: The method
[
https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923849#comment-15923849
]
Luke Hutchison edited comment on FLINK-6035 at 3/14/17 9:19 AM:
The name
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923859#comment-15923859
]
ASF GitHub Bot commented on FLINK-6039:
---
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/3529#discussion_r105856276
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -66,10 +66,11 @@ public int getArity() {
* Gets the field at the specified
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923882#comment-15923882
]
ASF GitHub Bot commented on FLINK-6039:
---
Github user clarkyzl commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923887#comment-15923887
]
ASF GitHub Bot commented on FLINK-6039:
---
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/3529#discussion_r105862926
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -66,10 +66,11 @@ public int getArity() {
* Gets the field at the specified
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923886#comment-15923886
]
Zhuoluo Yang commented on FLINK-6039:
-
Hi [~fhueske] Thank you for your comments. I'm not sure whether
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Labels: test (was: )
> DataStreamUserDefinedFunctionITCase occasionally fails
>
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923923#comment-15923923
]
ASF GitHub Bot commented on FLINK-6040:
---
GitHub user clarkyzl opened a pull request:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3518
@tzulitai The merge didn't close the PR :) I think the "this closes #xxx"
thing only works for commits to `master`.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923932#comment-15923932
]
ASF GitHub Bot commented on FLINK-6040:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3530#discussion_r105869656
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -85,6
[
https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923931#comment-15923931
]
ASF GitHub Bot commented on FLINK-6025:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923831#comment-15923831
]
ASF GitHub Bot commented on FLINK-6039:
---
Github user clarkyzl commented on the issue:
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105851855
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/ComputationState.java
---
@@ -52,14 +57,35 @@ public ComputationState(
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105856821
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854765
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -247,27 +275,148 @@ public int compare(final StateTransition o1,
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105853157
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -71,19 +70,16 @@
private final
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105855825
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/StateTransition.java
---
@@ -55,6 +65,7 @@ public boolean equals(Object obj) {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854576
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -247,27 +275,148 @@ public int compare(final StateTransition o1,
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105857677
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105857530
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/compiler/NFACompilerTest.java
---
@@ -18,9 +18,13 @@
package
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854241
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -209,33 +204,66 @@ public boolean equals(Object obj) {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854452
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -247,27 +275,148 @@ public int compare(final StateTransition o1,
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105851817
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -71,19 +70,16 @@
private final
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105851882
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/ComputationState.java
---
@@ -41,8 +43,11 @@
// Timestamp of the first
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105857618
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105857595
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Zhuoluo Yang created FLINK-6040:
---
Summary: DataStreamUserDefinedFunctionITCase occasionally fails
Key: FLINK-6040
URL: https://issues.apache.org/jira/browse/FLINK-6040
Project: Flink
Issue
GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3530
[FLINK-6040] [table] DataStreamUserDefinedFunctionITCase occasionally fails
Type: Bug
Priority: Major
Components: table, test
Problem Definition: DataStreamUserDefinedFunctionITCase
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3445
Thanks for the comments @aljoscha . I integrated them and I updated
https://issues.apache.org/jira/browse/FLINK-5969 to keep track.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923940#comment-15923940
]
ASF GitHub Bot commented on FLINK-5846:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923956#comment-15923956
]
Patrick Lucas commented on FLINK-3026:
--
Personally I like the idea of having as little code as
[
https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923964#comment-15923964
]
ASF GitHub Bot commented on FLINK-6025:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3518
Thanks for the reminder :-D
---
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
[
https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923966#comment-15923966
]
ASF GitHub Bot commented on FLINK-6025:
---
Github user tzulitai closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923965#comment-15923965
]
ASF GitHub Bot commented on FLINK-6025:
---
Github user tzulitai closed the pull request at:
Github user tzulitai closed the pull request at:
https://github.com/apache/flink/pull/3518
---
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 clarkyzl commented on the issue:
https://github.com/apache/flink/pull/3529
I didn't change the behavior of `org.apache.flink.types.Record`. I think we
can open another issue if necessary.
---
If your project is set up for it, you can reply to this email and have your
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105856015
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
---
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854116
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -209,33 +204,66 @@ public boolean equals(Object obj) {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854967
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -247,27 +275,148 @@ public int compare(final StateTransition o1,
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105855625
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -217,23 +217,22 @@ public void prune(long
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105854471
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -247,27 +275,148 @@ public int compare(final StateTransition o1,
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105855949
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/InvalidPatternException.java
---
@@ -0,0 +1,28 @@
+/*
+ * Licensed
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105855001
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -247,27 +275,148 @@ public int compare(final StateTransition o1,
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3477
Thanks @dawidwys I will have a look now.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-5969:
--
Description:
We currently only have tests that test migration from 1.1 to 1.3, because we
Github user tzulitai closed the pull request at:
https://github.com/apache/flink/pull/3519
---
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 kl0u commented on the issue:
https://github.com/apache/flink/pull/3477
Hi @dawidwys , the following produces no output, which should not be the
case. The same holds if you change the pattern to `oneOrMore`.
```
public void testZeroOrMore() {
[
https://issues.apache.org/jira/browse/FLINK-6006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923872#comment-15923872
]
ASF GitHub Bot commented on FLINK-6006:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3505#discussion_r105860440
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -489,16
[
https://issues.apache.org/jira/browse/FLINK-6006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923874#comment-15923874
]
ASF GitHub Bot commented on FLINK-6006:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3505#discussion_r105860279
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@
Github user clarkyzl commented on a diff in the pull request:
https://github.com/apache/flink/pull/3529#discussion_r105861507
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -66,10 +66,11 @@ public int getArity() {
* Gets the field at the
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/3477
Thanks @kl0u for your comments, I've changed all code style specific.
Some comments were addressing a behaviour that one `Pattern` can be
translated into multiple "equivalent" `States`
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Affects Version/s: 1.3.0
> DataStreamUserDefinedFunctionITCase occasionally fails
>
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Fix Version/s: 1.3.0
> DataStreamUserDefinedFunctionITCase occasionally fails
>
[
https://issues.apache.org/jira/browse/FLINK-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-6040:
Component/s: Tests
> DataStreamUserDefinedFunctionITCase occasionally fails
>
1 - 100 of 374 matches
Mail list logo
