[
https://issues.apache.org/jira/browse/FLINK-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011874#comment-16011874
]
Tzu-Li (Gordon) Tai commented on FLINK-5946:
Great news! Thanks for the info S
Chesnay Schepler created FLINK-6596:
---
Summary: Disable javadoc generation in all travis builds
Key: FLINK-6596
URL: https://issues.apache.org/jira/browse/FLINK-6596
Project: Flink
Issue Typ
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3914
[FLINK-6596][travis] Disable javadoc generation for jdk 7
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 6596_travis_javadoc
Alter
[
https://issues.apache.org/jira/browse/FLINK-6596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011879#comment-16011879
]
ASF GitHub Bot commented on FLINK-6596:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011893#comment-16011893
]
Timo Walther commented on FLINK-6593:
-
[~RuidongLi] have you started with this issue?
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3495
---
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/3655
---
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-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5781.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: b54a72e4507b0d968c8209f2c447729b51d5d3bd
>
[
https://issues.apache.org/jira/browse/FLINK-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011906#comment-16011906
]
ASF GitHub Bot commented on FLINK-6175:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5780.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: b54a72e4507b0d968c8209f2c447729b51d5d3bd
>
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011907#comment-16011907
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6175.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
1.3: 4e7598d9c21821db8f
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011917#comment-16011917
]
Ruidong Li commented on FLINK-6593:
---
Hi, I have fixed it, you can review later today
>
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/3915
[FLINK-6352] Support to use timestamp to set the initial offset of kafka
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into conside
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3861
Use [https://github.com/apache/flink/pull/3915](url) instead
---
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 h
Github user fanyon closed the pull request at:
https://github.com/apache/flink/pull/3861
---
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-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011918#comment-16011918
]
ASF GitHub Bot commented on FLINK-6352:
---
GitHub user zjureel opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011919#comment-16011919
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3915
@tzulitai Could you please review code here when you are free, thanks :)
---
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 projec
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3904
@zentol Thank you for your reply, I have update the code and add space
after `try`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011922#comment-16011922
]
ASF GitHub Bot commented on FLINK-6439:
---
Github user zjureel commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3890
The Java version of the API also depends on the Scala classes of
`flink-table`. Everything in `org.apache.flink.table.api` is used in both
languages. `org.apache.flink.table.api.scala/java` contain l
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011928#comment-16011928
]
ASF GitHub Bot commented on FLINK-6569:
---
Github user twalthr commented on the issue:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3916
[FLINK-6590] Integrate automatic docs generation
This PR partially integrates the docs generation introduced in
FLINK-5781/#3495 into the actual documentation.
The following sections now us
[
https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011937#comment-16011937
]
ASF GitHub Bot commented on FLINK-6590:
---
GitHub user zentol opened a pull request:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116674541
--- Diff: flink-connectors/flink-connector-kafka-0.10/pom.xml ---
@@ -37,7 +37,7 @@ under the License.
- 0.10.0.1
+
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116675083
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -290,10
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116675211
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -290,10
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011944#comment-16011944
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011943#comment-16011943
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011941#comment-16011941
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116675159
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -290,10
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116674925
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
---
@@ -181,12 +18
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011945#comment-16011945
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116674594
--- Diff: flink-connectors/flink-connector-kafka-0.10/pom.xml ---
@@ -53,6 +53,10 @@ under the License.
org.apache.ka
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r116676798
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -290,10
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011942#comment-16011942
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011946#comment-16011946
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011947#comment-16011947
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011952#comment-16011952
]
Stefan Richter commented on FLINK-6537:
---
Hi,
thanks a lot for the testing effort an
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011953#comment-16011953
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3915
Also, it seems like 0.8 does support a timestamp-based offset retrieval.
See the "finding start offsets for reads" in
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example.
[
https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6440:
---
Assignee: Chesnay Schepler
> Noisy logs from metric fetcher
> ---
[
https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011967#comment-16011967
]
ASF GitHub Bot commented on FLINK-6440:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3917
[FLINK-6440][metrics] Downgrade fetching failure logging to DEBUG
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 6440_fetcher_log
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/3633
Hi @StephanEwen
Have you been reviewing this PR? If not, I would like to rebase it and fix
those conflicts. What do you think?
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011984#comment-16011984
]
ASF GitHub Bot commented on FLINK-5982:
---
Github user tony810430 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011988#comment-16011988
]
Julien Preisner commented on FLINK-6062:
Yes, it is the solution that I designed t
[
https://issues.apache.org/jira/browse/FLINK-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Preisner closed FLINK-6062.
--
Resolution: Done
I wrote a shell script that restart the job. So my use case is done.
> Re-read
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-6593:
--
Description:
the ProctimeAttribute or RowtimeAttribute should not be take into codegenerator
was:
wh
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-6593:
--
Summary: Fix Bug in ProctimeAttribute or RowtimeAttribute with
CodeGenerator (was: Fix Bug in ProctimeA
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/3918
[FLINK-6593] Fix Bug in ProctimeAttribute or RowtimeAttribute with Coâ¦
â¦deGenerator
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following c
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012034#comment-16012034
]
ASF GitHub Bot commented on FLINK-6593:
---
GitHub user Xpray opened a pull request:
Github user nragon commented on the issue:
https://github.com/apache/flink/pull/2332
Any updates on this sink?
---
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
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3919
[FLINK-6583][talbe]Enable QueryConfig in count base GroupWindow
In this PR. Enabled the `QueryConfig` for count base `GroupWindow`.
- [x] General
- The pull request references t
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012042#comment-16012042
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user nragon commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012043#comment-16012043
]
ASF GitHub Bot commented on FLINK-6583:
---
GitHub user sunjincheng121 opened a pull re
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3820
Thanks for your work @zhangminglei . Changes look good! 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
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012049#comment-16012049
]
ASF GitHub Bot commented on FLINK-6381:
---
Github user kl0u commented on the issue:
sunjincheng created FLINK-6597:
--
Summary: Cleanup WindowOperatorTest useless imports
Key: FLINK-6597
URL: https://issues.apache.org/jira/browse/FLINK-6597
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-6597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6597:
---
Component/s: Streaming
> Cleanup WindowOperatorTest useless imports
>
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3903
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012061#comment-16012061
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user rmetzger commented on the issue
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3920
[FLINK-6597][streaming] Cleanup WindowOperatorTest useless imports
Don't miss doing any good thing no matter how insignificant it looks.
- [x] General
- The pull request referen
[
https://issues.apache.org/jira/browse/FLINK-6597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012067#comment-16012067
]
ASF GitHub Bot commented on FLINK-6597:
---
GitHub user sunjincheng121 opened a pull re
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3901
@tzulitai I agree with you and `ExecutorService` is really unnecessary. I
will update the code and remove `ExecutorService`
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012079#comment-16012079
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user zjureel commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey closed FLINK-6592.
-
Resolution: Invalid
Looks like by default new org.apache.hadoop.conf.Configuration loads defaultFS.
When Bucketin
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3909#discussion_r116699827
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -593,15 +596,24 @@ private boolean
checkFilterCondition(Computat
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3909#discussion_r116700334
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -271,8 +286,8 @@ public void lock(final K key, final V
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3909#discussion_r11678
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -83,26 +84,29 @@ public SharedBuffer(final TypeSerializ
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3909#discussion_r116700094
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -114,16 +118,16 @@ public void put(
* @param t
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3909#discussion_r116700283
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -256,8 +271,8 @@ public void prune(long pruningTimestam
[
https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012087#comment-16012087
]
ASF GitHub Bot commented on FLINK-6578:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012089#comment-16012089
]
ASF GitHub Bot commented on FLINK-6578:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012088#comment-16012088
]
ASF GitHub Bot commented on FLINK-6578:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012086#comment-16012086
]
ASF GitHub Bot commented on FLINK-6578:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012085#comment-16012085
]
ASF GitHub Bot commented on FLINK-6578:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012094#comment-16012094
]
ASF GitHub Bot commented on FLINK-6381:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3820
Thanks for review @kl0u and the travis had gave us the green light. Very
appreciate it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012126#comment-16012126
]
ASF GitHub Bot commented on FLINK-6058:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/3921
[FLINK-6058] fix read DEFAULT_PARALLELISM from ContextEnvironment
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
sunjincheng created FLINK-6598:
--
Summary: Fix `DataStreamGroupAggregateRule` matches error.
Key: FLINK-6598
URL: https://issues.apache.org/jira/browse/FLINK-6598
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6598:
---
Description: Change retrun from {{!distinctAggs && !groupSets &&
!agg.indicator}} to {{!distinctAggs
[
https://issues.apache.org/jira/browse/FLINK-5422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-5422:
-
Assignee: (was: Kostas Kloudas)
> Check for name collisions in the Rolling/BucketingS
[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012151#comment-16012151
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user johnboy14 commented on the issu
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3920
+1 to merge
---
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 johnboy14 commented on the issue:
https://github.com/apache/flink/pull/3903
Thanks for turning this around quickly @tillrohrmann We are experiencing
this issue with AWS EMR. Is it possible to patch the current 1.2.0 version
available via EMR?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-6597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012152#comment-16012152
]
ASF GitHub Bot commented on FLINK-6597:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6598:
---
Description: Change {{DataStreamGroupWindowAggregateRule}} and
{{DataStreamGroupAggregateRule}} retrun
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012159#comment-16012159
]
Fabian Hueske commented on FLINK-6598:
--
Why should {{agg.getAggCallList.isEmpty}} not
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3922
[FLINK-6598][table] Fix `DataStreamGroupAggregateRule` and `DataStreaâ¦
The changes of this PR. is modify the `matches` method of
`DataStreamGroupAggregateRule` and `DataStreamGroupWindowAgg
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012162#comment-16012162
]
ASF GitHub Bot commented on FLINK-6598:
---
GitHub user sunjincheng121 opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6598:
---
Summary: Fix `DataStreamGroupAggregateRule`and
`DataStreamGroupWindowAggregateRule` matches error. (w
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6598:
---
Description:
Changes as follows:
1. Add {{!agg.getAggCallList.isEmpty}} condition for
{{DataStreamGro
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012206#comment-16012206
]
sunjincheng commented on FLINK-6598:
Hi, [~fhueske], I think:
1. for `DataStreamGroupA
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3885
Thanks @tedyu and @zentol! I pushed another commit with these minor fixes.
---
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 pro
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012208#comment-16012208
]
ASF GitHub Bot commented on FLINK-6552:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012216#comment-16012216
]
Fabian Hueske commented on FLINK-6598:
--
I think this is valid SQL syntax that can be
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3913#discussion_r116721535
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CrudExternalCatalog.scala
---
@@ -79,7 +76,7 @@ trait CrudExternalCatalo
1 - 100 of 265 matches
Mail list logo
