[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124340#comment-16124340
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4522
@bowenli86 its fine to upgrade KPL. It's consumer related libraries version
that currently cannot be touched.
Consumer related versions can currently only be upgraded until 1) Flink 1.2
is
[
https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095490#comment-16095490
]
Ted Yu edited comment on FLINK-6333 at 8/11/17 11:56 PM:
-
Looks like rocksdb issue
[
https://issues.apache.org/jira/browse/FLINK-6402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15986965#comment-15986965
]
Ted Yu edited comment on FLINK-6402 at 8/11/17 11:49 PM:
-
Pardon the typo.
The
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4522
@tzulitai @aljoscha there's another major bug in KPL that we need to fix
for flink-connector-kinesis
https://github.com/awslabs/amazon-kinesis-producer/issues/10 We've been seeing
that bug
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124126#comment-16124126
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123939#comment-16123939
]
ASF GitHub Bot commented on FLINK-7226:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4392
@willddy Please open a new JIRA @
https://issues.apache.org/jira/browse/FLINK with a description of what error
you are encountering. I looked through the code and we never set the encoding
header
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123860#comment-16123860
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4522
oh.this is not goodDo you mean that we cannot upgrade KPL/KCL until
Flink 1.5?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4515#discussion_r132754963
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailureHandler.java
---
@@ -92,7 +92,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123772#comment-16123772
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4525
Hi @XuPingyong thanks for submitting this PR. I'm not clear on why the
`null` check was added in FLINK-4075 and `ContinuousFileProcessingTest` is not
running locally for me. When calling
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123696#comment-16123696
]
ASF GitHub Bot commented on FLINK-7245:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/4530
[FLINK-7245] [stream] Support holding back watermarks with static delays
## What is the purpose of the change
*This pull request aims to allow the operators to support holding back
Ted Yu created FLINK-7433:
-
Summary: Lack of synchronization accessing inProgress in
JobCancellationWithSavepointHandlers
Key: FLINK-7433
URL: https://issues.apache.org/jira/browse/FLINK-7433
Project: Flink
Ted Yu created FLINK-7432:
-
Summary: Unclosed HighAvailabilityServices instance in
QueryableStateClient
Key: FLINK-7432
URL: https://issues.apache.org/jira/browse/FLINK-7432
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123534#comment-16123534
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , Thank you for reviews!
Considering the difference between `FixedBufferPool` and `LocalBufferPool`,
I think you are right. I also think of this question when implement this new
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4529
FYI:
- newer netty 4.0.xx versions also use `buffer.slice(index, length)` inside
their `extractFrame()` method (see
https://github.com/netty/netty/commit/891be30a28c6dc5a1edf1cb5a3690644cf4ff66e)
[
https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123525#comment-16123525
]
ASF GitHub Bot commented on FLINK-7428:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123522#comment-16123522
]
Aljoscha Krettek commented on FLINK-3133:
-
I would be in favour of closing this issue. The
[
https://issues.apache.org/jira/browse/FLINK-3785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123515#comment-16123515
]
Ufuk Celebi commented on FLINK-3785:
It is possible but not documented as part of the rest API. We
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6281.
Resolution: Implemented
Fix Version/s: 1.4.0
Implemented for 1.4.0 with
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123487#comment-16123487
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3712
---
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 fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4479#discussion_r132691900
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala
---
@@ -314,5 +314,34 @@ class SqlITCase
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4479#discussion_r132703597
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1181,8 +1188,12 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123449#comment-16123449
]
ASF GitHub Bot commented on FLINK-7309:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123448#comment-16123448
]
ASF GitHub Bot commented on FLINK-7309:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123450#comment-16123450
]
ASF GitHub Bot commented on FLINK-7309:
---
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/4479#discussion_r132690201
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1172,6 +1172,13 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123446#comment-16123446
]
ASF GitHub Bot commented on FLINK-7309:
---
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/4479#discussion_r132703400
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1193,12 +1204,18 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123447#comment-16123447
]
ASF GitHub Bot commented on FLINK-7309:
---
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/4479#discussion_r132689501
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1193,12 +1204,18 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123437#comment-16123437
]
ASF GitHub Bot commented on FLINK-7226:
---
Github user willddy commented on the issue:
Github user willddy commented on the issue:
https://github.com/apache/flink/pull/4392
I still found this issue only when the job id not found as follows in the
latest v1.3.2. Pls. reopen the issue
localhost:8001/jobs/0e12860ffae73f23dc104aedb814d6d2
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123369#comment-16123369
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4358
Hi Nico, I'm still waiting for Travis before merging FLINK-7056. In the
meantime could you rebase this PR and squash all FLINK-7068 commits into one?
Thanks.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123367#comment-16123367
]
ASF GitHub Bot commented on FLINK-7396:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7396.
---
Resolution: Fixed
Fixed on master in
1de8acc3c89af22f10aed80d7016545db23a0ad5
Fixed on
[
https://issues.apache.org/jira/browse/FLINK-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123365#comment-16123365
]
ASF GitHub Bot commented on FLINK-7057:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123364#comment-16123364
]
ASF GitHub Bot commented on FLINK-7396:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4511
Could you please close the PR?
---
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
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4238
Hi Nico, I'm still waiting for Travis before merging FLINK-7056. Could you
rebase this PR in the meantime and maybe also squash all FLINK-7057 commits
into one? This helps me to get faster
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4511
Thanks! I merged it. ð
---
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-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123328#comment-16123328
]
Xingcan Cui commented on FLINK-7245:
Hi [~fhueske], thanks for the response. I think you are right.
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123314#comment-16123314
]
Fabian Hueske commented on FLINK-7245:
--
Hi [~xccui], thanks for the pointer to you code. I had a look
Nico Kruber created FLINK-7431:
--
Summary: test instability in JobManagerFailsITCase
Key: FLINK-7431
URL: https://issues.apache.org/jira/browse/FLINK-7431
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7431:
---
Labels: test-stability (was: )
> test instability in JobManagerFailsITCase
>
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123282#comment-16123282
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r132655177
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/FixedBufferPool.java
---
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123283#comment-16123283
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r132655478
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferPoolListener.java
---
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123287#comment-16123287
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123284#comment-16123284
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r13267
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactory.java
---
@@ -39,6 +39,17 @@
BufferPool
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123285#comment-16123285
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123286#comment-16123286
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r132670989
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/FixedBufferPool.java
---
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r132655594
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferPool.java
---
@@ -79,4 +79,12 @@
* Returns the number of used
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r132673916
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -221,13 +228,44 @@ public BufferPool
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7429:
--
Assignee: Tzu-Li (Gordon) Tai
> Add restore from 1.2 / 1.3 migration tests for
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4526
Thanks for the review @aljoscha!
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 not have
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123273#comment-16123273
]
ASF GitHub Bot commented on FLINK-7407:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123272#comment-16123272
]
Tzu-Li (Gordon) Tai commented on FLINK-7429:
[~aljoscha] I agree.
> Add restore from 1.2 /
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123262#comment-16123262
]
Gábor Hermann commented on FLINK-3133:
--
What's the status of this? We already have collect()
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123258#comment-16123258
]
Aljoscha Krettek commented on FLINK-7429:
-
I promoted to blocker, because we're thinking about
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7429:
Fix Version/s: 1.3.3
1.4.0
> Add restore from 1.2 / 1.3 migration tests
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7429:
Priority: Blocker (was: Major)
> Add restore from 1.2 / 1.3 migration tests for
[
https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123255#comment-16123255
]
ASF GitHub Bot commented on FLINK-6244:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4320
To me, this looks good now. Let's see if @kl0u want's to take another look,
otherwise I would say it's good to merge.
---
If your project is set up for it, you can reply to this email and have
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132669361
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -859,7 +940,7 @@ public boolean apply(@Nullable State input) {
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123249#comment-16123249
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123242#comment-16123242
]
ASF GitHub Bot commented on FLINK-7387:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4498
---
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-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123237#comment-16123237
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7387.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via d95d20eb45185151d731c9b41e9b1ac22cf81334
>
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7381.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via 9f790d3efe5e8267da05eb97bbe07ca8a0f859fe
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4492
---
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 dawidwys commented on the issue:
https://github.com/apache/flink/pull/4320
Thanks for the review @aljoscha . I've addressed all your comments. Also
changed a section in docs to use the preferred version of handling timeouted
results. I've rebased the PR, as it was far
[
https://issues.apache.org/jira/browse/FLINK-7260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7260.
Resolution: Fixed
Assignee: Timo Walther
Fix Version/s: 1.4.0
Fixed with
[
https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123229#comment-16123229
]
ASF GitHub Bot commented on FLINK-6244:
---
Github user dawidwys commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123225#comment-16123225
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3712
Thanks for the update @haohui.
I'll merge this PR :-)
I have to change some of the type mappings to make it work with
`JDBCOutputFormat`. I think it would be a good idea to redesign the
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123207#comment-16123207
]
Peter Ertl edited comment on FLINK-7430 at 8/11/17 11:21 AM:
-
It seems like
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123207#comment-16123207
]
Peter Ertl edited comment on FLINK-7430 at 8/11/17 11:20 AM:
-
It seems like
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123207#comment-16123207
]
Peter Ertl commented on FLINK-7430:
---
It seems like the task itself is finished but the output format is
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Ertl updated FLINK-7430:
--
Description:
The class *ContinuousFileReaderOperator* is swallowing exceptions as the
following
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Ertl updated FLINK-7430:
--
Description:
The class *ContinuousFileReaderOperator* is swallowing exceptions as the
following
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Ertl updated FLINK-7430:
--
Description:
The class *ContinuousFileReaderOperator* is swallowing exception as the
following example
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Ertl updated FLINK-7430:
--
Environment:
- macOS 10.12.6
- Oracle JDK 1.8.0_144
- Flink 1.3.2
> ContinuousFileReaderOperator
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Ertl updated FLINK-7430:
--
Description:
The class ContinuousFileReaderOperator is swallowing exception as the following
example
Peter Ertl created FLINK-7430:
-
Summary: ContinuousFileReaderOperator swallows exceptions
Key: FLINK-7430
URL: https://issues.apache.org/jira/browse/FLINK-7430
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123167#comment-16123167
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4522
Ok, so it seems like Java serialization of the Kinesis classes was removed
only starting from 1.3.x.
That means unless we do some classloading trick, we can't really upgrade
the Kinesis
Tzu-Li (Gordon) Tai created FLINK-7429:
--
Summary: Add restore from 1.2 / 1.3 migration tests for
FlinkKinesisConsumer
Key: FLINK-7429
URL: https://issues.apache.org/jira/browse/FLINK-7429
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123159#comment-16123159
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4522
Hmm, I think Java serialization was removed from the Kinesis connector
starting from 1.3.
But thinking of it now, I recall that there was some migration path from
that. Let me double check ..
1 - 100 of 166 matches
Mail list logo
