[
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 + "-"
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
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
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381024#comment-16381024
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380880#comment-16380880
]
ASF GitHub Bot commented on FLINK-8538:
---
Github user xccui commented on a diff in the pull request:
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-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-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380925#comment-16380925
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff in the pull
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-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8813:
Labels: flip-6 (was: )
> AutoParallellismITCase fails with Flip6
>
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380927#comment-16380927
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380928#comment-16380928
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff in the pull
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 @@
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380926#comment-16380926
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380924#comment-16380924
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user walterddr commented on a diff in the pull
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
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_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_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 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
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
[
https://issues.apache.org/jira/browse/FLINK-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381072#comment-16381072
]
ASF GitHub Bot commented on FLINK-8814:
---
GitHub user jelmerk opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381095#comment-16381095
]
ASF GitHub Bot commented on FLINK-7805:
---
Github user asfgit closed the pull request at:
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:
[
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()
>
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-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381159#comment-16381159
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user jahandarm commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381361#comment-16381361
]
mingleizhang commented on FLINK-8813:
-
Can not open
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
[
https://issues.apache.org/jira/browse/FLINK-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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 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 »
[
https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381479#comment-16381479
]
vinoyang commented on FLINK-5621:
-
Hi [~jgrier] What about we can introduce "tm tag / label"
[
https://issues.apache.org/jira/browse/FLINK-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381481#comment-16381481
]
Chesnay Schepler commented on FLINK-8813:
-
hmm, i can load the job page, but the logs aren't being
[
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
>
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-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381469#comment-16381469
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user Xpray commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381476#comment-16381476
]
Sihua Zhou commented on FLINK-8753:
---
Sorry for the interruption, but after have a look at the code of
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
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=16381583#comment-16381583
]
ASF GitHub Bot commented on FLINK-8817:
---
GitHub user sihuazhou opened a pull request:
[
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
>
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
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:
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:
[
https://issues.apache.org/jira/browse/FLINK-8817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381585#comment-16381585
]
ASF GitHub Bot commented on FLINK-8817:
---
Github user sihuazhou commented on the issue:
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-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-5231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381428#comment-16381428
]
vinoyang commented on FLINK-5231:
-
Hi [~StephanEwen] the JDK8, (more precisely since JDK 8u92, pelase see
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16381565#comment-16381565
]
ASF GitHub Bot commented on FLINK-8667:
---
Github user bowenli86 commented on the issue:
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-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381422#comment-16381422
]
ASF GitHub Bot commented on FLINK-8816:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381456#comment-16381456
]
ASF GitHub Bot commented on FLINK-8808:
---
Github user zhangminglei commented on the issue:
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 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-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-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381647#comment-16381647
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
[
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-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380277#comment-16380277
]
ASF GitHub Bot commented on FLINK-8560:
---
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/5481#discussion_r171237037
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala
---
@@ -79,7 +78,34 @@ class KeyedStream[T,
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380280#comment-16380280
]
ASF GitHub Bot commented on FLINK-8560:
---
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/5481#discussion_r171234582
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -321,19 +324,80 @@ private boolean
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380274#comment-16380274
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380272#comment-16380272
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380275#comment-16380275
]
ASF GitHub Bot commented on FLINK-8560:
---
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/5481#discussion_r171235356
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/KeyedProcessFunction.java
---
@@ -0,0 +1,130 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380281#comment-16380281
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380273#comment-16380273
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380276#comment-16380276
]
ASF GitHub Bot commented on FLINK-8560:
---
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/5481#discussion_r171236298
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala
---
@@ -54,21 +54,20 @@ class KeyedStream[T,
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5481#discussion_r171233924
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -321,19 +324,80 @@ private boolean
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380279#comment-16380279
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380278#comment-16380278
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user kl0u commented on a diff in the pull request:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5581
ok, fixed the tests again which broke with
11981d9173ccef2236fce6b3f30d1ef467a91d6f
---
[
https://issues.apache.org/jira/browse/FLINK-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380335#comment-16380335
]
ASF GitHub Bot commented on FLINK-8755:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380262#comment-16380262
]
Stefan Richter commented on FLINK-8413:
---
[~suganyap] and [~aljoscha] are there any updates on this
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253705
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -801,12 +788,12 @@ public long extractTimestamp(String
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253807
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -847,12 +834,12 @@ public long extractTimestamp(String
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253672
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -801,12 +788,12 @@ public long extractTimestamp(String
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253650
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -740,24 +734,17 @@ public void testProcessTranslation()
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253550
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -701,19 +701,13 @@ public void
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171252476
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java
---
@@ -163,12 +163,16 @@ public
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253833
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -847,12 +834,12 @@ public long extractTimestamp(String
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253575
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -701,19 +701,13 @@ public void
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171252831
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java
---
@@ -288,7 +288,7 @@ public long
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171252617
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java
---
@@ -118,7 +118,7 @@
*
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253126
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperatorTest.java
---
@@ -220,7 +227,8 @@ public
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253275
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperatorTest.java
---
@@ -381,26 +392,28 @@
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171252385
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java
---
@@ -163,12 +163,16 @@ public
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253604
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -740,24 +734,17 @@ public void testProcessTranslation()
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5500#discussion_r171253628
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -740,24 +734,17 @@ public void testProcessTranslation()
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-8557:
-
Assignee: Stefan Richter
> OperatorSubtaskDescriptionText causes failures on Windows
>
Till Rohrmann created FLINK-8808:
Summary: Enable RestClusterClient to submit jobs to local
Dispatchers
Key: FLINK-8808
URL: https://issues.apache.org/jira/browse/FLINK-8808
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380346#comment-16380346
]
ASF GitHub Bot commented on FLINK-8667:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380352#comment-16380352
]
ASF GitHub Bot commented on FLINK-8667:
---
Github user kl0u commented on a diff in the pull request:
1 - 100 of 341 matches
Mail list logo
