[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941614#comment-15941614
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in
Yuhong Hong created FLINK-6187:
--
Summary: Cancel job failed with option -m on yarn session
Key: FLINK-6187
URL: https://issues.apache.org/jira/browse/FLINK-6187
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941590#comment-15941590
]
ramkrishna.s.vasudevan commented on FLINK-5698:
---
Once this is integrated wil
[
https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CanBin Zheng updated FLINK-6186:
Description: Remove unused import
org.apache.flink.api.java.ExecutionEnvironment in
org.apache.flin
CanBin Zheng created FLINK-6186:
---
Summary: Remove unused import
Key: FLINK-6186
URL: https://issues.apache.org/jira/browse/FLINK-6186
Project: Flink
Issue Type: Wish
Reporter: CanBi
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941547#comment-15941547
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/3600
@Rucongzhang Please review it whether it meet your requirement.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-6117:
-
Issue Type: Sub-task (was: Bug)
Parent: FLINK-5839
> 'zookeeper.sasl.disable' not takes effet wh
[
https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941537#comment-15941537
]
CanBin Zheng commented on FLINK-6148:
-
This is a reduplicate issue, I have reported th
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r108026230
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -112,7 +113,12 @@
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941535#comment-15941535
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user hongyuhong commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941530#comment-15941530
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user zhengcanbin commented on the is
Github user zhengcanbin commented on the issue:
https://github.com/apache/flink/pull/3600
@EronWright @StephanEwen
In ZookeeperSaslClient.java, 'zookeeper.sasl.client' is true by default, so
I agree to set 'zookeeper.sasl.disable' to false by default, for consistency.
---
If you
[
https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-6148:
Assignee: (was: shijinkui)
> The Zookeeper client occur SASL error when the sasl is disable
> -
[
https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-6148:
Assignee: shijinkui
> The Zookeeper client occur SASL error when the sasl is disable
>
[
https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941522#comment-15941522
]
shijinkui commented on FLINK-5217:
--
ping [~srichter]
> Deprecated interface Checkpointed
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3599
I don't think it's a good idea, as it can not solve the "split brain" issue
too.
The key problem is that `LeaderLatch` in curator is too sensitive to
connection state to Zookeeper(it
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941520#comment-15941520
]
shijinkui commented on FLINK-5860:
--
ping [~yaroslav.mykhaylov]
> Replace all the file c
[
https://issues.apache.org/jira/browse/FLINK-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941521#comment-15941521
]
ASF GitHub Bot commented on FLINK-6174:
---
Github user WangTaoTheTonic commented on th
[
https://issues.apache.org/jira/browse/FLINK-6060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941519#comment-15941519
]
shijinkui commented on FLINK-6060:
--
[~aljoscha] Sorry for my unclear description.
For ex
[
https://issues.apache.org/jira/browse/FLINK-6060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-6060:
-
Summary: reference nonexistent class in the scaladoc (was: not exist class
referance in the scala functio
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941516#comment-15941516
]
shijinkui commented on FLINK-5754:
--
[~greghogan] At first, I image that the flink tag is
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941507#comment-15941507
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r108025485
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -112,7 +113,12
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941412#comment-15941412
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3607
HI, @rtudoran Thanks for this PR. It's looks very promising. Please rebase
code on master first, Then I glad to take a look this changes.
Best,
SunJincheng
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6185:
--
Description:
File sources (such as {{ExecutionEnvironment#readCsvFile()}}) and sinks (such
as {
Luke Hutchison created FLINK-6185:
-
Summary: Input readers and output writers/formats need to support
gzip
Key: FLINK-6185
URL: https://issues.apache.org/jira/browse/FLINK-6185
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6185:
--
Description:
File sources (such as {{env#readCsvFile()}}) and sinks (such as
{{FileOutputFormat
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3269
Hi @tonycox, thanks for the update!
I'll do some minor improvements and will merge the PR.
Thank you,
Fabian
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941330#comment-15941330
]
ASF GitHub Bot commented on FLINK-5698:
---
Github user fhueske commented on the issue:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3605#discussion_r108001505
--- Diff: tools/travis_mvn_watchdog.sh ---
@@ -164,7 +164,7 @@ watchdog () {
# Check the final fat jar for illegal artifacts
check_shaded_art
[
https://issues.apache.org/jira/browse/FLINK-6181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941153#comment-15941153
]
ASF GitHub Bot commented on FLINK-6181:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15939209#comment-15939209
]
Chen Qin edited comment on FLINK-6085 at 3/24/17 8:32 PM:
--
I woul
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3564
I accidentally merged this to `master` not `table-retraction`.
Since the changes do not break anything, this is not a problem.
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941043#comment-15941043
]
ASF GitHub Bot commented on FLINK-5658:
---
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/3386#discussion_r107987832
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -112,7 +113,12 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5990.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 7a9d39fe9f659d43bf4719a2981f6c4
[
https://issues.apache.org/jira/browse/FLINK-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941007#comment-15941007
]
sunjincheng commented on FLINK-6145:
Fixed by
[7a9d39f|https://github.com/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941021#comment-15941021
]
Fabian Hueske commented on FLINK-5829:
--
Calcite 1.12 has been release today:
http://
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5570.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 135a57c4bb37eaa9cb85faaff1cc694
[
https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941013#comment-15941013
]
ASF GitHub Bot commented on FLINK-6089:
---
Github user fhueske commented on the issue:
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r107982106
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -112,7 +113,12
[
https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6089.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 6949c8c79c41344023df08dde2936f0
[
https://issues.apache.org/jira/browse/FLINK-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-6145.
--
Resolution: Fixed
> Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to
> SQL
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5658.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with fe2c61a28e6a5300b2cf4c1e50ee884
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941000#comment-15941000
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940991#comment-15940991
]
ASF GitHub Bot commented on FLINK-5990:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940992#comment-15940992
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3409
---
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 if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940989#comment-15940989
]
ASF GitHub Bot commented on FLINK-6089:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940990#comment-15940990
]
ASF GitHub Bot commented on FLINK-5568:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3585
---
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 if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3564
---
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 if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3386
---
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 if the feature is enab
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3611
[backport] [FLINK-6183]/[FLINK-6184] Prevent some NPE and unclosed metric
groups
Backport of #3610 for 1.2 .
You can merge this pull request into a Git repository by running:
$ git pull https:/
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940943#comment-15940943
]
ASF GitHub Bot commented on FLINK-6183:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940910#comment-15940910
]
ASF GitHub Bot commented on FLINK-6183:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3610
[FLINK-6183]/[FLINK-6184] Prevent some NPE and unclosed metric groups
This PR fixes 2 issues:
1) It prevents some NPEs in the buffer metrics by instantiating them after
the task has been reg
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6183:
---
Assignee: Chesnay Schepler
> TaskMetricGroup may not be cleanup when Task.run() is ne
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r107968436
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java
---
@@ -119,13 +183,154 @@ protected void clea
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940880#comment-15940880
]
radu commented on FLINK-6073:
-
the join window can be one window element as we emit for every
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940872#comment-15940872
]
ASF GitHub Bot commented on FLINK-6073:
---
Github user rtudoran commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940873#comment-15940873
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940878#comment-15940878
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940877#comment-15940877
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940874#comment-15940874
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940875#comment-15940875
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940876#comment-15940876
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in t
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r107968935
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java
---
@@ -17,100 +17,164 @@
package o
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r107969496
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java
---
@@ -17,100 +17,164 @@
package o
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3609
@fhueske @twalthr @sunjincheng121 @shijinkui @stefanobortoli @hongyuhong
I have made a first implementation draft for supporting inner queries
mainly when operating on processing time. I wou
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r107967910
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java
---
@@ -119,13 +183,154 @@ protected void clea
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r107968567
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java
---
@@ -119,13 +183,154 @@ protected void clea
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r107967886
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java
---
@@ -119,13 +183,154 @@ protected void clea
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3609
Inner query implementation model
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of
[
https://issues.apache.org/jira/browse/FLINK-6184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6184:
---
Assignee: Chesnay Schepler
> Buffer metrics can cause NPE
> -
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3590
@fhueske @sunjincheng121 @hongyuhong @stefanobortoli
I have run a test to compare the 3 approaches:
-windows based #3550
-processfunction based with events managed in ValueState[
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940830#comment-15940830
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940819#comment-15940819
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940820#comment-15940820
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter closed the pull
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/3602
---
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 if the feature
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3602
Merged in c6a80725053c49dd2064405577291bdc86c82003.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940809#comment-15940809
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3602
After a discussion with @StephanEwen , we decided to follow my proposal.
Merging this now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940804#comment-15940804
]
Fabian Hueske commented on FLINK-5498:
--
Hi [~lincoln.86xy], I thought about this prob
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940777#comment-15940777
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the i
Github user senorcarbone commented on the issue:
https://github.com/apache/flink/pull/1668
Hey. Any update/opinion/something anyone?
Just a gentle reminder, sorry if this sounds a bit desperate :)
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6183:
Affects Version/s: 1.2.0
> TaskMetricGroup may not be cleanup when Task.run() is never calle
[
https://issues.apache.org/jira/browse/FLINK-6184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6184:
Affects Version/s: 1.2.0
> Buffer metrics can cause NPE
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6183:
Component/s: Metrics
> TaskMetricGroup may not be cleanup when Task.run() is never called or
Chesnay Schepler created FLINK-6184:
---
Summary: Buffer metrics can cause NPE
Key: FLINK-6184
URL: https://issues.apache.org/jira/browse/FLINK-6184
Project: Flink
Issue Type: Bug
Co
Chesnay Schepler created FLINK-6183:
---
Summary: TaskMetricGroup may not be cleanup when Task.run() is
never called or exits early
Key: FLINK-6183
URL: https://issues.apache.org/jira/browse/FLINK-6183
[
https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4760.
-
Resolution: Not A Problem
> Kafka 09 Consumer failed to initialize state because of corrupted oper
[
https://issues.apache.org/jira/browse/FLINK-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan closed FLINK-6063.
-
Resolution: Not A Problem
It's not an actual issue with the framework just isn't clear dfs MUST be used
for HA.
Github user DmytroShkvyra commented on the issue:
https://github.com/apache/flink/pull/3502
@twalthr I have tried run `SubQueryRemoveRule` (register it in
`FlinkRulesSets`) and so on but it have not called from Flink. I have looked
thru Calcite docs and they said that calcite rules ca
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940716#comment-15940716
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on the
[
https://issues.apache.org/jira/browse/FLINK-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940707#comment-15940707
]
Razvan commented on FLINK-6063:
---
Hi, it works with DFS for me though I'd underline it is req
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940678#comment-15940678
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3567
I have no preference for any style of import order. I just wanted to
mandate some order so that we don't have edit wars when people use different
IDE settings.
@greghogan Have you tried set
1 - 100 of 231 matches
Mail list logo
