[
https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651143#comment-16651143
]
ASF GitHub Bot commented on FLINK-10559:
TisonKun edited a comment on issue #6851: [FLINK-10559]
[
https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651142#comment-16651142
]
ASF GitHub Bot commented on FLINK-10559:
TisonKun commented on issue #6851: [FLINK-10559] Remove
TisonKun commented on issue #6851: [FLINK-10559] Remove
LegacyLocalStreamEnvironment
URL: https://github.com/apache/flink/pull/6851#issuecomment-430105332
Travis fails on
```
05:09:30.233 [ERROR] Failed to execute goal
com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp
TisonKun edited a comment on issue #6851: [FLINK-10559] Remove
LegacyLocalStreamEnvironment
URL: https://github.com/apache/flink/pull/6851#issuecomment-430105332
Travis fails on
>05:09:30.233 [ERROR] Failed to execute goal
com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp
TisonKun opened a new pull request #6852: [hotfix] correct document
URL: https://github.com/apache/flink/pull/6852
## What is the purpose of the change
We don't use `LocalFlinkMiniCluster`, in fact we use `MiniCluster`
## Verifying this change
This change is a trivial
[
https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10559:
---
Labels: pull-request-available (was: )
> Remove LegacyLocalStreamEnvironment
>
[
https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651120#comment-16651120
]
ASF GitHub Bot commented on FLINK-10559:
TisonKun opened a new pull request #6851: [FLINK-10559]
TisonKun opened a new pull request #6851: [FLINK-10559] Remove
LegacyLocalStreamEnvironment
URL: https://github.com/apache/flink/pull/6851
## What is the purpose of the change
Remove `LegacyLocalStreamEnvironment` which based on legacy mode and now we
have its replacement
TisonKun created FLINK-10559:
Summary: Remove LegacyLocalStreamEnvironment
Key: FLINK-10559
URL: https://issues.apache.org/jira/browse/FLINK-10559
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651114#comment-16651114
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull request #6705:
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r225396776
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1665#comment-1665
]
ASF GitHub Bot commented on FLINK-10398:
yanghua commented on issue #6736: [FLINK-10398][table]
yanghua commented on issue #6736: [FLINK-10398][table] Add Tanh math function
supported in Table API and SQL
URL: https://github.com/apache/flink/pull/6736#issuecomment-430099630
@xccui Does it look good to you?
This is an
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651110#comment-16651110
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on issue #6705:
zhijiangW commented on issue #6705: [FLINK-10356][network] add sanity checks to
SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#issuecomment-430099420
@NicoK , thanks for this improvement and I think it is actually necessary to
add some checks
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651108#comment-16651108
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull request #6705:
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651107#comment-16651107
]
ASF GitHub Bot commented on FLINK-10356:
zhijiangW commented on a change in pull request #6705:
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r225395730
##
File path:
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r225389817
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651085#comment-16651085
]
vinoyang commented on FLINK-10246:
--
[~till.rohrmann] Now the remaining two tasks of this task already
[
https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651083#comment-16651083
]
ASF GitHub Bot commented on FLINK-10252:
yanghua opened a new pull request #6850: [FLINK-10252]
yanghua opened a new pull request #6850: [FLINK-10252] Handle oversized metric
messges
URL: https://github.com/apache/flink/pull/6850
## What is the purpose of the change
*This pull request handles oversized metric messges*
## Brief change log
- *Handle oversized
[
https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10252:
---
Labels: pull-request-available (was: )
> Handle oversized metric messges
>
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651052#comment-16651052
]
ASF GitHub Bot commented on FLINK-4816:
---
tony810430 closed pull request #4828: [FLINK-4816]
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-4816:
--
Labels: pull-request-available (was: )
> Executions failed from "DEPLOYING" should retain
[
https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4574:
--
Assignee: (was: Wei-Che Wei)
> Strengthen fetch interval implementation in Kinesis
tony810430 closed pull request #4828: [FLINK-4816] [checkpoints] Executions
failed from "DEPLOYING" should retain restored checkpoint information
URL: https://github.com/apache/flink/pull/4828
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4816:
--
Assignee: (was: Wei-Che Wei)
> Executions failed from "DEPLOYING" should retain restored
[
https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651050#comment-16651050
]
ASF GitHub Bot commented on FLINK-4574:
---
tony810430 closed pull request #2925: [FLINK-4574]
[
https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-4574:
--
Labels: pull-request-available (was: )
> Strengthen fetch interval implementation in Kinesis
tony810430 closed pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch
interval implementation in Kinesis consumer
URL: https://github.com/apache/flink/pull/2925
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651048#comment-16651048
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on issue #6432: [FLINK-9970] [table] Add
yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function
for table/sql API
URL: https://github.com/apache/flink/pull/6432#issuecomment-430076195
@xccui Some suggestion I have accepted, some of them I gave a new comment.
Any problem, please let me know.
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651046#comment-16651046
]
ASF GitHub Bot commented on FLINK-10253:
yanghua commented on issue #6839: [FLINK-10253] Run
yanghua commented on issue #6839: [FLINK-10253] Run MetricQueryService with
lower priority
URL: https://github.com/apache/flink/pull/6839#issuecomment-430075883
@tillrohrmann Referring to your suggestion, I have updated this PR, please
review again. Thank you.
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651037#comment-16651037
]
ASF GitHub Bot commented on FLINK-10474:
hequn8128 commented on issue #6792:
hequn8128 commented on issue #6792: [FLINK-10474][table] Don't translate
IN/NOT_IN to JOIN with VALUES
URL: https://github.com/apache/flink/pull/6792#issuecomment-430073199
Thanks a lot for your review!
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651034#comment-16651034
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull request #6432:
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225370746
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651031#comment-16651031
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull request #6432:
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225370366
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651022#comment-16651022
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull request #6432:
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225367314
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651021#comment-16651021
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull request #6432:
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225367094
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651019#comment-16651019
]
ASF GitHub Bot commented on FLINK-10527:
yanghua commented on issue #6816: [FLINK-10527] Cleanup
yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in
YarnTestBase
URL: https://github.com/apache/flink/pull/6816#issuecomment-430066720
Hi @tillrohrmann and @TisonKun what about this change? In addition, I create
a single JIRA issue
vinoyang created FLINK-10558:
Summary: Port YARNHighAvailabilityITCase and
YARNSessionCapacitySchedulerITCase to new code base
Key: FLINK-10558
URL: https://issues.apache.org/jira/browse/FLINK-10558
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650851#comment-16650851
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650847#comment-16650847
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650844#comment-16650844
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225311291
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650843#comment-16650843
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225324041
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650848#comment-16650848
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650842#comment-16650842
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650846#comment-16650846
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225311291
##
File path:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225302431
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650841#comment-16650841
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650845#comment-16650845
]
ASF GitHub Bot commented on FLINK-9970:
---
xccui commented on a change in pull request #6432:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225319289
##
File path:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225322607
##
File path:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225322741
##
File path:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225307607
##
File path:
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r225320391
##
File path: docs/dev/table/functions.md
##
@@ -2449,6 +2449,30 @@ REPEAT(string,
Ruby Andrews created FLINK-10557:
Summary: Checkpoint size metric incorrectly reports the same value
until restart
Key: FLINK-10557
URL: https://issues.apache.org/jira/browse/FLINK-10557
Project:
[
https://issues.apache.org/jira/browse/FLINK-10553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650824#comment-16650824
]
ASF GitHub Bot commented on FLINK-10553:
xuefuz commented on issue #6847: [FLINK-10553] [sql]
xuefuz commented on issue #6847: [FLINK-10553] [sql] Unified sink and source
table name in SQL statement
URL: https://github.com/apache/flink/pull/6847#issuecomment-430020997
Hi Jerry,
Thanks for fixing this. Your changes seems good. However, I have a side
question: do we expect
[
https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10556:
--
Description:
This is an umbrella JIRA tracking all enhancement and issues related to
integrating
[
https://issues.apache.org/jira/browse/FLINK-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun closed FLINK-2592.
---
Resolution: Won't Fix
In fact, we want to remove {{FlinkMiniCluster}} since it is based on deprecated
[
https://issues.apache.org/jira/browse/FLINK-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9932.
--
Resolution: Fixed
Fixed via
1.7.0:
438f650b180d1b47a4fa79c9c8314787b3d164e3
[
https://issues.apache.org/jira/browse/FLINK-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650716#comment-16650716
]
ASF GitHub Bot commented on FLINK-9932:
---
asfgit closed pull request #6780: [FLINK-9932] [runtime]
asfgit closed pull request #6780: [FLINK-9932] [runtime] fix slot leak when
task executor offer slot to job master timeout
URL: https://github.com/apache/flink/pull/6780
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650696#comment-16650696
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9697] Provide
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-429991327
cc @aljoscha
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang updated FLINK-10542:
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-10556
> Register Hive metastore as
Xuefu Zhang created FLINK-10556:
---
Summary: Integration with Apache Hive
Key: FLINK-10556
URL: https://issues.apache.org/jira/browse/FLINK-10556
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rafi Aroch reassigned FLINK-10525:
--
Assignee: (was: Rafi Aroch)
> Deserialization schema, skip data, that couldn't be
TisonKun opened a new pull request #6849: [FLINK-10555] [test] Port
AkkaSslITCase to new code base
URL: https://github.com/apache/flink/pull/6849
## What is the purpose of the change
Port `AkkaSslITCase` to new code base, as `MiniClusterSslITCase`.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10555:
---
Labels: pull-request-available (was: )
> Port AkkaSslITCase to new code base
>
[
https://issues.apache.org/jira/browse/FLINK-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650525#comment-16650525
]
ASF GitHub Bot commented on FLINK-10555:
TisonKun opened a new pull request #6849: [FLINK-10555]
TisonKun created FLINK-10555:
Summary: Port AkkaSslITCase to new code base
Key: FLINK-10555
URL: https://issues.apache.org/jira/browse/FLINK-10555
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650498#comment-16650498
]
ASF GitHub Bot commented on FLINK-10474:
fhueske commented on issue #6792: [FLINK-10474][table]
fhueske commented on issue #6792: [FLINK-10474][table] Don't translate
IN/NOT_IN to JOIN with VALUES
URL: https://github.com/apache/flink/pull/6792#issuecomment-429937833
Thanks for the update @hequn8128.
The changes look good. I'll merge this PR.
Thanks, Fabian
[
https://issues.apache.org/jira/browse/FLINK-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650482#comment-16650482
]
ASF GitHub Bot commented on FLINK-10554:
zentol opened a new pull request #6848:
[
https://issues.apache.org/jira/browse/FLINK-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10554:
---
Labels: pull-request-available (was: )
> Bump flink-shaded dependency version
>
zentol opened a new pull request #6848: [FLINK-10554][build] Bump flink-shaded
to 5.0
URL: https://github.com/apache/flink/pull/6848
This PR bumps the flink-shaded version to 5.0. This shouldn't affect
anything except giving the table API access to `jackson-dataformat-csv`.
/cc
Chesnay Schepler created FLINK-10554:
Summary: Bump flink-shaded dependency version
Key: FLINK-10554
URL: https://issues.apache.org/jira/browse/FLINK-10554
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650471#comment-16650471
]
Fabian Hueske commented on FLINK-8578:
--
bq. If a user wants to upsert under proct-time, he doesn't
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650448#comment-16650448
]
ASF GitHub Bot commented on FLINK-9592:
---
kl0u commented on issue #6824:
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650447#comment-16650447
]
ASF GitHub Bot commented on FLINK-9592:
---
kent2171 closed pull request #6824:
kl0u commented on issue #6824: [FLINK-9592][flink-connector-filesystem] added
ability to hook file state changing
URL: https://github.com/apache/flink/pull/6824#issuecomment-429922404
Perfect @kent2171 ! Looking forward to your design proposal.
kent2171 closed pull request #6824: [FLINK-9592][flink-connector-filesystem]
added ability to hook file state changing
URL: https://github.com/apache/flink/pull/6824
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
[
https://issues.apache.org/jira/browse/FLINK-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650443#comment-16650443
]
Hequn Cheng commented on FLINK-8578:
> Upsert Order
Yes, a non-timestamp order filed can cover more
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10135.
Resolution: Fixed
1.6: 5b5d95334a91bf7d51a8c02c0d168a6d4ad006e9
1.5:
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650442#comment-16650442
]
ASF GitHub Bot commented on FLINK-9592:
---
kent2171 commented on issue #6824:
kent2171 commented on issue #6824: [FLINK-9592][flink-connector-filesystem]
added ability to hook file state changing
URL: https://github.com/apache/flink/pull/6824#issuecomment-429921703
ok, will return with the proposal, thx @kl0u
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650438#comment-16650438
]
ASF GitHub Bot commented on FLINK-9592:
---
kl0u commented on issue #6824:
kl0u commented on issue #6824: [FLINK-9592][flink-connector-filesystem] added
ability to hook file state changing
URL: https://github.com/apache/flink/pull/6824#issuecomment-429920387
Hi @kent2171 ! I am not so sure if the `BucketingSink` is going to be
deprecated soon. The reason that
1 - 100 of 314 matches
Mail list logo
