[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837834#comment-15837834
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97790271
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -130,26 +114,166 @@
}
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837835#comment-15837835
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837831#comment-15837831
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97790228
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -130,26 +114,166 @@
}
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837828#comment-15837828
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837830#comment-15837830
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837832#comment-15837832
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837833#comment-15837833
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97790385
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -130,26 +114,166 @@
}
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97789988
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -130,26 +114,166 @@
}
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97789900
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -130,26 +114,166 @@
}
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97789775
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -80,25 +82,17 @@
// return
[
https://issues.apache.org/jira/browse/FLINK-5599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837815#comment-15837815
]
Aljoscha Krettek commented on FLINK-5599:
-
Definite +1, yes.
> State interface docs often refer
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837809#comment-15837809
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2836#discussion_r97788511
--- Diff: flink-contrib/flink-storm-examples/pom.xml ---
@@ -364,6 +363,18 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837807#comment-15837807
]
ASF GitHub Bot commented on FLINK-5638:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3210
Agreed, the problem is a little bit that you don't control from where the
`close` method is called... Thanks for the review @StephanEwen.
Merging once Travis has passed.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837805#comment-15837805
]
ASF GitHub Bot commented on FLINK-5643:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5643.
Resolution: Fixed
1.3.0: cf9f4c77c8e785567f036cc2fbb97c0cd16979a7
1.2.0:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3212
---
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-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837800#comment-15837800
]
ASF GitHub Bot commented on FLINK-5643:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3212
Forwarding review from #3213. Merging this PR.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837798#comment-15837798
]
ASF GitHub Bot commented on FLINK-5643:
---
Github user tillrohrmann closed the pull request at:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/3213
---
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
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3213
Thanks for the review @rmetzger. Merging this PR.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837795#comment-15837795
]
ASF GitHub Bot commented on FLINK-5643:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837776#comment-15837776
]
ASF GitHub Bot commented on FLINK-5546:
---
Github user shijinkui commented on the issue:
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/3190
@greghogan That make sense. Let JUnit to create root dir and delete
temporary dir recursively.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3214
[FLINK-5644] Remove metric: Task#lastCheckpointSize
This PR removes the lastCheckpointSize metric that was broken when the
key-groups were introduced. I couldn't find an easy way to fix it instead.
[
https://issues.apache.org/jira/browse/FLINK-5644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837773#comment-15837773
]
ASF GitHub Bot commented on FLINK-5644:
---
GitHub user zentol opened a pull request:
Chesnay Schepler created FLINK-5644:
---
Summary: Task#lastCheckpointSize metric broken
Key: FLINK-5644
URL: https://issues.apache.org/jira/browse/FLINK-5644
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837769#comment-15837769
]
Aljoscha Krettek commented on FLINK-5551:
-
I think this can happen when canceling happens before
[
https://issues.apache.org/jira/browse/FLINK-5637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-5637:
-
Assignee: Robert Metzger
> Default Flink configuration contains whitespace characters,
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837761#comment-15837761
]
ASF GitHub Bot commented on FLINK-5643:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837760#comment-15837760
]
Chesnay Schepler commented on FLINK-5516:
-
Yeah this is easy to implement; it is pretty much a
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3213
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-5492.
---
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
> BootstrapTools log
[
https://issues.apache.org/jira/browse/FLINK-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837756#comment-15837756
]
Robert Metzger commented on FLINK-5492:
---
Fixed for 1.2 in
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3213
[FLINK-5643] Fix NPE in StateUtil
Introduces a null check to deal with state futures which have a null value.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837752#comment-15837752
]
ASF GitHub Bot commented on FLINK-5643:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837750#comment-15837750
]
Robert Metzger commented on FLINK-5229:
---
Thank you!
> Cleanup StreamTaskStates if a checkpoint
[
https://issues.apache.org/jira/browse/FLINK-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837751#comment-15837751
]
ASF GitHub Bot commented on FLINK-5643:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3212
[FLINK-5643] Fix NPE in StateUtil
Introduces a null check to deal with state futures which have a null value.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837748#comment-15837748
]
Till Rohrmann commented on FLINK-5229:
--
Will be addressed with FLINK-5643.
> Cleanup
Till Rohrmann created FLINK-5643:
Summary: StateUtil.discardStateFuture fails when state future
contains null value
Key: FLINK-5643
URL: https://issues.apache.org/jira/browse/FLINK-5643
Project:
[
https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837744#comment-15837744
]
Aljoscha Krettek commented on FLINK-5516:
-
[~Zentol] would this be possible?
I think no one is
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Efimov closed FLINK-4905.
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed by Stephan Ewen
> Kafka test instability
[
https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837740#comment-15837740
]
Till Rohrmann commented on FLINK-5229:
--
Should be fixed. Apparently, there are state handle futures
[
https://issues.apache.org/jira/browse/FLINK-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5641:
--
Attachment: application-1485249546281-0021-misbehaved-1.2.0-rc1
> Directories of expired
Nico Kruber created FLINK-5642:
--
Summary: queryable state: race condition with HeadListState
Key: FLINK-5642
URL: https://issues.apache.org/jira/browse/FLINK-5642
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837738#comment-15837738
]
Robert Metzger commented on FLINK-5641:
---
I have a job that has expiring checkpoints.
I'll attach the
[
https://issues.apache.org/jira/browse/FLINK-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837736#comment-15837736
]
Till Rohrmann commented on FLINK-5641:
--
[~rmetzger] how have you produced this?
> Directories of
[
https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837735#comment-15837735
]
Robert Metzger commented on FLINK-5229:
---
I'm seeing the following exceptions in my 1.2.0 RC1 code
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3207#discussion_r97775252
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
---
@@ -279,6 +286,202 @@ public
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837730#comment-15837730
]
ASF GitHub Bot commented on FLINK-5630:
---
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/3207#discussion_r97774934
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
---
@@ -279,6 +286,202 @@ public
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837729#comment-15837729
]
ASF GitHub Bot commented on FLINK-5630:
---
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/3207#discussion_r97776155
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
---
@@ -515,12 +515,16 @@ public
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837731#comment-15837731
]
ASF GitHub Bot commented on FLINK-5630:
---
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/3207#discussion_r97773952
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -18,14 +18,37 @@
package
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837733#comment-15837733
]
ASF GitHub Bot commented on FLINK-5630:
---
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/3207#discussion_r97774041
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -81,14 +104,55 @@
* }
* }
* }
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3207#discussion_r97776428
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AllWindowTranslationTest.java
---
@@ -101,6 +108,24 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3207#discussion_r97775106
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
---
@@ -279,6 +286,202 @@ public
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837732#comment-15837732
]
ASF GitHub Bot commented on FLINK-5630:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837728#comment-15837728
]
ASF GitHub Bot commented on FLINK-5630:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837734#comment-15837734
]
ASF GitHub Bot commented on FLINK-5630:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-5641:
Assignee: Till Rohrmann
> Directories of expired checkpoints are not cleaned up
>
[
https://issues.apache.org/jira/browse/FLINK-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837726#comment-15837726
]
Till Rohrmann commented on FLINK-5492:
--
Arg, you're right. The grizzled logger used in the Scala
[
https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-4719:
---
Assignee: (was: Nico Kruber)
> KryoSerializer random exception
> ---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3210
It's a bit hacky to release the lock in scope via `wait()` but seems to
work.
One more reason to go for a post-box model...
+1
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837722#comment-15837722
]
ASF GitHub Bot commented on FLINK-5638:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837721#comment-15837721
]
ASF GitHub Bot commented on FLINK-4905:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837720#comment-15837720
]
Robert Metzger commented on FLINK-5492:
---
I will provide a fix for the issue.
> BootstrapTools log
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3035
I pushed a fix for that to master in
e7cda75b8594417559d6aac6229b5893f5459f0f
---
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-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5640:
-
Description:
There are four types of Unit Test file: *ITCase.java, *Test.java,
*ITSuite.scala,
[
https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837719#comment-15837719
]
ASF GitHub Bot commented on FLINK-5640:
---
GitHub user shijinkui opened a pull request:
GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/3211
c[FLINK-5640][test]onfigure the explicit Unit Test file suffix
There are four types of Unit Test file: *ITCase.java, *Test.java,
*ITSuite.scala, *Suite.scala
File name ending with "IT.java"
[
https://issues.apache.org/jira/browse/FLINK-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837716#comment-15837716
]
ASF GitHub Bot commented on FLINK-5638:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837717#comment-15837717
]
ASF GitHub Bot commented on FLINK-5638:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3210
[FLINK-5638] [asyncIO] Fix deadlock when closing two chained
AsyncWaitOperators
This PR is a backport of #3209 onto `release-1.2.`
This PR addresses the problem by changing the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3209
[FLINK-5638] [asyncIO] Fix deadlock when closing two chained
AsyncWaitOperators
This PR addresses the problem by changing the Emitter's behaviour to first
output the
element before
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837713#comment-15837713
]
ASF GitHub Bot commented on FLINK-4905:
---
Github user BrainLogic commented on the issue:
Github user BrainLogic commented on the issue:
https://github.com/apache/flink/pull/3035
I caught yours idea and together with the argument which I mentioned above
- users will not extensively use 8 version of kafka connector, I agree with
this proposal.
Let me finish this jira,
[
https://issues.apache.org/jira/browse/FLINK-5628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-5628:
--
Assignee: Ufuk Celebi
> CheckpointStatsTracker implements Serializable but isn't
>
[
https://issues.apache.org/jira/browse/FLINK-5608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837708#comment-15837708
]
ASF GitHub Bot commented on FLINK-5608:
---
Github user uce commented on the issue:
Robert Metzger created FLINK-5641:
-
Summary: Directories of expired checkpoints are not cleaned up
Key: FLINK-5641
URL: https://issues.apache.org/jira/browse/FLINK-5641
Project: Flink
Issue
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3189
Good point. @rehevkor5 is it possible to only hide the color boxes when the
browser window is very narrow?
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5638:
-
Fix Version/s: (was: 1.2.1)
1.2.0
> Deadlock when closing two chained
[
https://issues.apache.org/jira/browse/FLINK-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5638:
-
Description:
The {{AsyncWaitOperator}} can deadlock in a special cases when closing two
chained
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3208
[hotfix] [rat] Add exclusion for rolling-sink snapshot
Adds a RAT exclusion for the rolling sink snapshot used for testing
backwards compatibility. Note that the RAT plugin only complains about
[
https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837691#comment-15837691
]
ASF GitHub Bot commented on FLINK-5634:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3204
Looks good to me, +1
@uce the ScriptMeister should probably give his blessing as well...
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837684#comment-15837684
]
ASF GitHub Bot commented on FLINK-4905:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3035
I this case, the exception would not be logged, true.
It is a very rare corner case that should not affect correctness, and not
really distinguishable from the case where an exception is
shijinkui created FLINK-5640:
Summary: configure the explicit Unit Test file suffix
Key: FLINK-5640
URL: https://issues.apache.org/jira/browse/FLINK-5640
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837665#comment-15837665
]
ASF GitHub Bot commented on FLINK-4905:
---
Github user BrainLogic commented on the issue:
Github user BrainLogic commented on the issue:
https://github.com/apache/flink/pull/3035
Distributed systems and multithreading environments make us think in term
of logical clock, like Lamport clock, step by step:
Thread1 - fetcher is running `running = true`
Thread2 performs
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3206#discussion_r97768800
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/io/GlobFilePathFilterTest.java
---
@@ -138,4 +141,30 @@ public void doubleStarPattern() {
201 - 300 of 375 matches
Mail list logo
