[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381647#comment-16381647
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5174
@Xpray Yes, I think for a long term solution we should move some variables
in the member area but I don't know if it makes sense to move all local
variables there. We should fix the `expandLocalRef`
[
https://issues.apache.org/jira/browse/FLINK-5809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-5809:
Issue Type: Improvement (was: Bug)
> Add registerNextWatermarkCallback() to TimerService
>
[
https://issues.apache.org/jira/browse/FLINK-5809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-5809:
---
Assignee: Bowen Li
> Add registerNextWatermarkCallback() to TimerService
> --
[
https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8799:
---
Assignee: vinoyang
> Make AbstractYarnClusterDescriptor immutable
> -
[
https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-8799:
---
Assignee: (was: Bowen Li)
> Make AbstractYarnClusterDescriptor immutable
> --
[
https://issues.apache.org/jira/browse/FLINK-8817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381585#comment-16381585
]
ASF GitHub Bot commented on FLINK-8817:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5605
Hi @tillrohrmann , Could you please have a look at this?
---
[
https://issues.apache.org/jira/browse/FLINK-8817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381583#comment-16381583
]
ASF GitHub Bot commented on FLINK-8817:
---
GitHub user sihuazhou opened a pull request
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5605
[FLINK-8817][Distributed Coordination] Decrement
numPendingContainerRequests only when request container successfully
## What is the purpose of the change
This PR address
[FLINK-8817](ht
[
https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-8799:
---
Assignee: Bowen Li
> Make AbstractYarnClusterDescriptor immutable
> -
Sihua Zhou created FLINK-8817:
-
Summary: Decrement numPendingContainerRequests only when request
container successfully
Key: FLINK-8817
URL: https://issues.apache.org/jira/browse/FLINK-8817
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381564#comment-16381564
]
ASF GitHub Bot commented on FLINK-7836:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381565#comment-16381565
]
ASF GitHub Bot commented on FLINK-8667:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5500
@kl0u @aljoscha I've updated this PR, and its build is green
---
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5593
Hi @tillrohrmann should do more work for this PR?
---
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/6c44d93d0a9da725ef8b1ad2a94889f79321db73#commitcomment-27855304
In flink-dist/src/main/flink-bin/bin/taskmanager.sh:
In flink-dist/src/main/flink-bin/bin/taskmanager.sh on line 64:
`8388607
[
https://issues.apache.org/jira/browse/FLINK-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381481#comment-16381481
]
Chesnay Schepler commented on FLINK-8813:
-
hmm, i can load the job page, but the l
[
https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381479#comment-16381479
]
vinoyang commented on FLINK-5621:
-
Hi [~jgrier] What about we can introduce "tm tag / labe
[
https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381476#comment-16381476
]
Sihua Zhou commented on FLINK-8753:
---
Sorry for the interruption, but after have a look a
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381469#comment-16381469
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user Xpray commented on the issue:
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/5174
Thanks @twalthr, that's great, I'm also working on another issue trying to
move all local variables to class field, that'll make code split more
convenient.
---
[
https://issues.apache.org/jira/browse/FLINK-8808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381456#comment-16381456
]
ASF GitHub Bot commented on FLINK-8808:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5599
I watched the code and think it is very good. But the travis says
```
Results :
Tests in error:
FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint:333 »
Test
[
https://issues.apache.org/jira/browse/FLINK-5231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381428#comment-16381428
]
vinoyang commented on FLINK-5231:
-
Hi [~StephanEwen] the JDK8, (more precisely since JDK 8
[
https://issues.apache.org/jira/browse/FLINK-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381422#comment-16381422
]
ASF GitHub Bot commented on FLINK-8816:
---
Github user sihuazhou commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381420#comment-16381420
]
ASF GitHub Bot commented on FLINK-8816:
---
GitHub user sihuazhou opened a pull request
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5604
Hi, @tillrohrmann Could you please have a look at this?
---
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5604
[FLINK-8816][ResourceManager] Remove the oldWorker only after starting
newWorker successfully
## What is the purpose of the change
This PR address
[FLINK-8816](https://issues.apache.org/
Sihua Zhou created FLINK-8816:
-
Summary: Remove the oldWorker only after starting newWorker
successfully in registerTaskExecutorInternal()
Key: FLINK-8816
URL: https://issues.apache.org/jira/browse/FLINK-8816
benwang li created FLINK-8815:
-
Summary: EventTime won't work as reduce
Key: FLINK-8815
URL: https://issues.apache.org/jira/browse/FLINK-8815
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381397#comment-16381397
]
ASF GitHub Bot commented on FLINK-8037:
---
Github user tedyu commented on the issue:
Github user yuqi1129 commented on the pull request:
https://github.com/apache/flink/commit/6c44d93d0a9da725ef8b1ad2a94889f79321db73#commitcomment-27853406
In flink-dist/src/main/flink-bin/bin/taskmanager.sh:
In flink-dist/src/main/flink-bin/bin/taskmanager.sh on line 64:
Why th
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/5205
Looks like the PR needs to be rebased.
---
[
https://issues.apache.org/jira/browse/FLINK-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381361#comment-16381361
]
mingleizhang commented on FLINK-8813:
-
Can not open [https://travis-ci.org/zentol/flin
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381159#comment-16381159
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user jahandarm commented on a diff i
Github user jahandarm commented on a diff in the pull request:
https://github.com/apache/flink/pull/5174#discussion_r171410369
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CalcWithSplitCodeGenITCase.scala
---
@@ -0,0 +1,385 @@
[
https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8667:
Fix Version/s: 1.6.0
> expose key in KeyedBroadcastProcessFunction#onTimer()
> -
[
https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381095#comment-16381095
]
ASF GitHub Bot commented on FLINK-7805:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5597
---
[
https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7805.
Resolution: Fixed
Fix Version/s: 1.6.0
1.5.0
Fixed via
1.6.0: 45397fe974e
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381072#comment-16381072
]
ASF GitHub Bot commented on FLINK-8814:
---
GitHub user jelmerk opened a pull request:
GitHub user jelmerk opened a pull request:
https://github.com/apache/flink/pull/5603
[FLINK-8814] Control over the extension of part files created by
BucketingSink
## What is the purpose of the change
Popular tools like hue and the avro connector for spark require files
st
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381024#comment-16381024
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5174
Thanks for the PR @Xpray and the review @walterddr. I also looked over the
changes and saw multiple issues that need to be fixed. If it is ok for you, I
would add some commits to this one and open a
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jelmer Kuperus updated FLINK-8814:
--
Description:
BucketingSink creates files with the following pattern
{noformat}
partPrefix + "-"
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jelmer Kuperus updated FLINK-8814:
--
Description:
BucketingSink creates files with the following pattern
{noformat}
partPrefix + "-"
Jelmer Kuperus created FLINK-8814:
-
Summary: Control over the extension of part files created by
BucketingSink
Key: FLINK-8814
URL: https://issues.apache.org/jira/browse/FLINK-8814
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380925#comment-16380925
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380927#comment-16380927
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380928#comment-16380928
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380924#comment-16380924
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380926#comment-16380926
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff i
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5174#discussion_r171346253
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CalcWithSplitCodeGenITCase.scala
---
@@ -0,0 +1,385 @@
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5174#discussion_r170804955
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/FunctionCodeGenerator.scala
---
@@ -41,7 +41,7 @@ import org.apache.fl
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5174#discussion_r171360773
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CalcWithSplitCodeGenITCase.scala
---
@@ -0,0 +1,385 @@
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5174#discussion_r171358583
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala
---
@@ -46,10 +47,22 @@ trait CommonCalc {
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5174#discussion_r171357748
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala
---
@@ -171,4 +186,47 @@ trait CommonCalc {
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5564#discussion_r171354820
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -67,14 +85,129 @@ class SchemaValidator(i
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380880#comment-16380880
]
ASF GitHub Bot commented on FLINK-8538:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8813:
Labels: flip-6 (was: )
> AutoParallellismITCase fails with Flip6
>
Chesnay Schepler created FLINK-8813:
---
Summary: AutoParallellismITCase fails with Flip6
Key: FLINK-8813
URL: https://issues.apache.org/jira/browse/FLINK-8813
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-8812:
---
Summary: Possible resource leak in Flip6
Key: FLINK-8812
URL: https://issues.apache.org/jira/browse/FLINK-8812
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380726#comment-16380726
]
ASF GitHub Bot commented on FLINK-8801:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5602
[FLINK-8801][yarn/s3] fix Utils#setupLocalResource() relying on consistent
read-after-write
## What is the purpose of the change
> Amazon S3 provides read-after-write consistency for PUTS of
[
https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380710#comment-16380710
]
ASF GitHub Bot commented on FLINK-8336:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5601
[FLINK-8336][yarn/s3][tests] harden YarnFileStageTest upload test for
eventual consistent read-after-write
## What is the purpose of the change
In case the newly written object cannot be read
[
https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380708#comment-16380708
]
ASF GitHub Bot commented on FLINK-7805:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380707#comment-16380707
]
ASF GitHub Bot commented on FLINK-7805:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5597#discussion_r171323432
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/RegisterApplicationMasterResponseReflector.java
---
@@ -0,0 +1,103 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5597#discussion_r171323504
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/RegisterApplicationMasterResponseReflectorTest.java
---
@@ -0,0 +1,115 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380702#comment-16380702
]
Till Rohrmann commented on FLINK-8770:
--
I actually don't know how it can happen that
[
https://issues.apache.org/jira/browse/FLINK-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380700#comment-16380700
]
ASF GitHub Bot commented on FLINK-8755:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5581
one more rebase onto latest master to fix merge conflicts - good to go
after travis is green
---
[
https://issues.apache.org/jira/browse/FLINK-8811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380689#comment-16380689
]
ASF GitHub Bot commented on FLINK-8811:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5600
[FLINK-8811] [flip6] Add initial implementation of the MiniClusterClient
## What is the purpose of the change
The MiniClusterClient directly talks to the MiniCluster avoiding polling
[
https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-8747.
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in
- master via
[6e9e0dd6eb3c4fdb1168cc4e294d
[
https://issues.apache.org/jira/browse/FLINK-8760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8760.
-
Resolution: Fixed
Fix Version/s: 1.5.0
> Correctly set `moreAvailable` flag in SingleInputG
Till Rohrmann created FLINK-8811:
Summary: Add MiniClusterClient to allow fast MiniCluster operations
Key: FLINK-8811
URL: https://issues.apache.org/jira/browse/FLINK-8811
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-8760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reopened FLINK-8760:
---
> Correctly set `moreAvailable` flag in SingleInputGate and UnionInputGate
> -
[
https://issues.apache.org/jira/browse/FLINK-8694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8694.
-
Resolution: Fixed
Fix Version/s: 1.5.0
> Make notifyDataAvailable call reliable
> -
[
https://issues.apache.org/jira/browse/FLINK-8694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reopened FLINK-8694:
---
> Make notifyDataAvailable call reliable
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-8737.
Resolution: Fixed
Fixed in
- master via
[e8de53817c60917776c7264623cf8adfd7886f93|https://github.
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380666#comment-16380666
]
ASF GitHub Bot commented on FLINK-7866:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/4949
@tillrohrmann I have updated the PR ... Could you please have a loot at
this now or just wait until 1.5 release out?
---
Aljoscha Krettek created FLINK-8810:
---
Summary: Move end-to-end test scripts to end-to-end module
Key: FLINK-8810
URL: https://issues.apache.org/jira/browse/FLINK-8810
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380634#comment-16380634
]
ASF GitHub Bot commented on FLINK-8737:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5583
---
[
https://issues.apache.org/jira/browse/FLINK-8805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8805.
-
Resolution: Fixed
> Optimize EventSerializer.isEvent method
>
[
https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380611#comment-16380611
]
Timo Walther commented on FLINK-8537:
-
[~xccui] yes, I think that makes sense. In a lo
[
https://issues.apache.org/jira/browse/FLINK-8760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8760.
-
Resolution: Fixed
> Correctly set `moreAvailable` flag in SingleInputGate and UnionInputGate
> ---
[
https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380599#comment-16380599
]
ASF GitHub Bot commented on FLINK-8747:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8750.
-
Resolution: Fixed
> InputGate may contain data after an EndOfPartitionEvent
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5558
---
[
https://issues.apache.org/jira/browse/FLINK-8694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8694.
-
Resolution: Fixed
> Make notifyDataAvailable call reliable
> -
[
https://issues.apache.org/jira/browse/FLINK-8694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380589#comment-16380589
]
ASF GitHub Bot commented on FLINK-8694:
---
Github user pnowojski commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380590#comment-16380590
]
ASF GitHub Bot commented on FLINK-8694:
---
Github user pnowojski closed the pull reque
Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/5572
---
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5572
Thanks for merging :)
---
[
https://issues.apache.org/jira/browse/FLINK-8750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380576#comment-16380576
]
ASF GitHub Bot commented on FLINK-8750:
---
Github user asfgit closed the pull request
1 - 100 of 341 matches
Mail list logo
