[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866803#comment-15866803
]
ASF GitHub Bot commented on FLINK-2908:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url :
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-2908.
-
Resolution: Implemented
Implemented in d88c938cf04cd438db0f084bd670894d2eadcff2
> Web interface redraw
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866933#comment-15866933
]
Till Rohrmann commented on FLINK-5773:
--
I think the problem is that we use the wrong {{Failure}}
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-5773:
Assignee: Till Rohrmann
> Cannot cast scala.util.Failure to
>
[
https://issues.apache.org/jira/browse/FLINK-5801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrick Lucas updated FLINK-5801:
-
Attachment: OrderFulfillmentStateQuery.scala
OrderFulfillment.scala
> Queryable
Patrick Lucas created FLINK-5801:
Summary: Queryable State from Scala job/client fails with key of
type Long
Key: FLINK-5801
URL: https://issues.apache.org/jira/browse/FLINK-5801
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:55 PM:
--
Github user skonto commented on the issue:
https://github.com/apache/flink/pull/3313
@thvasilo @tillrohrmann pls review.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 10:15 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 10:17 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:41 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867116#comment-15867116
]
Zhijiang Wang commented on FLINK-5798:
--
That is good, and the heartbeat manager component can reuse
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867126#comment-15867126
]
Zhijiang Wang edited comment on FLINK-5799 at 2/15/17 2:56 AM:
---
This fix is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3305
@tillrohrmann Thanks for your review.
Sorry for the reformatted code. It seems that my IDE will automatically
reformat all the files I've edited. I will revert the reformatted code.
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867155#comment-15867155
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user shixiaogang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867194#comment-15867194
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user shixiaogang commented on the issue:
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3305
@StephanEwen @tillrohrmann I found a problem that is the packages
`ListTypeInfo` and `ListTypeSerializer` locate. Now `ListTypeInfo` is put in
package "org.apache.flink.api.java.typeutils" and
[
https://issues.apache.org/jira/browse/FLINK-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yelei Feng closed FLINK-5797.
-
Resolution: Not A Bug
> incorrect use of port range selector in BootstrapTool
>
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867089#comment-15867089
]
ASF GitHub Bot commented on FLINK-5567:
---
Github user beyond1920 commented on the issue:
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/3197
@fhueske , thanks for your review. I already modify code based on your
advice and rebase the pr.
---
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-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5792:
---
Summary: Improve “UDF/UDTF" to support constructor with parameter. (was:
Improve “UDF/UDTF" to
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5795:
---
Summary: Improve “UDTF" to support constructor with parameter. (was:
Improve “UDTF" to support with
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5794:
---
Summary: Improve “UDF" to support constructor with parameter. (was:
Improve “UDF" to support with
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/3306
@StephanEwen done, add unittest.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867205#comment-15867205
]
ASF GitHub Bot commented on FLINK-5793:
---
Github user shuai-xu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/15/17 2:09 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867126#comment-15867126
]
Zhijiang Wang commented on FLINK-5799:
--
This fix is useful and the {{HeartbeatManagerSenderImpl}} can
[
https://issues.apache.org/jira/browse/FLINK-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu resolved FLINK-5141.
-
Resolution: Fixed
> Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch
>
Zhuoluo Yang created FLINK-5802:
---
Summary: Flink SQL calling Hive User-Defined Functions
Key: FLINK-5802
URL: https://issues.apache.org/jira/browse/FLINK-5802
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867368#comment-15867368
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user sunjincheng121 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867369#comment-15867369
]
Haohui Mai commented on FLINK-5655:
---
I'm particularly interested in the part that compiles the sliding
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3266
@fhueske thanks for the review. you are right. I need rebase the code and
update the PR according your comments.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867405#comment-15867405
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue:
sunjincheng created FLINK-5803:
--
Summary: Add [partitioned] processing time OVER RANGE BETWEEN
UNBOUNDED PRECEDING aggregation to SQL
Key: FLINK-5803
URL: https://issues.apache.org/jira/browse/FLINK-5803
sunjincheng created FLINK-5804:
--
Summary: Add [non-partitioned] processing time OVER RANGE BETWEEN
UNBOUNDED PRECEDING aggregation to SQL
Key: FLINK-5804
URL: https://issues.apache.org/jira/browse/FLINK-5804
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Thanks for the review @rmetzger! The final 2 commits have addressed all
your comments.
I'll also wait for @kl0u to have a look at the changes in
`FlinkKafkaConsumerBaseMigration` before
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867288#comment-15867288
]
Haohui Mai commented on FLINK-5570:
---
We are interested in this feature as well. Just curious about the
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5657:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-4557)
> Add processing time
GitHub user 501256092 opened a pull request:
https://github.com/apache/flink/pull/3315
Release 1.2.0 rc3
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 the items
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Labels: features (was: )
> Flink SQL calling Hive User-Defined Functions
>
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Component/s: Table API & SQL
> Flink SQL calling Hive User-Defined Functions
>
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867362#comment-15867362
]
sunjincheng commented on FLINK-5657:
Hi, [~fhueske] When I splitting FLINK-5657 into the partitioned
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865814#comment-15865814
]
ASF GitHub Bot commented on FLINK-5690:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865813#comment-15865813
]
Robert Metzger commented on FLINK-5690:
---
Merged documentation update to master in
[
https://issues.apache.org/jira/browse/FLINK-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865850#comment-15865850
]
ASF GitHub Bot commented on FLINK-5566:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865849#comment-15865849
]
ASF GitHub Bot commented on FLINK-5566:
---
Github user asfgit closed the pull request at:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3196
Merged.
Thanks @beyond1920!
---
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
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865858#comment-15865858
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865860#comment-15865860
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865856#comment-15865856
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3299
---
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-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865880#comment-15865880
]
ASF GitHub Bot commented on FLINK-5762:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865878#comment-15865878
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865877#comment-15865877
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3301
---
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/3291
---
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/3300
---
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/3196
---
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-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5566.
Resolution: Fixed
Fix Version/s: 1.3.0
Implemented with
Nico Kruber created FLINK-5796:
--
Summary: broken links in the docs
Key: FLINK-5796
URL: https://issues.apache.org/jira/browse/FLINK-5796
Project: Flink
Issue Type: Bug
Components:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101047374
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101045081
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@ -438,6
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865857#comment-15865857
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865859#comment-15865859
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101000341
--- Diff: docs/dev/connectors/kafka.md ---
@@ -161,6 +161,46 @@ For convenience, Flink provides the following schemas:
The KeyValue objectNode
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101000141
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r100989660
--- Diff: docs/dev/connectors/kafka.md ---
@@ -161,6 +161,46 @@ For convenience, Flink provides the following schemas:
The KeyValue objectNode
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865863#comment-15865863
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101048002
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101050554
--- Diff: docs/dev/connectors/kafka.md ---
@@ -161,6 +161,46 @@ For convenience, Flink provides the following schemas:
The KeyValue objectNode
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865874#comment-15865874
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101050769
--- Diff: docs/dev/connectors/kafka.md ---
@@ -161,6 +161,46 @@ For convenience, Flink provides the following schemas:
The KeyValue objectNode
[
https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865879#comment-15865879
]
ASF GitHub Bot commented on FLINK-5553:
---
Github user asfgit closed the pull request at:
201 - 279 of 279 matches
Mail list logo
