[
https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570772#comment-15570772
]
Tzu-Li (Gordon) Tai commented on FLINK-4627:
Hi Neelesh,
I'm not aware of anyone working on
[
https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570772#comment-15570772
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4627 at 10/13/16 4:13 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570769#comment-15570769
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Rebasing + adding tests for the new functions now.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570766#comment-15570766
]
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_r83141867
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570763#comment-15570763
]
Tzu-Li (Gordon) Tai commented on FLINK-4280:
I think using the {{KafkaTopicPartition}} is a
[
https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570751#comment-15570751
]
Tzu-Li (Gordon) Tai commented on FLINK-3037:
I'm a little bit confused here.
On checkpoints /
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2580
Thanks for the review @rmetzger. I've created several local branches to
test out the new IT tests stability as @StephanEwen suggested, and they seem to
be fine.
I'll rebase this, address
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570730#comment-15570730
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570678#comment-15570678
]
ASF GitHub Bot commented on FLINK-4727:
---
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/2585#discussion_r83138654
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2627
+1, looks good to me ð
---
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
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570510#comment-15570510
]
ASF GitHub Bot commented on FLINK-3722:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2628
[FLINK-3722] [runtime] Don't / and % when sorting
Replace division and modulus with addition and subtraction.
The timing chart below has three columns for two Gelly algorithms with
Zhenzhong Xu created FLINK-4820:
---
Summary: Slf4j / log4j version upgrade to support dynamic change
of log levels.
Key: FLINK-4820
URL: https://issues.apache.org/jira/browse/FLINK-4820
Project: Flink
Zhenzhong Xu created FLINK-4819:
---
Summary: Checkpoint metadata+data inspection tool (view / update)
Key: FLINK-4819
URL: https://issues.apache.org/jira/browse/FLINK-4819
Project: Flink
Issue
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2627
Thanks a lot for fixing this.
+1 from my side
---
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
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4816:
Summary: Executions failed from "DEPLOYING" should retain restored
checkpoint information (was:
Stephan Ewen created FLINK-4818:
---
Summary: RestartStrategy should track how many failed restore
attempts the same checkpoint has and fall back to earlier checkpoints
Key: FLINK-4818
URL:
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2606#discussion_r83071641
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationSynchronizationSinkTask.java
---
@@ -56,11 +56,15 @@
Stephan Ewen created FLINK-4817:
---
Summary: Checkpoint Coordinator should be called to restore state
with a specific checkpoint ID
Key: FLINK-4817
URL: https://issues.apache.org/jira/browse/FLINK-4817
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569632#comment-15569632
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569631#comment-15569631
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2606#discussion_r83069609
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java
---
@@ -1513,14 +1513,21 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569630#comment-15569630
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2606#discussion_r83075316
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorConvergenceITCase.java
---
@@ -137,42 +138,51 @@ public void
Stephan Ewen created FLINK-4816:
---
Summary: Executions from "DEPLOYING" should retain restored
checkpoint information
Key: FLINK-4816
URL: https://issues.apache.org/jira/browse/FLINK-4816
Project: Flink
Github user cresny commented on the issue:
https://github.com/apache/flink/pull/2288
I was hoping that when the 1.2-SNAPSHOT dust cleared it would no longer be
necessary. At this point it seems it's only necessary for staging a YARN
session for an S3A configured FileSystem,
Stephan Ewen created FLINK-4815:
---
Summary: Automatic fallback to earlier checkpoints when checkpoint
restore fails
Key: FLINK-4815
URL: https://issues.apache.org/jira/browse/FLINK-4815
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569490#comment-15569490
]
Stephan Ewen commented on FLINK-4632:
-
Do you have the logs of the JobManager from when the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2288
@cresny Do you want to continue on this? I think it is a good fix.
---
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-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569468#comment-15569468
]
Stephan Ewen commented on FLINK-4651:
-
How will this be resolved?
> Re-register processing time
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569467#comment-15569467
]
Stephan Ewen commented on FLINK-4651:
-
Fixed in 1.2 as part of
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569461#comment-15569461
]
Stephan Ewen commented on FLINK-3154:
-
I would like to close this as "won't fix".
This can only be
[
https://issues.apache.org/jira/browse/FLINK-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4701.
-
Resolution: Not A Problem
Not applicable any more to the latest code, where the cancelables have
[
https://issues.apache.org/jira/browse/FLINK-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4701.
---
> Unprotected access to cancelables in StreamTask
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3253.
-
Resolution: Unresolved
The code for this part of the system changed completely, so that this
[
https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3253.
---
> deserializeObject exception on WindowOperator
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-4102.
---
Resolution: Cannot Reproduce
> Test failure with checkpoint barriers
>
[
https://issues.apache.org/jira/browse/FLINK-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3354.
---
> RocksDB should compute checkpoint size based on backup file size
>
[
https://issues.apache.org/jira/browse/FLINK-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3354.
-
Resolution: Fixed
Fixed in b17632ddbbb58f8b3e3d1a31d6658e59258918c7
> RocksDB should compute
[
https://issues.apache.org/jira/browse/FLINK-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569440#comment-15569440
]
Stephan Ewen commented on FLINK-4102:
-
Can we close that as "could not reproduce" and reopen it once
[
https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2624.
-
Resolution: Fixed
Fixed in 9215b72422d3e638fe950b61fa01f2e4e04981a0
> RabbitMQ source / sink
[
https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2624.
---
> RabbitMQ source / sink should participate in checkpointing
>
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569405#comment-15569405
]
Stephan Ewen commented on FLINK-4410:
-
Code that gathers additional metrics is integrated. What is
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Assignee: (was: Stephan Ewen)
> Report more information about operator checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3594.
---
> StreamTask may fail when checkpoint is concurrent to regular termination
>
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3594.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via 34110fefc6e49bcbe1ae8de090fa43a5f6ef5fec
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569386#comment-15569386
]
Stephan Ewen commented on FLINK-2221:
-
I would like to close this as "won't fix", because it is
[
https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3844.
---
> Checkpoint failures should not always lead to job failures
>
[
https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3844.
-
Resolution: Duplicate
Duplicate of FLINK-4809
The other issue has already fine grained subtasks
Ufuk Celebi created FLINK-4814:
--
Summary: Remove extra storage location for externalized checkpoint
metadata
Key: FLINK-4814
URL: https://issues.apache.org/jira/browse/FLINK-4814
Project: Flink
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2627
Kafka 0.10 follow-up fixes
After merging https://github.com/apache/flink/pull/2369, there was some
follow-up feedback in the final commit:
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569028#comment-15569028
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2608
+1 to the general approach and the code
Some suggestions for name polishing:
- How about renaming `DISCARD_ON_CANCELLATION` to
`DELETE_ON_CANCELLATION`? That would sound more
[
https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569025#comment-15569025
]
Shannon Carey commented on FLINK-4803:
--
Yes, that's right. cancel() blocks on close(), and therefore
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569021#comment-15569021
]
Timo Walther commented on FLINK-4604:
-
You cannot use
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83017556
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83014810
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83016929
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83005668
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -111,8 +114,8 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83019574
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -295,7 +256,7 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83016682
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83019658
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -107,10 +113,10 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83007178
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83022623
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
---
@@ -257,74 +190,158 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83005541
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -54,8 +55,10 @@
import java.util.List;
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83019134
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -146,102 +152,57 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83004834
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingITCase.java
---
@@ -111,174 +115,191 @@ protected void testProgram()
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83014794
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -578,18 +647,28 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83015686
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -578,18 +647,28 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83006923
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83022754
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
---
@@ -257,74 +190,158 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83020529
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -60,26 +63,27 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83005706
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -256,11 +265,11 @@ public int compare(String o1,
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568940#comment-15568940
]
Alexander Shoshin commented on FLINK-4283:
--
It is still relevant. I have just strated researching
[
https://issues.apache.org/jira/browse/FLINK-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4635:
--
Issue Type: Sub-task (was: Task)
Parent: FLINK-3930
> Implement Data Transfer
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568819#comment-15568819
]
Stephan Ewen commented on FLINK-4283:
-
Is this issue still relevant, or has this instability been
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568803#comment-15568803
]
Stephan Ewen commented on FLINK-4813:
-
+1
> Having flink-test-utils as a dependency outside Flink
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2439
Okay, then we should re-add all the dependency exclusions that were removed
from the `flink-storm/pom.xml`.
---
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-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568798#comment-15568798
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2623
As far as I read it, Kryo 3.x is not strictly serialization compatible with
2.x, hence the major version number bump.
If the interfaces are still stable, then it should be fine to bump
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r83009444
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/PropertyRead.scala
---
@@ -0,0 +1,33 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568745#comment-15568745
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568789#comment-15568789
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568768#comment-15568768
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568782#comment-15568782
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user StephanEwen commented on the issue:
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r83008188
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeutils/RowIntervalTypeInfo.scala
---
@@ -0,0 +1,108 @@
+/*
+ *
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2623
This change adds Kryo-shaded to our dependency tree:
```
[INFO] | +- com.twitter:chill_2.10:jar:0.8.1:compile
[INFO] | | +- com.twitter:chill-java:jar:0.8.1:compile
[INFO] |
Github user albertoRamon commented on the issue:
https://github.com/apache/flink/pull/2619
Works OK ¡¡
[Capture
Output](http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/jdbc-JDBCInputFormat-tp9393p9489.html)
Thanks, Alb
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568712#comment-15568712
]
ASF GitHub Bot commented on FLINK-4108:
---
Github user albertoRamon commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3037:
--
Description:
Currently, if the {{FlinkKafkaConsumer}} is restoring a checkpoint and the
offset
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r83003348
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568701#comment-15568701
]
Robert Metzger commented on FLINK-4280:
---
This issue is related:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568703#comment-15568703
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568669#comment-15568669
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r83000595
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/windows/Session.java
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568664#comment-15568664
]
Anton Mushin commented on FLINK-4604:
-
I tried check function in
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568657#comment-15568657
]
Maximilian Michels commented on FLINK-4813:
---
+1 That sounds like a good solution.
> Having
1 - 100 of 224 matches
Mail list logo
