[
https://issues.apache.org/jira/browse/FLINK-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516671#comment-16516671
]
ASF GitHub Bot commented on FLINK-9417:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6088
cc @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Addison Higham updated FLINK-9612:
--
Component/s: Configuration
> Add option for minimal artifacts being pulled in meseos
>
[
https://issues.apache.org/jira/browse/FLINK-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Addison Higham updated FLINK-9611:
--
Component/s: Configuration
> Allow for user-defined artifacts to be specified as part of a
[
https://issues.apache.org/jira/browse/FLINK-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Addison Higham updated FLINK-9611:
--
Component/s: Docker
> Allow for user-defined artifacts to be specified as part of a mesos
Addison Higham created FLINK-9612:
-
Summary: Add option for minimal artifacts being pulled in meseos
Key: FLINK-9612
URL: https://issues.apache.org/jira/browse/FLINK-9612
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516530#comment-16516530
]
ASF GitHub Bot commented on FLINK-9143:
---
Github user yuqi1129 commented on the issue:
Github user yuqi1129 commented on the issue:
https://github.com/apache/flink/pull/5846
@dawidwys
Sorry , I will push my code in two days, if there still have any problem,
any suggestions are appreciated.
any way, if you have try to fix this problem, just go head.
---
Addison Higham created FLINK-9611:
-
Summary: Allow for user-defined artifacts to be specified as part
of a mesos overlay
Key: FLINK-9611
URL: https://issues.apache.org/jira/browse/FLINK-9611
Project:
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-9610:
Description:
The kafka connector package only contains the FlinkFixedPartitioner
implementation
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516283#comment-16516283
]
ASF GitHub Bot commented on FLINK-9610:
---
GitHub user nielsbasjes opened a pull request:
GitHub user nielsbasjes opened a pull request:
https://github.com/apache/flink/pull/6181
[FLINK-9610] [flink-connector-kafka-base] Add Kafka Partitioner that uses
the hash of the provided key.
## What is the purpose of the change
Add the simple feature of being able to
Niels Basjes created FLINK-9610:
---
Summary: Add Kafka partitioner that uses the key to partition by
Key: FLINK-9610
URL: https://issues.apache.org/jira/browse/FLINK-9610
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516161#comment-16516161
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6083
@dawidwys Thanks for the review! I will look into that PR. This test is for
Release 1.4 and 1.5 and provide a proof that Flink V4.0 and V5.0 can work with
ConfluentSchema Registry properly. As PR you
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516155#comment-16516155
]
ASF GitHub Bot commented on FLINK-9524:
---
GitHub user yzandrew opened a pull request:
GitHub user yzandrew opened a pull request:
https://github.com/apache/flink/pull/6180
[FLINK-9524][Table API & SQL] check whether a clean-up timer is expeired in
ProcTimeBoundedRangeOverâ¦
⦠to prevent NPE
## What is the purpose of the change
This pull request solve
[
https://issues.apache.org/jira/browse/FLINK-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516150#comment-16516150
]
ASF GitHub Bot commented on FLINK-9550:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6138
@dawidwys PR's been updated! Please review.
---
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/6177
@tzulitai the commits in this PR (except the most recent version change)
are from our 1.4.x fork and what we use in production. As discussed on the ML
not even the Kinesis version number is strictly
[
https://issues.apache.org/jira/browse/FLINK-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandish Kumar HN closed FLINK-9548.
---
Resolution: Duplicate
> Flink Apache Kudu Connector
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515974#comment-16515974
]
Sandish Kumar HN commented on FLINK-9548:
-
there is already work around here for Kudu and flink
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515915#comment-16515915
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196129193
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java
---
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9481:
-
Fix Version/s: 1.6.0
> FlinkKafkaProducer011ITCase deadlock in initializeState
>
[
https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9560:
Assignee: Etienne CARRIERE
> RateLimiting for FileSystem
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515886#comment-16515886
]
Till Rohrmann commented on FLINK-9567:
--
Thanks for reporting the issue [~dangdangdang]. Your
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9567:
Assignee: Shimin Yang
> Flink does not release resource in Yarn Cluster mode
>
[
https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9574:
-
Fix Version/s: 1.6.0
> Add a dedicated documentation page for state evolution
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9567:
-
Fix Version/s: 1.6.0
> Flink does not release resource in Yarn Cluster mode
>
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9575:
-
Fix Version/s: 1.6.0
> Potential race condition when removing JobGraph in HA
>
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9575:
-
Priority: Critical (was: Major)
> Potential race condition when removing JobGraph in HA
>
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9575:
-
Affects Version/s: 1.5.0
> Potential race condition when removing JobGraph in HA
>
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515881#comment-16515881
]
Till Rohrmann commented on FLINK-9575:
--
True, the problem you've described can occur [~Wosinsan]. It
[
https://issues.apache.org/jira/browse/FLINK-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9576:
-
Priority: Critical (was: Major)
> Wrong contiguity documentation
>
[
https://issues.apache.org/jira/browse/FLINK-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9576:
-
Fix Version/s: 1.6.0
> Wrong contiguity documentation
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9583:
-
Fix Version/s: 1.6.0
> Wrong number of TaskManagers' slots after recovery.
>
[
https://issues.apache.org/jira/browse/FLINK-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9587:
-
Fix Version/s: 1.6.0
> ContinuousFileMonitoringFunction crashes on short living files
>
[
https://issues.apache.org/jira/browse/FLINK-9595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9595:
-
Priority: Critical (was: Major)
> Add instructions to docs about ceased support of KPL version
[
https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9598:
-
Affects Version/s: 1.3.2
> [Checkpoints] The config Minimum Pause Between Checkpoints doesn't
GitHub user Tobii42 opened a pull request:
https://github.com/apache/flink/pull/6179
[hotfix][docs] Removed duplicate line in windows doc page
**(The sections below can be removed for hotfixes of typos)**
## Brief change log
- Removed a duplicate line in the windows
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196090706
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -52,7 +57,10 @@
--- End diff --
should
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515744#comment-16515744
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515713#comment-16515713
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196081080
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,455 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515689#comment-16515689
]
ASF GitHub Bot commented on FLINK-9599:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6178
[FLINK-9599][rest] Implement generic mechanism to access uploaded files
## What is the purpose of the change
This PR extends the existing multipart handling to also support mixed
multipart
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515675#comment-16515675
]
Dominik Wosiński commented on FLINK-9575:
-
Is my understanding right ?
> Potential race
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9571.
-
Resolution: Implemented
Merged in:
master: 0bdde8377c
> Switch to internal states in
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515655#comment-16515655
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6173
---
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/6173
LGTM ð Will merge.
---
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515652#comment-16515652
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515610#comment-16515610
]
ASF GitHub Bot commented on FLINK-6469:
---
Github user dawidwys commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515611#comment-16515611
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/6173
I had a few comments inline. After they are addressed, I think this is good
to merge.
---
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515608#comment-16515608
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user StefanRRichter commented on a diff in the pull
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5448
Hi @yanghua,
I am afraid Stephan won't be able to reply any time soon. I would suggest
to
- add the default unit to the parse method of `MemorySize` and use MB for
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r196046444
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java
---
@@ -392,14 +268,14 @@ public KeyGroupRange
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515600#comment-16515600
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r196043061
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java
---
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515597#comment-16515597
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r196042694
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java
---
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/6083
Just my two cents, we've recently introduced a `DeserializationSchema` that
uses Confluent Schema Registry to decode data. Could you reuse it rather than
introduce a new one. The PR in which it was
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515565#comment-16515565
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user dawidwys commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Summary: Add bucket ready mechanism for BucketingSink when checkpoint
complete (was: Add bucket
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515548#comment-16515548
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user azagrebin commented on the issue:
Github user azagrebin commented on the issue:
https://github.com/apache/flink/pull/6173
Thanks @sihuazhou! I have added changes to address the comments
---
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Issue Type: New Feature (was: Improvement)
> Add bucket ready notification mechanism for
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/6076
I have added a sentence covering this, but it would be nice to merge it and
not prolonging and ever extending this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515516#comment-16515516
]
Chesnay Schepler commented on FLINK-9467:
-
PR: https://github.com/apache/flink/pull/6152
> No
[
https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515511#comment-16515511
]
ASF GitHub Bot commented on FLINK-9560:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6149#discussion_r196008935
--- Diff:
flink-core/src/test/java/org/apache/flink/core/fs/LimitedConnectionsFileSystemTest.java
---
@@ -122,6 +122,42 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description: Currently, BucketingSink only can {{notifyCheckpointComplete}}
(was: Currently, )
>
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description: Currently,
> Add bucket ready notification mechanism for BucketingSink when
mingleizhang created FLINK-9609:
---
Summary: Add bucket ready notification mechanism for BucketingSink
when checkpoint complete
Key: FLINK-9609
URL: https://issues.apache.org/jira/browse/FLINK-9609
[
https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515503#comment-16515503
]
Piotr Nowojski commented on FLINK-8521:
---
Nope, I haven't worked on it further after marking this as
[
https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8521:
-
Assignee: (was: Piotr Nowojski)
>
[
https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8521:
--
Fix Version/s: (was: 1.5.1)
(was: 1.4.3)
>
[
https://issues.apache.org/jira/browse/FLINK-9602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9602:
-
Priority: Blocker (was: Major)
> Extend CommonOption section
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515473#comment-16515473
]
ASF GitHub Bot commented on FLINK-9594:
---
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/6172#discussion_r195992732
--- Diff: flink-end-to-end-tests/README.md ---
@@ -33,6 +33,53 @@ $ FLINK_DIR=
flink-end-to-end-tests/test-scripts/test_batch_wordcount
##
[
https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515475#comment-16515475
]
ASF GitHub Bot commented on FLINK-9594:
---
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/6172#discussion_r195992679
--- Diff: flink-end-to-end-tests/README.md ---
@@ -33,6 +33,53 @@ $ FLINK_DIR=
flink-end-to-end-tests/test-scripts/test_batch_wordcount
##
[
https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515474#comment-16515474
]
ASF GitHub Bot commented on FLINK-9594:
---
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/6172#discussion_r195992920
--- Diff: flink-end-to-end-tests/README.md ---
@@ -33,6 +33,53 @@ $ FLINK_DIR=
flink-end-to-end-tests/test-scripts/test_batch_wordcount
##
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6172#discussion_r195991753
--- Diff: flink-end-to-end-tests/README.md ---
@@ -33,6 +33,53 @@ $ FLINK_DIR=
flink-end-to-end-tests/test-scripts/test_batch_wordcount
##
[
https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515472#comment-16515472
]
ASF GitHub Bot commented on FLINK-9594:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6177
I'm not sure that we want to backport the shard-mapping hash function. IMO,
that is a new feature and shouldn't go into a bugfix release.
What do you think @tweise?
---
[
https://issues.apache.org/jira/browse/FLINK-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9601.
-
Resolution: Fixed
Merged in:
master: 0e9b066aab
> Snapshot of CopyOnWriteStateTable will failed
[
https://issues.apache.org/jira/browse/FLINK-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515461#comment-16515461
]
ASF GitHub Bot commented on FLINK-9601:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6174
---
[
https://issues.apache.org/jira/browse/FLINK-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515442#comment-16515442
]
ASF GitHub Bot commented on FLINK-9601:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/6174
LGTM now ð Will merge.
---
[
https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9606.
Resolution: Duplicate
Closing as duplicate of FLINK-2169.
> Support ParquetTableSource
>
1 - 100 of 101 matches
Mail list logo
