Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5132#discussion_r159926701
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -492,11 +509,16 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313446#comment-16313446
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user twalthr commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159949798
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java
---
@@ -28,8 +29,12 @@
import java.net.Socket;
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8139.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5132
Thanks for the intensive review @fhueske. I will merge this now :)
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5132
---
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313513#comment-16313513
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313653#comment-16313653
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user casidiablo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8374.
---
> Unstable Yarn tests due to Akka Shutdown Exception Logging
>
[
https://issues.apache.org/jira/browse/FLINK-8374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8374.
-
Resolution: Fixed
Fixed via c7c72704ab8827245d08850edf3d9a448d18097f
> Unstable Yarn tests due
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159941955
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java
---
@@ -28,8 +29,12 @@
import
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159942085
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/package-info.java
---
@@ -0,0 +1,25 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313487#comment-16313487
]
Aljoscha Krettek commented on FLINK-8380:
-
You can already do that by encoding the topic in your
[
https://issues.apache.org/jira/browse/FLINK-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313498#comment-16313498
]
Nico Kruber commented on FLINK-8371:
Working on it - also, while doing so, I noticed that similarly,
Github user casidiablo commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r159950881
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8346.
---
> add S3 signature v4 workaround to docs
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-8359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8359.
-
Resolution: Fixed
Fixed via 1eaef6abf4839194a12b19a038a1ec480a037783
> Update copyright date in
[
https://issues.apache.org/jira/browse/FLINK-8359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8359.
---
> Update copyright date in NOTICE
> ---
>
> Key: FLINK-8359
>
[
https://issues.apache.org/jira/browse/FLINK-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313438#comment-16313438
]
Aljoscha Krettek commented on FLINK-8318:
-
Thanks, that looks alright. I think that we just have
[
https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313571#comment-16313571
]
sunjincheng commented on FLINK-8331:
Fixed in 1.4 1c7a7fa706e9b373bbe395398507378a61759190
>
[
https://issues.apache.org/jira/browse/FLINK-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313504#comment-16313504
]
Kyle Hamlin edited comment on FLINK-8380 at 1/5/18 6:53 PM:
I agree that is
Kyle Hamlin created FLINK-8380:
--
Summary: Dynamic BucketingSink paths based on ingested Kafka topics
Key: FLINK-8380
URL: https://issues.apache.org/jira/browse/FLINK-8380
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313494#comment-16313494
]
ASF GitHub Bot commented on FLINK-8203:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8203.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5204
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5237
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5231
---
[
https://issues.apache.org/jira/browse/FLINK-8373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8373.
-
Resolution: Fixed
Fixed via 3d0ed12edab5e1b89db0829230e69fb6ef841b7e
> Inconsistencies in some
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5238
---
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313622#comment-16313622
]
ASF GitHub Bot commented on FLINK-8175:
---
Github user bowenli86 commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5242
---
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8346.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via fd13ed09d4dfeea04be3acb7856fe97ac4ae6c32
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5178
---
[
https://issues.apache.org/jira/browse/FLINK-8373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8373.
---
> Inconsistencies in some FileSystem directory functions
>
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5248
[FLINK-5823] [checkpoints] State backends now also handle the checkpoint
metadata
## What is the purpose of the change
This pull requests puts the State Backends in charge of
[
https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313670#comment-16313670
]
ASF GitHub Bot commented on FLINK-5823:
---
GitHub user StephanEwen opened a pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5065
---
[
https://issues.apache.org/jira/browse/FLINK-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313362#comment-16313362
]
Jihyun Cho commented on FLINK-8318:
---
Here is my code and pom files.
{code:title=Test.scala}
import
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313366#comment-16313366
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313470#comment-16313470
]
ASF GitHub Bot commented on FLINK-8356:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313504#comment-16313504
]
Kyle Hamlin commented on FLINK-8380:
I agree that is the simplest solution. I thought it might be
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313568#comment-16313568
]
ASF GitHub Bot commented on FLINK-8175:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313567#comment-16313567
]
ASF GitHub Bot commented on FLINK-8175:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313628#comment-16313628
]
ASF GitHub Bot commented on FLINK-8346:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8346.
---
> add S3 signature v4 workaround to docs
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-8359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313627#comment-16313627
]
ASF GitHub Bot commented on FLINK-8359:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313457#comment-16313457
]
ASF GitHub Bot commented on FLINK-8356:
---
GitHub user paulzwu opened a pull request:
GitHub user paulzwu opened a pull request:
https://github.com/apache/flink/pull/5247
[FLINK-8356] Need to add the commit in flush() in JDBCOutputFormat
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5247
Thanks for opening a PR for this issue @paulzwu.
It seems the branches are a bit messed up. Can you update this PR by
putting your changes on top of the `master` branch? We'll backport the fix
Timo Walther created FLINK-8381:
---
Summary: Document more flexible schema definition
Key: FLINK-8381
URL: https://issues.apache.org/jira/browse/FLINK-8381
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Wu closed FLINK-8356.
--
Resolution: Not A Bug
Release Note: A person from my workplace found that this can be simply
fixed by
[
https://issues.apache.org/jira/browse/FLINK-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313362#comment-16313362
]
Jihyun Cho edited comment on FLINK-8318 at 1/5/18 4:14 PM:
---
Here is my code and
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8346.
-
Resolution: Fixed
Fix Version/s: 1.4.1
Fixed in
- 1.4.1 via
[
https://issues.apache.org/jira/browse/FLINK-8346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reopened FLINK-8346:
-
Reopen to fix closing message.
> add S3 signature v4 workaround to docs
>
[
https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314122#comment-16314122
]
Elias Levy commented on FLINK-7935:
---
[~Zentol] thoughts?
> Metrics with user supplied scope variables
[
https://issues.apache.org/jira/browse/FLINK-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-8329:
-
Assignee: Shuyi Chen (was: Till Rohrmann)
> Move YarnClient out of YarnClusterClient
>
[
https://issues.apache.org/jira/browse/FLINK-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8265.
---
Resolution: Fixed
Fixed on master in
9ae4c5447a2f5aae2b65d5860f822d452a9d5af1
> Missing
[
https://issues.apache.org/jira/browse/FLINK-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313852#comment-16313852
]
ASF GitHub Bot commented on FLINK-8265:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5208
Merged, and thanks for fixing this! ð
Could you please close the PR?
---
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314388#comment-16314388
]
ASF GitHub Bot commented on FLINK-8268:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314386#comment-16314386
]
ASF GitHub Bot commented on FLINK-8116:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314387#comment-16314387
]
ASF GitHub Bot commented on FLINK-8260:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314389#comment-16314389
]
ASF GitHub Bot commented on FLINK-8283:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314356#comment-16314356
]
ASF GitHub Bot commented on FLINK-8283:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5201
Thanks for the review @pnowojski. I'm merging the last commit of this PR to
`master` and `release-1.4` ..
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5193
Merging to `master` ..
---
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314362#comment-16314362
]
ASF GitHub Bot commented on FLINK-8268:
---
Github user tzulitai commented on the issue:
Zhu Zhu created FLINK-8382:
--
Summary: sheduleRunAsync with a positive schedule delay does not
work in JobMaster
Key: FLINK-8382
URL: https://issues.apache.org/jira/browse/FLINK-8382
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-8383:
--
Summary: flink-mesos build failing: duplicate Jackson relocation
in shaded jar
Key: FLINK-8383
URL: https://issues.apache.org/jira/browse/FLINK-8383
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5201
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5121
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5179
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5193
---
[
https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314357#comment-16314357
]
ASF GitHub Bot commented on FLINK-8260:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5179
Thanks a lot for the review. Merging this to `master` and `release-1.4` ..
---
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5140
Hi @fhueske, thanks for your concrete suggestions! IMO, the refactorings in
`TimeBoundedStreamJoin` are quite reasonable, while the refactoring for
`createNegativeWindowSizeJoin()` may not be so
[
https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314410#comment-16314410
]
Tzu-Li (Gordon) Tai commented on FLINK-8260:
Merged.
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8116.
Resolution: Fixed
> Stale comments referring to Checkpointed interface
>
[
https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8260.
Resolution: Fixed
> Document API of Kafka 0.11 Producer
>
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314408#comment-16314408
]
Tzu-Li (Gordon) Tai commented on FLINK-8116:
Merged.
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8287.
Resolution: Fixed
> Flink Kafka Producer docs should clearly state what partitioner
[
https://issues.apache.org/jira/browse/FLINK-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314411#comment-16314411
]
Tzu-Li (Gordon) Tai commented on FLINK-8287:
Merged.
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314415#comment-16314415
]
Tzu-Li (Gordon) Tai commented on FLINK-8283:
Merged.
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8298.
Resolution: Fixed
> Shutdown MockEnvironment
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8283.
Resolution: Fixed
Fix Version/s: 1.4.1
1.5.0
>
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314413#comment-16314413
]
Tzu-Li (Gordon) Tai commented on FLINK-8268:
Merged for 1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8268.
Resolution: Fixed
> Test instability for 'TwoPhaseCommitSinkFunctionTest'
>
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8268:
---
Fix Version/s: 1.5.0
> Test instability for 'TwoPhaseCommitSinkFunctionTest'
>
[
https://issues.apache.org/jira/browse/FLINK-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314414#comment-16314414
]
Tzu-Li (Gordon) Tai commented on FLINK-8298:
Merged for 1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314404#comment-16314404
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user xccui commented on the issue:
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5205#discussion_r159904126
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@ -742,7
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313320#comment-16313320
]
ASF GitHub Bot commented on FLINK-8037:
---
Github user pnowojski commented on a diff in the pull
Timo Walther created FLINK-8377:
---
Summary: Document DataViews for user-defined aggregate functions
Key: FLINK-8377
URL: https://issues.apache.org/jira/browse/FLINK-8377
Project: Flink
Issue
Christophe Philemotte created FLINK-8378:
Summary: Serialization and Deserialization of Kafka Avro messages
from and to Row with Confluent Schema Registry
Key: FLINK-8378
URL:
Timo Walther created FLINK-8379:
---
Summary: Improve type checking for DataView
Key: FLINK-8379
URL: https://issues.apache.org/jira/browse/FLINK-8379
Project: Flink
Issue Type: Improvement
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5218
---
[
https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-8331.
--
Resolution: Fixed
Fixed in 1.5.0 9dd3a859b1609d27ccc80a3da86456e533895b7a
> FieldParsers do not
[
https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313356#comment-16313356
]
ASF GitHub Bot commented on FLINK-8331:
---
Github user asfgit closed the pull request at:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5193
Thanks for the review! Fixed typo, rebased and squashed commits.
---
Hequn Cheng created FLINK-8366:
--
Summary: Use Row instead of String as key when process upsert
results
Key: FLINK-8366
URL: https://issues.apache.org/jira/browse/FLINK-8366
Project: Flink
1 - 100 of 252 matches
Mail list logo
