[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5788.
-
Resolution: Fixed
Fixed via f7af3b01681592787db16a555b55d6b11d35f869
> Document assumptions
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865886#comment-15865886
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865881#comment-15865881
]
Ufuk Celebi commented on FLINK-5796:
[~rmetzger] Can we integrate this check with the build bot?
>
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5788.
---
> Document assumptions about File Systems and persistence
>
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101051346
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101051496
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5553.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed via af81bebd0fabc6390930689df131e72edab6995b
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101051598
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@ -438,6
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865888#comment-15865888
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865891#comment-15865891
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5553.
---
> Job fails during deployment with IllegalStateException from subpartition
> request
>
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5762.
---
> Protect initializeState() and open() by the same lock.
>
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5762.
-
Resolution: Fixed
Fixed via a91b6ff05d8af870ad076f9bf0fc17886787bc46
> Protect initializeState()
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865894#comment-15865894
]
Robert Metzger commented on FLINK-5796:
---
Sorry, I don't have time for this right now.
I think we
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3308
[FLINK-5796] fix some broken links in the docs
this probably also applies to the release-1.2 docs
You can merge this pull request into a Git repository by running:
$ git pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3297#discussion_r101052582
--- Diff: docs/setup/config.md ---
@@ -151,6 +151,8 @@ one of the values specified in
`security.kerberos.login.contexts`.
### Other
+-
[
https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865897#comment-15865897
]
ASF GitHub Bot commented on FLINK-5431:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865900#comment-15865900
]
ASF GitHub Bot commented on FLINK-5796:
---
GitHub user NicoK opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865902#comment-15865902
]
Nico Kruber commented on FLINK-5796:
{{/api/java/org/apache/flink/table/api/Table.html}} is actually
[
https://issues.apache.org/jira/browse/FLINK-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866466#comment-15866466
]
Stephan Ewen commented on FLINK-5778:
-
I am not sure about this design. State handle immutability is
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3311
Let RpcService.scheduleRunnable return a ScheduledFuture
This PR is based #3310.
The returned ScheduledFuture instance allows to cancel a scheduled runnable
and obtain
the delay
Till Rohrmann created FLINK-5798:
Summary: Let the RPCService provide a ScheduledExecutorService
Key: FLINK-5798
URL: https://issues.apache.org/jira/browse/FLINK-5798
Project: Flink
Issue
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3310
[FLINK-5798] [rpc] Let the RpcService provide a ScheduledExecutorService
This PR adds the getScheduledExecutorService method to the RpcService
interface. So
henceforth all RpcService
[
https://issues.apache.org/jira/browse/FLINK-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866450#comment-15866450
]
ASF GitHub Bot commented on FLINK-5798:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866340#comment-15866340
]
Mariusz Wojakowski commented on FLINK-5253:
---
I have 2 questions:
* should we store these dynamic
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3300#discussion_r100977226
--- Diff: docs/dev/best_practices.md ---
@@ -310,3 +310,17 @@ Next, you need to put the following jar files into the
`lib/` folder:
Note that you need to
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865327#comment-15865327
]
ASF GitHub Bot commented on FLINK-5690:
---
Github user uce commented on a diff in the pull request:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3298#discussion_r100978413
--- Diff: flink-dist/src/main/flink-bin/bin/stop-cluster.sh ---
@@ -25,14 +25,30 @@ bin=`cd "$bin"; pwd`
# Stop TaskManager instance(s) using pdsh
[
https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865340#comment-15865340
]
ASF GitHub Bot commented on FLINK-5672:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3298#discussion_r100978305
--- Diff: flink-dist/src/main/flink-bin/bin/stop-cluster.sh ---
@@ -25,14 +25,30 @@ bin=`cd "$bin"; pwd`
# Stop TaskManager instance(s) using pdsh
[
https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865342#comment-15865342
]
ASF GitHub Bot commented on FLINK-5672:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865606#comment-15865606
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865609#comment-15865609
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865607#comment-15865607
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865608#comment-15865608
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865604#comment-15865604
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865603#comment-15865603
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865605#comment-15865605
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user alpinegizmo commented on a diff in the pull
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101010905
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865588#comment-15865588
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865587#comment-15865587
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user StephanEwen commented on a diff in the pull
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/3293
@StephanEwen already did when #3290 got in
---
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
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865641#comment-15865641
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865636#comment-15865636
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865639#comment-15865639
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865634#comment-15865634
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865637#comment-15865637
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865640#comment-15865640
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865638#comment-15865638
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865635#comment-15865635
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101016955
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -306,6 +307,85 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101014900
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetWindowAggregate.scala
---
@@ -281,9 +279,36 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101014280
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetWindowAggregateITCase.scala
---
@@ -141,16 +141,18 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101014879
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetWindowAggregate.scala
---
@@ -294,18 +319,29 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101016814
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -306,6 +307,85 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101015171
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateProcessor.scala
---
@@ -59,7
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101014526
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregatePreProcessor.scala
---
@@ -19,30
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3307
[FLINK-5420] Make CEP operators rescalable
Transforms the CEP operators into ProcessFunctions that use only managed
keyed state. Rescalability now comes out-of-the-box. In addition, for the keyed
[
https://issues.apache.org/jira/browse/FLINK-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865674#comment-15865674
]
ASF GitHub Bot commented on FLINK-5420:
---
GitHub user kl0u opened a pull request:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3293
This looks good to me now. Nico moved the `FatalExitExceptionHandler` out
of `ExecutorThreadFactory`. I'm going to merge this later today if @StephanEwen
has no objections.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5133:
-
Summary: Support to set resource for operator in DataStream and DataSet
(was: Add new
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865497#comment-15865497
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5792:
---
Description: Currently UDTF in the codegen phase using a nonparametric
constructor to create the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3306
Good fix, thanks.
Could you add a quick unit test for the bug? That way we can make sure the
bug is not accidentally re-introduced by another patch.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865545#comment-15865545
]
ASF GitHub Bot commented on FLINK-5793:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865563#comment-15865563
]
ASF GitHub Bot commented on FLINK-5553:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3299
Good fix, +1
Merging this...
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3293
@NicoK I think you can update this now...
---
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-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865583#comment-15865583
]
ASF GitHub Bot commented on FLINK-5672:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/3298#discussion_r101008195
--- Diff: flink-dist/src/main/flink-bin/bin/stop-cluster.sh ---
@@ -25,14 +25,30 @@ bin=`cd "$bin"; pwd`
# Stop TaskManager instance(s) using pdsh
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101008561
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ArrayListSerializer.java
---
@@ -108,9 +112,13 @@ public void
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101009073
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/ArrayListTypeInfo.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101011358
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101011728
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101012059
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101010804
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101011921
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3301#discussion_r101011563
--- Diff: docs/internals/filesystems.md ---
@@ -0,0 +1,138 @@
+---
+title: "File Systems"
+nav-parent_id: internals
+nav-pos: 10
+---
[
https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865612#comment-15865612
]
ASF GitHub Bot commented on FLINK-5745:
---
Github user NicoK commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3266#discussion_r101013750
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateProcessor.scala
---
@@ -19,15
[
https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865717#comment-15865717
]
ASF GitHub Bot commented on FLINK-5745:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-5420:
--
Summary: Make CEP operators rescalable (was: Make keyed CEP operator
rescalable)
> Make CEP
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-4651.
-
Resolution: Fixed
> Re-register processing time timers at the WindowOperator upon recovery.
>
[
https://issues.apache.org/jira/browse/FLINK-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865393#comment-15865393
]
ASF GitHub Bot commented on FLINK-5566:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3196#discussion_r100984668
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/stats/ColumnStats.scala
---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3302
Thanks for reopening the PR!
I made a few comments on #3271 before and after it was closed that should
be addressed.
Thanks, Fabian
---
If your project is set up for it, you can reply
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r100988931
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
[
https://issues.apache.org/jira/browse/FLINK-5316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-5316:
-
Assignee: (was: Kostas Kloudas)
> Make the GenericWriteAheadSink backwards
[
https://issues.apache.org/jira/browse/FLINK-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865409#comment-15865409
]
ASF GitHub Bot commented on FLINK-5566:
---
Github user fhueske commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3252#discussion_r100990608
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TimeModeIndicatorFunctions.scala
---
@@ -33,10 +34,18 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865499#comment-15865499
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865498#comment-15865498
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3252#discussion_r100991050
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -225,12 +231,29 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3252#discussion_r100995825
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamAggregateRule.scala
---
@@ -159,9 +152,25 @@
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3291
Merging this...
---
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,
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865560#comment-15865560
]
ASF GitHub Bot commented on FLINK-5762:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865571#comment-15865571
]
ASF GitHub Bot commented on FLINK-5723:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3274
+1 from my side.
---
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
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/3298#discussion_r101008339
--- Diff: flink-dist/src/main/flink-bin/bin/stop-cluster.sh ---
@@ -25,14 +25,30 @@ bin=`cd "$bin"; pwd`
# Stop TaskManager instance(s) using pdsh
[
https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865581#comment-15865581
]
ASF GitHub Bot commented on FLINK-5672:
---
Github user NicoK commented on a diff in the pull request:
1 - 100 of 279 matches
Mail list logo
