[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941590#comment-15941590
]
ramkrishna.s.vasudevan commented on FLINK-5698:
---
Once this is integrated will work on
[
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
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:
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941547#comment-15941547
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user shijinkui commented on the issue:
[
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
[
https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941537#comment-15941537
]
CanBin Zheng commented on FLINK-6148:
-
This is a reduplicate issue, I have reported this problem
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941535#comment-15941535
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941530#comment-15941530
]
ASF GitHub Bot commented on FLINK-6117:
---
Github user zhengcanbin commented on the issue:
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
[
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=15941522#comment-15941522
]
shijinkui commented on FLINK-5217:
--
ping [~srichter]
> Deprecated interface Checkpointed make clear
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
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941520#comment-15941520
]
shijinkui commented on FLINK-5860:
--
ping [~yaroslav.mykhaylov]
> Replace all the file creating from
[
https://issues.apache.org/jira/browse/FLINK-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941521#comment-15941521
]
ASF GitHub Bot commented on FLINK-6174:
---
Github user WangTaoTheTonic commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941519#comment-15941519
]
shijinkui commented on FLINK-6060:
--
[~aljoscha] Sorry for my unclear description.
For example, the class
[
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
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941516#comment-15941516
]
shijinkui commented on FLINK-5754:
--
[~greghogan] At first, I image that the flink tag is the same with
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941507#comment-15941507
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user sunjincheng121 commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941412#comment-15941412
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-6181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941153#comment-15941153
]
ASF GitHub Bot commented on FLINK-6181:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939209#comment-15939209
]
Chen Qin edited comment on FLINK-6085 at 3/24/17 8:32 PM:
--
I would like to see if
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
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941043#comment-15941043
]
ASF GitHub Bot commented on FLINK-5658:
---
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/3386#discussion_r107987832
--- 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-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
[
https://issues.apache.org/jira/browse/FLINK-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941007#comment-15941007
]
sunjincheng commented on FLINK-6145:
Fixed by
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941021#comment-15941021
]
Fabian Hueske commented on FLINK-5829:
--
Calcite 1.12 has been release today:
[
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
[
https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941000#comment-15941000
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940991#comment-15940991
]
ASF GitHub Bot commented on FLINK-5990:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940992#comment-15940992
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940989#comment-15940989
]
ASF GitHub Bot commented on FLINK-6089:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940990#comment-15940990
]
ASF GitHub Bot commented on FLINK-5568:
---
Github user asfgit closed the pull request at:
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
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
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
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://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940880#comment-15940880
]
radu commented on FLINK-6073:
-
the join window can be one window element as we emit for every incoming event
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15940873#comment-15940873
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940878#comment-15940878
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940875#comment-15940875
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940877#comment-15940877
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940874#comment-15940874
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940876#comment-15940876
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user gyfora commented on a diff in the pull request:
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
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
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
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
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15940819#comment-15940819
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940820#comment-15940820
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter closed the pull request at:
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
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
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940809#comment-15940809
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940804#comment-15940804
]
Fabian Hueske commented on FLINK-5498:
--
Hi [~lincoln.86xy], I thought about this problem and I think
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940777#comment-15940777
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the issue:
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
[
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
[
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940716#comment-15940716
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940707#comment-15940707
]
Razvan commented on FLINK-6063:
---
Hi, it works with DFS for me though I'd underline it is required for HA
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3567#discussion_r107946611
--- Diff: tools/maven/strict-checkstyle.xml ---
@@ -0,0 +1,550 @@
+
+
+http://www.puppycrawl.com/dtds/configuration_1_3.dtd;>
+
+
+
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940675#comment-15940675
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940669#comment-15940669
]
ASF GitHub Bot commented on FLINK-6169:
---
GitHub user tedyu opened a pull request:
GitHub user tedyu opened a pull request:
https://github.com/apache/flink/pull/3608
FLINK-6169 yarnClient should be stopped in AbstractYarnClusterDescriptor in
case of error
Stop yarnClient before throwing exception
You can merge this pull request into a Git repository by running:
1 - 100 of 234 matches
Mail list logo
