[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174341#comment-16174341
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140159387
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174340#comment-16174340
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140159053
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4693
https://user-images.githubusercontent.com/4133864/30681471-27f33090-9ed8-11e7-9cf8-d5a74fb998f1.png";>
---
[
https://issues.apache.org/jira/browse/FLINK-7645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174330#comment-16174330
]
ASF GitHub Bot commented on FLINK-7645:
---
Github user yew1eb commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174327#comment-16174327
]
ASF GitHub Bot commented on FLINK-7645:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4693
[FLINK-7645][docs] Modify system-metrics part show in the document
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community r
[
https://issues.apache.org/jira/browse/FLINK-7644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174320#comment-16174320
]
ASF GitHub Bot commented on FLINK-7644:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4692
[FLINK-7644][build] Drop unnecessary semicolon
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yew1eb/flink FLINK-7644
Alternatively you can rev
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174288#comment-16174288
]
Bowen Li commented on FLINK-7635:
-
[~foxss] [~aljoscha]
After taking a quick look at the
Bowen Li created FLINK-7660:
---
Summary: Support sideOutput in ProcessAllWindowFunction
Key: FLINK-7660
URL: https://issues.apache.org/jira/browse/FLINK-7660
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7635:
Summary: Support sideOutput in ProcessWindowFunciton (was: Support
sideOutput in ProcessWindowFunciton & Pr
[
https://issues.apache.org/jira/browse/FLINK-7571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174248#comment-16174248
]
ASF GitHub Bot commented on FLINK-7571:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4635
Hi @fhueske , thanks for the work! It is a very important fix! I'm fine
with the changes.
+1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173959#comment-16173959
]
Kent Murra edited comment on FLINK-7657 at 9/21/17 12:34 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173959#comment-16173959
]
Kent Murra edited comment on FLINK-7657 at 9/20/17 10:48 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173959#comment-16173959
]
Kent Murra commented on FLINK-7657:
---
I've noticed that the scope of the problem is a bit
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173936#comment-16173936
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/4616
+1
---
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173931#comment-16173931
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r140108752
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
---
@@ -31,10 +31,50 @@
public interfac
Ted Yu created FLINK-7659:
-
Summary: Unprotected access to inProgress in
JobCancellationWithSavepointHandlers#handleNewRequest
Key: FLINK-7659
URL: https://issues.apache.org/jira/browse/FLINK-7659
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173814#comment-16173814
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140089533
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/MultisetRelDataType.scala
---
@@ -0,0 +1,50 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173810#comment-16173810
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140089018
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -329,6 +329,35 @@ class Aggregat
Shuyi Chen created FLINK-7658:
-
Summary: Support COLLECT Aggregate function in Flink TABLE API
Key: FLINK-7658
URL: https://issues.apache.org/jira/browse/FLINK-7658
Project: Flink
Issue Type: New
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140083074
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173777#comment-16173777
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173670#comment-16173670
]
ASF GitHub Bot commented on FLINK-7571:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4635
@wuchong can you have a look at this PR?
It fixes the code generation for table sources with time attributes.
Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173652#comment-16173652
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173651#comment-16173651
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173649#comment-16173649
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173650#comment-16173650
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140051191
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -663,6 +666,7 @@ private void t
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140021958
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -366,6 +425,34 @@ public Strin
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140022455
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
---
@@ -155,7 +155,7 @@ public int getPort
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140038861
--- Diff: docs/ops/deployment/mesos.md ---
@@ -226,6 +226,10 @@ When running Flink with Marathon, the whole Flink
cluster including the job mana
Take
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4657
@tzulitai Thank you, Gordon!
---
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173629#comment-16173629
]
ASF GitHub Bot commented on FLINK-7508:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173631#comment-16173631
]
ASF GitHub Bot commented on FLINK-7600:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4656
@tzulitai Thank you!
---
[
https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173626#comment-16173626
]
ASF GitHub Bot commented on FLINK-7603:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173625#comment-16173625
]
ASF GitHub Bot commented on FLINK-7603:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4684
cc @zentol
---
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4684#discussion_r140050554
--- Diff: docs/ops/cli.md ---
@@ -138,17 +138,30 @@ This allows the job to finish processing all inflight
data.
[Savepoints]({{site.baseurl}}/op
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173526#comment-16173526
]
ASF GitHub Bot commented on FLINK-7647:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/4691
[FLINK-7647] [flip6] Port JobManagerConfigHandler to new REST endpoint
## What is the purpose of the change
This PR ports the existing `JobManagerConfigHandler` to the new REST
endpoint. T
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173505#comment-16173505
]
Kent Murra commented on FLINK-7657:
---
Thats great, thanks!
> SQL Timestamps Converted To
[
https://issues.apache.org/jira/browse/FLINK-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173502#comment-16173502
]
ASF GitHub Bot commented on FLINK-7656:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4690
[FLINK-7656] [runtime] Switch to user classloader before calling
initializeOnMaster and finalizeOnMaster.
## What is the purpose of the change
Fixes a classloading issue for `OutputFormat`s
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7486:
Assignee: Bhumika Bayani
> flink-mesos: Support for adding unique attribute / group_by attr
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173486#comment-16173486
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173484#comment-16173484
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173485#comment-16173485
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173487#comment-16173487
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173483#comment-16173483
]
ASF GitHub Bot commented on FLINK-7491:
---
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/4585#discussion_r140024187
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140022994
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140026944
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -329,6 +329,35 @@ class Aggregate
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140009815
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140025368
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/MultisetRelDataType.scala
---
@@ -0,0 +1,50 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173442#comment-16173442
]
Fabian Hueske commented on FLINK-7657:
--
Thanks for reporting this bug and investigati
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-7657:
Assignee: Kent Murra
> SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCas
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Affects Version/s: 1.3.1
> SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastExceptio
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Affects Version/s: 1.3.2
> SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastExceptio
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173419#comment-16173419
]
Kent Murra edited comment on FLINK-7657 at 9/20/17 4:12 PM:
I'
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Description:
I have a SQL statement using the Tables API that has a timestamp in it. When
the execution
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173419#comment-16173419
]
Kent Murra commented on FLINK-7657:
---
I'm looking at taking my bugfix and formatting it a
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Description:
I have a SQL statement using the Tables API that has a timestamp in it. When
the execution
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Description:
I have a SQL statement using the Tables API that has a timestamp in it. When
the execution
Kent Murra created FLINK-7657:
-
Summary: SQL Timestamps Converted To Wrong Type By Optimizer
Causing ClassCastException
Key: FLINK-7657
URL: https://issues.apache.org/jira/browse/FLINK-7657
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4603
---
[
https://issues.apache.org/jira/browse/FLINK-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173388#comment-16173388
]
ASF GitHub Bot commented on FLINK-7534:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7534.
Resolution: Fixed
Fix Version/s: 1.4.0
Added via dbabdb1cc2c122dbf1e83ffb9960491eaf4914bb
>
[
https://issues.apache.org/jira/browse/FLINK-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173367#comment-16173367
]
ASF GitHub Bot commented on FLINK-7655:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4689
[FLINK-7655] [flip6] Set fencing token to null if not leader
## What is the purpose of the change
This commit changes the fencing behaviour such that a component which is
not the
l
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173295#comment-16173295
]
ASF GitHub Bot commented on FLINK-7638:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4688
[FLINK-7638] [flip6] Port CurrentJobsOverviewHandler to new REST endpoint
## What is the purpose of the change
Ports the CurrentJobsOverviewHandler to the new REST endpoint by letting i
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5372:
Priority: Blocker (was: Major)
> Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoin
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5372:
Fix Version/s: 1.4.0
> Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173278#comment-16173278
]
Aljoscha Krettek commented on FLINK-4228:
-
The other parts are not relevant anymor
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4228:
Priority: Blocker (was: Major)
> RocksDB semi-async snapshot to S3AFileSystem fails
> -
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4228:
Fix Version/s: 1.4.0
> RocksDB semi-async snapshot to S3AFileSystem fails
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173277#comment-16173277
]
Aljoscha Krettek commented on FLINK-4228:
-
Moved to critical for the part about ch
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173246#comment-16173246
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7357.
Resolution: Fixed
Fix Version/s: 1.3.3
1.4.0
Release Note:
Fixed for
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r139986193
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala
---
@@ -383,13 +384,158 @@ class JoinHarness
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173236#comment-16173236
]
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_r139983961
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class Ti
Fabian Hueske created FLINK-7656:
Summary: Switch to user ClassLoader when invoking
initializeOnMaster finalizeOnMaster
Key: FLINK-7656
URL: https://issues.apache.org/jira/browse/FLINK-7656
Project: F
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/4687
[hotfix][docs][CEP] wrong method name for PatternFlatSelectFunction
The name of the single abstract method in the PatternFlatSelectFunction
interface is flatSelect, not select.
This PR
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173193#comment-16173193
]
Robert Metzger commented on FLINK-7608:
---
[~Zentol] Is there a nice way to solve this
Github user bbayani commented on the issue:
https://github.com/apache/flink/pull/4628
@EronWright , @tillrohrmann Can you please review this?
---
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173192#comment-16173192
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user bbayani commented on the issue:
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/4572#discussion_r139971451
--- Diff: flink-connectors/flink-parquet/pom.xml ---
@@ -0,0 +1,81 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173185#comment-16173185
]
Hai Zhou_UTC+8 commented on FLINK-7608:
---
[~rmetzger] I do not know jmx, do not kno
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4358#discussion_r139969639
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java
---
@@ -0,0 +1,322 @@
+/*
+ * Licensed to the Apache Softw
1 - 100 of 214 matches
Mail list logo
