Luke Hutchison created FLINK-6035:
-
Summary: The method name(String) is undefined for the type
UnsortedGrouping
Key: FLINK-6035
URL: https://issues.apache.org/jira/browse/FLINK-6035
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923565#comment-15923565
]
ASF GitHub Bot commented on FLINK-5975:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923564#comment-15923564
]
ASF GitHub Bot commented on FLINK-5975:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/3481#discussion_r105826378
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -162,11 +182,65 @@ public stat
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/3481#discussion_r105825035
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
---
@@ -259,9 +262,11 @@ public String toS
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3467
@NicoK ï¼thank you for explanation, and I already trace the code in your
local branch. Wish your further change commit in global pool.
@StephanEwen , thanks for further elaboration. From
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923554#comment-15923554
]
ASF GitHub Bot commented on FLINK-4545:
---
Github user zhijiangW commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923530#comment-15923530
]
shijinkui commented on FLINK-5756:
--
[~StephanEwen] Thank for your reply. [~SyinchwunLeo]
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3107
updated the documentation.
---
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 wishe
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/3406
@fhueske , thanks for your review. I already updated the pr based on 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.
[
https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923509#comment-15923509
]
ASF GitHub Bot commented on FLINK-5441:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-6034:
Description:
Currently, the only type of the snapshots in keyed streams is
{{KeyGroupsStateHandle}}
Xiaogang Shi created FLINK-6034:
---
Summary: Add KeyedStateHandle for the snapshots in keyed streams
Key: FLINK-6034
URL: https://issues.apache.org/jira/browse/FLINK-6034
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923433#comment-15923433
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user godfreyhe commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923432#comment-15923432
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user godfreyhe commented on a diff i
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r105811515
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala
---
@@ -42,63 +41,40 @@ class DataSetCalc
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923434#comment-15923434
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user godfreyhe commented on a diff i
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r105814436
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/PushFilterIntoTableSourceScanRuleBase.scala
---
@@ -0,0 +1,9
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r105812230
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/PushFilterIntoTableSourceScanRuleBase.scala
---
@@ -0,0 +1,9
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922949#comment-15922949
]
ASF GitHub Bot commented on FLINK-5134:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3455
Thanks, looks good. Will merge this once the CI builds have passed!
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3503
Looks good. I would actually like to extend the test by one more, just to
make sure that the proper `ExecutionConfig` is passed (which is not currently
tested - the execution config in the test i
[
https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922937#comment-15922937
]
ASF GitHub Bot commented on FLINK-5995:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922923#comment-15922923
]
Haohui Mai commented on FLINK-6033:
---
Discussed offline with [~fhueske] -- the proposed a
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922909#comment-15922909
]
Stephan Ewen edited comment on FLINK-5756 at 3/13/17 8:52 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922909#comment-15922909
]
Stephan Ewen edited comment on FLINK-5756 at 3/13/17 8:52 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922909#comment-15922909
]
Stephan Ewen commented on FLINK-5756:
-
Thanks for opening this and sharing the test re
[
https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6033:
--
Summary: Support UNNEST query in the stream SQL API (was: Support UNNEST
query in the stream SQL api)
Haohui Mai created FLINK-6033:
-
Summary: Support UNNEST query in the stream SQL api
Key: FLINK-6033
URL: https://issues.apache.org/jira/browse/FLINK-6033
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922878#comment-15922878
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user sjwiesman commented on a diff i
Github user sjwiesman commented on a diff in the pull request:
https://github.com/apache/flink/pull/3479#discussion_r105763162
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalAggregateProcessAllWindowFunction.java
-
[
https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922875#comment-15922875
]
ASF GitHub Bot commented on FLINK-2814:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2029
@greghogan I think you are right with your suggestion. Would be great if
you can create an alternate fix.
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922825#comment-15922825
]
ASF GitHub Bot commented on FLINK-5090:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3348#discussion_r105753418
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateMetrics.java
---
@@ -0,0 +1,168 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922810#comment-15922810
]
Billy Newport commented on FLINK-6022:
--
Thanks for this Robert. Basically to help wit
Kostas Kloudas created FLINK-6032:
-
Summary: CEP-Clean up the operator state when not needed.
Key: FLINK-6032
URL: https://issues.apache.org/jira/browse/FLINK-6032
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-5756:
Description:
When using RocksDB as the StateBackend, if there are many values under the same
key in
[
https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922776#comment-15922776
]
ASF GitHub Bot commented on FLINK-5975:
---
Github user addisonj commented on the issue
Github user addisonj commented on the issue:
https://github.com/apache/flink/pull/3481
@EronWright @zentol minor bump on this... any other steps to get this on
the path to being merged?
Don't want to let this hang out for too long so I forgot about it :)
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-6007.
-
Resolution: Fixed
> ConcurrentModificationException in WatermarkCallbackService
>
[
https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922767#comment-15922767
]
ASF GitHub Bot commented on FLINK-6007:
---
Github user kl0u closed the pull request at
[
https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922766#comment-15922766
]
ASF GitHub Bot commented on FLINK-6007:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3514
Merged at 14c1941d8eaa583eb8f7eeb5478e605850c0d355
---
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 feat
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3514
---
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 enable
[
https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922763#comment-15922763
]
Kostas Kloudas commented on FLINK-6007:
---
Merged at 14c1941d8eaa583eb8f7eeb5478e60585
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/3348#discussion_r105742696
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGateMetrics.java
---
@@ -0,0 +1,168 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922732#comment-15922732
]
Luke Hutchison commented on FLINK-6026:
---
Makes sense, I wondered if that may be the
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922726#comment-15922726
]
ASF GitHub Bot commented on FLINK-5090:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922699#comment-15922699
]
Luke Hutchison commented on FLINK-6024:
---
This was for the batch API (DataSet).
More
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3040
Thanks for the update @tonycox. I haven't looked at the new changes yet but
just commented on the join. Please let me know if you have further questions.
Thanks, Fabian
---
If your project
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105731937
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala
---
@@ -199,10 +200,21 @@ class DataSetJoin
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15917780#comment-15917780
]
ASF GitHub Bot commented on FLINK-3850:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15917356#comment-15917356
]
ASF GitHub Bot commented on FLINK-3850:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907875#comment-15907875
]
ASF GitHub Bot commented on FLINK-3850:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
@fhueske I fixed commented points.
Could you explain the join keys forwarding?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105712740
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableSourceUtil.scala
---
@@ -0,0 +1,146 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105714201
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSourceConverter.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105704013
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ReadonlyExternalCatalog.scala
---
@@ -0,0 +1,72 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105703538
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/InMemoryExternalCatalog.scala
---
@@ -0,0 +1,155 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105703767
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CRUDExternalCatalog.scala
---
@@ -0,0 +1,110 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2491:
Summary: Checkpointing only works if all operators/tasks are still running
(was: Operators
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2491:
Component/s: (was: Streaming)
State Backends, Checkpointing
[
https://issues.apache.org/jira/browse/FLINK-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907858#comment-15907858
]
Aljoscha Krettek commented on FLINK-2263:
-
[~StephanEwen] and [~till.rohrmann] is
[
https://issues.apache.org/jira/browse/FLINK-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5222.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed as part of another change.
> Rename State
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5991:
Component/s: (was: Streaming)
DataStream API
> Expose Broadcast Operato
[
https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4858:
Component/s: (was: Streaming)
DataStream API
> Remove Legacy Checkpoint
[
https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907793#comment-15907793
]
ASF GitHub Bot commented on FLINK-5823:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3522
CI tests pass (except one profile which does not complete within the limit
of 50 minutes)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907780#comment-15907780
]
ASF GitHub Bot commented on FLINK-5846:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3445#discussion_r105707379
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
---
@@ -75,9 +94,15 @@ public void testKeyedCEPFunctionMi
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105700201
--- 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,
fin
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105702715
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
---
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Soft
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105700521
--- 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,
fin
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105697591
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/ComputationState.java
---
@@ -52,14 +57,35 @@ public ComputationState(
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105702140
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/InvalidPatternException.java
---
@@ -0,0 +1,28 @@
+/*
+ * Licensed to th
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105699655
--- 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,
fin
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105704530
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105697452
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/ComputationState.java
---
@@ -41,8 +43,11 @@
// Timestamp of the first eleme
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105698150
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -71,19 +70,16 @@
private final NonDuplicatingTypeSerializer
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105699988
--- 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,
fin
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105700500
--- 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,
fin
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105704399
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105698031
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -71,19 +70,16 @@
private final NonDuplicatingTypeSerializer
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105704335
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105699441
--- 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 kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105704267
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java
---
@@ -272,37 +372,42 @@ public void testBranchingPattern() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105702323
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/compiler/NFACompilerTest.java
---
@@ -18,9 +18,13 @@
package org.apache.f
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105698626
--- 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 kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105701064
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -217,23 +217,22 @@ public void prune(long pruningTimestamp)
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105700356
--- 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,
fin
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r105701669
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/StateTransition.java
---
@@ -55,6 +65,7 @@ public boolean equals(Object obj) {
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-3123.
Resolution: Fixed
Fix Version/s: 1.3.0
Resolved for {{master}} with
http://g
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-5949:
--
Assignee: Tzu-Li (Gordon) Tai
> Flink on YARN checks for Kerberos credentials f
[
https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6025.
Resolution: Fixed
Fix Version/s: 1.2.1
1.1.5
[
https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907695#comment-15907695
]
ASF GitHub Bot commented on FLINK-5441:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3107
Thanks for the quick update @wuchong. The code looks good to merge. Can you
add some documentation to the SQL section?
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907692#comment-15907692
]
ASF GitHub Bot commented on FLINK-6025:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3517
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/2687
---
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
1 - 100 of 265 matches
Mail list logo
