GitHub user phiradet opened a pull request:
https://github.com/apache/flink/pull/4704
[hotfix] [docs] Update function name in DataStream API
Currently, the `javaStream` should be used to get the underlying java
DataStream object -- not `getJavaStream`
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16176009#comment-16176009
]
Bowen Li commented on FLINK-7388:
-
Interesting one. I just got some experience on ProcessF
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7388:
---
Assignee: Bowen Li
> ProcessFunction.onTimer() sets processing time as timestamp
> --
[
https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175981#comment-16175981
]
Bowen Li commented on FLINK-7433:
-
[~tedyu] Hi Ted, this seems to be a dup of FLINK-7659.
[
https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-7433.
---
Resolution: Duplicate
> Lack of synchronization accessing inProgress in
> JobCancellationWithSavepointHandler
[
https://issues.apache.org/jira/browse/FLINK-7592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175977#comment-16175977
]
Bowen Li commented on FLINK-7592:
-
Hi, are you requesting a feature or asking this specifi
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175963#comment-16175963
]
Bowen Li commented on FLINK-5726:
-
[~longda] Hi Longda, I'm curious that is Alibaba's BLIN
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175953#comment-16175953
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , I missed that message of `verifyAllBuffersReturned()` issue before.
I have submitted the modifications of it. :)
---
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4703
[FLINK-7659][REST] Unprotected access to inProgress in
JobCancellationWithSavepointHandlers#handleNewRequest
## What is the purpose of the change
There's a thread accessing `inProgress` w
[
https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175942#comment-16175942
]
ASF GitHub Bot commented on FLINK-7659:
---
GitHub user bowenli86 opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7659:
Component/s: REST
> Unprotected access to inProgress in
> JobCancellationWithSavepointHandlers#handleNewReq
[
https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7659:
---
Assignee: Bowen Li
> Unprotected access to inProgress in
> JobCancellationWithSavepointHandlers#hand
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175888#comment-16175888
]
ASF GitHub Bot commented on FLINK-7635:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4702
@aljoscha @chenqin Hi guys, can you please take a look? I'll write doc
about this feature with
[FLINK-7660](https://issues.apache.org/jira/browse/FLINK-7660). BTW, this is
my first time writing S
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175800#comment-16175800
]
ASF GitHub Bot commented on FLINK-7635:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4702
[FLINK-7635][DataStream API][Scala API] Support sideOutput in
ProcessWindowFunciton
## What is the purpose of the change
Add support for sideOutput in ProcessWindowFunciton
## Ve
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175658#comment-16175658
]
Till Rohrmann commented on FLINK-4319:
--
Hi [~suez1224],
thanks for testing out the c
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175656#comment-16175656
]
Till Rohrmann commented on FLINK-7076:
--
Hi [~yuemeng], are you still working on this?
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175640#comment-16175640
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4691#discussion_r140380156
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ClusterConfigHandler.java
---
@@ -33,20 +43,27 @@
/**
* R
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175639#comment-16175639
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175638#comment-16175638
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4691#discussion_r140381187
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterConfiguration.java
---
@@ -0,0 +1,57 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175637#comment-16175637
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175641#comment-16175641
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4691#discussion_r140382392
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterConfiguration.java
---
@@ -0,0 +1,57 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4691#discussion_r140381079
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterConfiguration.java
---
@@ -0,0 +1,57 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4691#discussion_r140379775
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java
---
@@ -55,16 +59,19 @@
public class Dispatc
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4689
---
[
https://issues.apache.org/jira/browse/FLINK-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175614#comment-16175614
]
ASF GitHub Bot commented on FLINK-7655:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7655.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via 42cc3a2a9c41dda7cf338db36b45131db9150674
>
[
https://issues.apache.org/jira/browse/FLINK-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175609#comment-16175609
]
ASF GitHub Bot commented on FLINK-7655:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4689
Travis passed. Merging this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175494#comment-16175494
]
Shuyi Chen commented on FLINK-4319:
---
Hi [~till.rohrmann], thanks a lot for the pointers.
Ufuk Celebi created FLINK-7666:
--
Summary: ContinuousFileReaderOperator swallows chained watermarks
Key: FLINK-7666
URL: https://issues.apache.org/jira/browse/FLINK-7666
Project: Flink
Issue Type
Ufuk Celebi created FLINK-7665:
--
Summary: Use wait/notify in ContinuousFileReaderOperator
Key: FLINK-7665
URL: https://issues.apache.org/jira/browse/FLINK-7665
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-7664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175144#comment-16175144
]
ASF GitHub Bot commented on FLINK-7664:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4701
[FLINK-7664] Replace FlinkFutureException by
java.util.concurrent.CompletionException
## What is the purpose of the change
FlinkFutureException was introduced to fail a CompletableFutu
Till Rohrmann created FLINK-7664:
Summary: Replace FlinkFutureException by CompletionException
Key: FLINK-7664
URL: https://issues.apache.org/jira/browse/FLINK-7664
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175091#comment-16175091
]
ASF GitHub Bot commented on FLINK-7636:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175093#comment-16175093
]
ASF GitHub Bot commented on FLINK-7636:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175090#comment-16175090
]
ASF GitHub Bot commented on FLINK-7636:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175092#comment-16175092
]
ASF GitHub Bot commented on FLINK-7636:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4681#discussion_r140297123
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkRelOptTable.scala
---
@@ -0,0 +1,265 @@
+/*
+ * License
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4681#discussion_r140291045
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkRelOptTable.scala
---
@@ -0,0 +1,265 @@
+/*
+ * License
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4681#discussion_r140292203
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkRelOptTable.scala
---
@@ -0,0 +1,265 @@
+/*
+ * License
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4681#discussion_r140290245
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkRelOptTable.scala
---
@@ -0,0 +1,265 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175080#comment-16175080
]
ASF GitHub Bot commented on FLINK-7649:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4700
[FLINK-7649] [flip6] Extend JobTerminationHandler to support stop
## What is the purpose of the change
Rename the JobCancellationHandler into JobTerminationHandler which is now
respons
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4699
[FLINK-7663] [flip6] Return BAD_REQUEST if HandlerRequest cannot be created
## What is the purpose of the change
This commit changes the behaviour such that a failure in creating a
`Ha
[
https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175050#comment-16175050
]
ASF GitHub Bot commented on FLINK-7663:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175036#comment-16175036
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175034#comment-16175034
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175035#comment-16175035
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4688#discussion_r140291439
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/CurrentJobsOverviewHandler.java
---
@@ -92,24 +101,26 @@ public Curr
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4688#discussion_r140291476
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/CurrentJobsOverviewHandler.java
---
@@ -92,24 +101,26 @@ public Curr
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4688#discussion_r140291389
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/CurrentJobsOverviewHandler.java
---
@@ -92,24 +101,26 @@ public Curr
[
https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174974#comment-16174974
]
Aljoscha Krettek commented on FLINK-7623:
-
I think that would be incorrect, becaus
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174972#comment-16174972
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174973#comment-16174973
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4688#discussion_r140281116
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/CurrentJobsOverviewHandler.java
---
@@ -92,24 +101,26 @@ public CurrentJ
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4688#discussion_r140280832
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/CurrentJobsOverviewHandler.java
---
@@ -92,24 +101,26 @@ public CurrentJ
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174969#comment-16174969
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4688#discussion_r140281028
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/CurrentJobsOverviewHandler.java
---
@@ -92,24 +101,26 @@ public CurrentJ
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174953#comment-16174953
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r140276174
--- Diff: docs/dev/table/udfs.md ---
@@ -297,7 +297,7 @@ optionally implemented. While some of these methods
allow the system more effici
- `merge()` is
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174926#comment-16174926
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r140271306
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -186,7 +186,7 @@ public void testUniformDis
Till Rohrmann created FLINK-7663:
Summary: Allow AbstractRestHandler to handle bad requests
Key: FLINK-7663
URL: https://issues.apache.org/jira/browse/FLINK-7663
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174882#comment-16174882
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r140266297
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class Ti
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174880#comment-16174880
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4691
Sorry about that, local Travis tests pass, should be fine now.
---
[
https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7652:
--
Assignee: Tzu-Li (Gordon) Tai
> Port CurrentJobIdsHandler to new REST endpoint
[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7648:
--
Assignee: (was: Tzu-Li (Gordon) Tai)
> Port TaskManagersHandler to new REST
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174875#comment-16174875
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r140263201
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -0,0 +1,442 @@
+/*
Stephan Ewen created FLINK-7662:
---
Summary: Remove unnecessary packaged licenses
Key: FLINK-7662
URL: https://issues.apache.org/jira/browse/FLINK-7662
Project: Flink
Issue Type: Improvement
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r140262200
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174868#comment-16174868
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user fhueske commented on a diff in
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r140258895
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NormalizedKeySorter.java
---
@@ -309,7 +309,7 @@ public boolean write(T reco
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r140258675
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NormalizedKeySorter.java
---
@@ -47,61 +47,61 @@
public sta
[
https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174841#comment-16174841
]
ASF GitHub Bot commented on FLINK-7661:
---
GitHub user zhijiangW opened a pull request
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/4698
[FLINK-7661][network] Add credit field in PartitionRequest message
## What is the purpose of the change
*`PartitionRequest` message adds the credit field which corresponds to the
number o
Github user zhijiangW closed the pull request at:
https://github.com/apache/flink/pull/4695
---
[
https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174839#comment-16174839
]
ASF GitHub Bot commented on FLINK-7661:
---
Github user zhijiangW closed the pull reque
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r140255052
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -0,0 +1,442 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174834#comment-16174834
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174815#comment-16174815
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r140251765
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class Ti
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174757#comment-16174757
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , sorry for the typos. I have submitted the updates.
---
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174746#comment-16174746
]
ASF GitHub Bot commented on FLINK-7638:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4688
@tillrohrmann Yes that makes sense, lets do that separately in the future
then.
+1.
---
[
https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174734#comment-16174734
]
ASF GitHub Bot commented on FLINK-7502:
---
Github user mbode commented on the issue:
Github user mbode commented on the issue:
https://github.com/apache/flink/pull/4586
@zentol It would be great if you could have another look on occasion, I
added better handling for metrics that are registered e.g. by different
subtasks.
[green travis](https://travis-ci.org/m
[
https://issues.apache.org/jira/browse/FLINK-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7649:
Assignee: Till Rohrmann
> Port JobStoppingHandler to new REST endpoint
> --
[
https://issues.apache.org/jira/browse/FLINK-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7649:
-
Description: Port existing {{JobStoppingHandler}} to new REST endpoint
(was: Port existing `JobSt
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174731#comment-16174731
]
ASF GitHub Bot commented on FLINK-7647:
---
Github user tillrohrmann commented on the i
1 - 100 of 198 matches
Mail list logo
