[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057444#comment-16057444
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123004606
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r122842288
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonJoin.scala
---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123003230
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123028155
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r122841979
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonJoin.scala
---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057414#comment-16057414
]
ASF GitHub Bot commented on FLINK-6655:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4156
cc @twalthr @zentol Please helps to review, Thank you very much.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057411#comment-16057411
]
ASF GitHub Bot commented on FLINK-6655:
---
GitHub user zhangminglei opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4156
[FLINK-6655] Add validateAndNormalizeUri method to MemoryArchivist
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
Github user zhangminglei closed the pull request at:
https://github.com/apache/flink/pull/4155
---
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 zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4155
Flink 6655 misleading error message historyserver
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6907:
Summary: Adjust TupleGenerator javadocs in flink-java (was: Remove
TupleGenerator in
[
https://issues.apache.org/jira/browse/FLINK-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6907:
---
Assignee: Chesnay Schepler
> Remove TupleGenerator in flink-java
>
[
https://issues.apache.org/jira/browse/FLINK-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057391#comment-16057391
]
Chesnay Schepler commented on FLINK-6907:
-
yes, it appears that they are both needed.
The one in
[
https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057378#comment-16057378
]
ASF GitHub Bot commented on FLINK-6008:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4146
please note that there are four unrelated test failures:
* 2x Kafka010ITCase
* 2x YARNSessionCapacitySchedulerITCase
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057374#comment-16057374
]
ASF GitHub Bot commented on FLINK-6940:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4136#discussion_r123228173
--- Diff: docs/ops/state_backends.md ---
@@ -124,7 +124,7 @@ RocksDBStateBackend is currently the only backend that
offers incremental checkp
##
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4145
Nice work. Just one comment: the states in NFA is metadata, maybe we should
get rid of serializing them at all?
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057361#comment-16057361
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dianfu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6655:
---
Assignee: mingleizhang
> Misleading error message when HistoryServer path is empty
>
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057337#comment-16057337
]
mingleizhang commented on FLINK-6655:
-
Exactly. That is why I said it is not suitable fix in
Github user sunjincheng121 closed the pull request at:
https://github.com/apache/flink/pull/4154
---
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 sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4154
[Flink 6649][table]Improve Non-window group aggregate with update intâ¦
In this PR. I have improve Non-window group aggregate with update interval.
- [x] General
- The pull
[
https://issues.apache.org/jira/browse/FLINK-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-6897:
---
Assignee: Dawid Wysakowicz
> Re-add support for Java 8 lambdas in CEP library
>
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057274#comment-16057274
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123204588
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -126,6 +129,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057249#comment-16057249
]
Stefan Richter commented on FLINK-6633:
---
I created https://issues.apache.org/jira/browse/FLINK-6964
Stefan Richter created FLINK-6964:
-
Summary: Fix recovery for incremental checkpoints in
StandaloneCompletedCheckpointStore
Key: FLINK-6964
URL: https://issues.apache.org/jira/browse/FLINK-6964
Shaoxuan Wang created FLINK-6962:
Summary: SQL DDL for input and output tables
Key: FLINK-6962
URL: https://issues.apache.org/jira/browse/FLINK-6962
Project: Flink
Issue Type: New Feature
Shaoxuan Wang created FLINK-6963:
Summary: User Defined Operator
Key: FLINK-6963
URL: https://issues.apache.org/jira/browse/FLINK-6963
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057237#comment-16057237
]
ASF GitHub Bot commented on FLINK-6494:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4075#discussion_r123197240
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
---
@@ -52,7 +52,74 @@
Shaoxuan Wang created FLINK-6961:
Summary: Enable configurable early-firing rate
Key: FLINK-6961
URL: https://issues.apache.org/jira/browse/FLINK-6961
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057218#comment-16057218
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123192355
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -126,6 +129,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057216#comment-16057216
]
Aegeaner commented on FLINK-6958:
-
Maybe you could set a CountDownLatch, and call countdown in case of
[
https://issues.apache.org/jira/browse/FLINK-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viliam Durina closed FLINK-6953.
Resolution: Won't Fix
Not an issue in flink but rather in zookeeper.
> Ignore space after comman
[
https://issues.apache.org/jira/browse/FLINK-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057210#comment-16057210
]
Viliam Durina commented on FLINK-6953:
--
https://issues.apache.org/jira/browse/ZOOKEEPER-2814
>
[
https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057209#comment-16057209
]
ASF GitHub Bot commented on FLINK-6498:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4123
@zentol Thank you for your suggestions. I have fixed them, 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 project
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057204#comment-16057204
]
ASF GitHub Bot commented on FLINK-6960:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057203#comment-16057203
]
ASF GitHub Bot commented on FLINK-6960:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4152#discussion_r123188958
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/scalarSqlFunctions/MathSqlFunctions.scala
---
@@ -0,0 +1,35 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4152#discussion_r123189112
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -1116,6 +1116,13 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057200#comment-16057200
]
ASF GitHub Bot commented on FLINK-6389:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4151
lgtm
---
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-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057193#comment-16057193
]
ASF GitHub Bot commented on FLINK-6927:
---
GitHub user dianfu opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/4153
[FLINK-6927] [cep] Support pattern group in CEP
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057188#comment-16057188
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123186831
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -1131,6 +1152,7 @@ private void serializeStates(Set
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057177#comment-16057177
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057176#comment-16057176
]
Stefan Richter commented on FLINK-6633:
---
[~cre...@gmail.com], I think this log was already enough to
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123184832
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -1131,6 +1152,7 @@ private void serializeStates(Set
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057173#comment-16057173
]
ASF GitHub Bot commented on FLINK-6960:
---
GitHub user sunjincheng121 opened a pull request:
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4152
[FLINK-6960][table] Add E supported in SQL.
In this PR. I have add Math.E supported in SQL.
- [x] General
- The pull request references the related JIRA issue
[
https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057147#comment-16057147
]
ASF GitHub Bot commented on FLINK-6494:
---
Github user zjureel commented on a diff in the pull
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4075#discussion_r123180174
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
---
@@ -52,7 +52,74 @@
[
https://issues.apache.org/jira/browse/FLINK-6959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057103#comment-16057103
]
Fabian Hueske commented on FLINK-6959:
--
I don't think we need to add a specific section to the
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6847:
--
Assignee: (was: sunjincheng)
> Add TIMESTAMPDIFF supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6846:
---
Labels: starter (was: )
> Add TIMESTAMPADD supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6846:
--
Assignee: (was: sunjincheng)
> Add TIMESTAMPADD supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6942:
---
Labels: starter (was: )
> Add a document for the FLINK-6810 related scalar functions
>
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6847:
---
Labels: starter (was: )
> Add TIMESTAMPDIFF supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057097#comment-16057097
]
Chesnay Schepler commented on FLINK-6655:
-
The stack trace is sufficient. The basic problem is
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-6960:
---
Labels: starter (was: )
> Add E(2.7182818284590452354),PI(3.14159265358979323846) supported in SQL
>
[
https://issues.apache.org/jira/browse/FLINK-6926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6926:
--
Assignee: Shaoxuan Wang (was: sunjincheng)
> Add MD5/SHA1/SHA2 supported in SQL
>
sunjincheng created FLINK-6960:
--
Summary: Add E(2.7182818284590452354),PI(3.14159265358979323846)
supported in SQL
Key: FLINK-6960
URL: https://issues.apache.org/jira/browse/FLINK-6960
Project: Flink
sunjincheng created FLINK-6959:
--
Summary: Add documentation for SQL OVER windows
Key: FLINK-6959
URL: https://issues.apache.org/jira/browse/FLINK-6959
Project: Flink
Issue Type: Improvement
201 - 270 of 270 matches
Mail list logo