[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189039#comment-17189039
]
Nicholas Jiang edited comment on FLINK-19064 at 9/2/20, 7:24 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189039#comment-17189039
]
Nicholas Jiang commented on FLINK-19064:
[~rmetzger],
[
https://issues.apache.org/jira/browse/FLINK-19015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189097#comment-17189097
]
jack sun commented on FLINK-19015:
--
[~gkgkgk]no , It will throw 'reassignment to val' error, if replace
[
https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188635#comment-17188635
]
Roman Khachatryan edited comment on FLINK-19109 at 9/2/20, 9:35 AM:
HuangXingBo commented on a change in pull request #13232:
URL: https://github.com/apache/flink/pull/13232#discussion_r481933942
##
File path: docs/dev/python/user-guide/table/dependency_management.zh.md
##
@@ -61,49 +61,49 @@ table_env.add_python_file(file_path)
HuangXingBo commented on a change in pull request #13295:
URL: https://github.com/apache/flink/pull/13295#discussion_r481943491
##
File path: docs/dev/python/faq.md
##
@@ -52,6 +52,19 @@ $ source venv/bin/activate
$ python xxx.py
{% endhighlight %}
+**Note:** When
crazyzhou opened a new pull request #13303:
URL: https://github.com/apache/flink/pull/13303
## What is the purpose of the change
This pull request makes the rowdata converters public. That way third party
projects can utilize the converter to serialize and deserialize
[
https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-18712:
Assignee: Yun Tang
> Flink RocksDB statebackend memory leak issue
>
[
https://issues.apache.org/jira/browse/FLINK-19124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189153#comment-17189153
]
Aljoscha Krettek commented on FLINK-19124:
--
I'd be very happy to work in this with a
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189043#comment-17189043
]
Robert Metzger commented on FLINK-19064:
In my understanding of the {{InputFormat}} interface,
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* b58ab30b48a7405840656ebc26ce55fad7473497 Azure:
Harold Dost III created FLINK-19122:
---
Summary: Prometheus scrape generates huge scrape target.
Key: FLINK-19122
URL: https://issues.apache.org/jira/browse/FLINK-19122
Project: Flink
Issue
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481887743
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharedSlot.java
##
@@ -0,0 +1,204 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189088#comment-17189088
]
Jark Wu commented on FLINK-19115:
-
If I understand correctly, what you want is only write non-null
flinkbot edited a comment on pull request #13301:
URL: https://github.com/apache/flink/pull/13301#issuecomment-685356952
## CI report:
* a5a665a041c0a6c2c017289463e5122f2c8f6282 Azure:
dawidwys commented on a change in pull request #13249:
URL: https://github.com/apache/flink/pull/13249#discussion_r481928736
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##
@@ -1160,14 +1160,25 @@ public final
tzulitai opened a new pull request #7:
URL: https://github.com/apache/flink-statefun-docker/pull/7
This makes some commonly used filesystems ready to be used out-of-box with
the image.
This is an automated message from the
tzulitai opened a new pull request #140:
URL: https://github.com/apache/flink-statefun/pull/140
This change also has a corresponding change in
`apache/flink-statefun-docker`:
https://github.com/apache/flink-statefun-docker/pull/7
[
https://issues.apache.org/jira/browse/FLINK-19019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19019:
---
Labels: pull-request-available (was: )
> Add HDFS / S3 / GCS support to Flink-StateFun
flinkbot commented on pull request #13303:
URL: https://github.com/apache/flink/pull/13303#issuecomment-685551684
## CI report:
* 167e59c5fc3ee18bdc6ecd8175f914e379191816 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
miklosgergely commented on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-685551218
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot edited a comment on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000
## CI report:
* 21bf743431be5233b62ff1a127f81721edd3939d Azure:
flinkbot edited a comment on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836
## CI report:
* 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN
* ef0e2d93a502dd9b3050200b4a5b43f96f4e045b Azure:
flinkbot commented on pull request #13305:
URL: https://github.com/apache/flink/pull/13305#issuecomment-685657746
## CI report:
* 6da9dbc0b1f5f47475da8dfe5be8d8fd4ef80edc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
dianfu commented on a change in pull request #13302:
URL: https://github.com/apache/flink/pull/13302#discussion_r481989552
##
File path: docs/dev/python/index.md
##
@@ -2,7 +2,7 @@
title: "Python API"
nav-id: python
nav-parent_id: dev
-nav-pos: 50
Review comment:
flinkbot edited a comment on pull request #13304:
URL: https://github.com/apache/flink/pull/13304#issuecomment-685633990
## CI report:
* d308fe842311e794be70b21c1f9335c93fb29b5b Azure:
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19110:
---
Labels: pull-request-available (was: )
> Flatten current PyFlink documentation structure
>
[
https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189047#comment-17189047
]
Dawid Wysakowicz commented on FLINK-19112:
--
Just throwing in another idea.
How about catching
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* 4f62c8cfc30654a7236e45b48a5846267897ba3a Azure:
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189049#comment-17189049
]
Nicholas Jiang commented on FLINK-19064:
[~rmetzger], I got your point of understanding. In
flinkbot edited a comment on pull request #13302:
URL: https://github.com/apache/flink/pull/13302#issuecomment-685404422
## CI report:
* f034b22420e2670b326949b657a61ac5a0dc7185 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-19113:
---
Component/s: API / DataStream
> Add support for checkpointing with selectable inputs
>
[
https://issues.apache.org/jira/browse/FLINK-19113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189117#comment-17189117
]
Piotr Nowojski commented on FLINK-19113:
Another reason why this check in
flinkbot edited a comment on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836
## CI report:
* 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN
* ef0e2d93a502dd9b3050200b4a5b43f96f4e045b Azure:
echauchot commented on pull request #13040:
URL: https://github.com/apache/flink/pull/13040#issuecomment-685570227
> Thanks for the update @echauchot
>
> I see there are some git conflicts now, can you rebase your branch to the
latest master? Besides, there are some checkstyle
echauchot edited a comment on pull request #13040:
URL: https://github.com/apache/flink/pull/13040#issuecomment-685570227
> Thanks for the update @echauchot
>
> I see there are some git conflicts now, can you rebase your branch to the
latest master? Besides, there are some
zhijiangW merged pull request #13286:
URL: https://github.com/apache/flink/pull/13286
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-19124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189154#comment-17189154
]
Timo Walther commented on FLINK-19124:
--
+1 to this. I was wondering about this as well.
> Some
flinkbot commented on pull request #13304:
URL: https://github.com/apache/flink/pull/13304#issuecomment-685633990
## CI report:
* d308fe842311e794be70b21c1f9335c93fb29b5b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189161#comment-17189161
]
liufangliang commented on FLINK-18938:
--
[~jark] , i will finish it later.
> Throw better exception
flinkbot edited a comment on pull request #13302:
URL: https://github.com/apache/flink/pull/13302#issuecomment-685404422
## CI report:
* f034b22420e2670b326949b657a61ac5a0dc7185 Azure:
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* 4f62c8cfc30654a7236e45b48a5846267897ba3a Azure:
flinkbot commented on pull request #13302:
URL: https://github.com/apache/flink/pull/13302#issuecomment-685396154
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
rkhachatryan commented on a change in pull request #13286:
URL: https://github.com/apache/flink/pull/13286#discussion_r481809234
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -366,11
wangxiyuan opened a new pull request #23:
URL: https://github.com/apache/flink-docker/pull/23
The docker image `openjdk:8-jre` only works for amd64.
When running test on arm64, use `arm64v8/openjdk:8-jre` instead.
HuangXingBo commented on a change in pull request #13292:
URL: https://github.com/apache/flink/pull/13292#discussion_r481923107
##
File path: flink-python/pyflink/datastream/stream_execution_environment.py
##
@@ -553,6 +553,34 @@ def set_python_executable(self, python_exec:
[
https://issues.apache.org/jira/browse/FLINK-19019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-19019:
---
Assignee: Tzu-Li (Gordon) Tai
> Add HDFS / S3 / GCS support to
Aljoscha Krettek created FLINK-19123:
Summary: TestStreamEnvironment does not use shared MiniCluster for
executeAsync()
Key: FLINK-19123
URL: https://issues.apache.org/jira/browse/FLINK-19123
[
https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19098:
---
Labels: pull-request-available (was: )
> Make Rowdata converters public
>
[
https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189152#comment-17189152
]
tartarus commented on FLINK-19022:
--
[~trohrmann] sorry , There is another question to confirm.
if we
[
https://issues.apache.org/jira/browse/FLINK-19123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-19123:
-
Fix Version/s: 1.12.0
> TestStreamEnvironment does not use shared MiniCluster for
[
https://issues.apache.org/jira/browse/FLINK-19118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19118:
---
Labels: pull-request-available (was: )
> Support Expression in the operations of the
flinkbot commented on pull request #13304:
URL: https://github.com/apache/flink/pull/13304#issuecomment-685626147
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
Aljoscha Krettek created FLINK-19124:
Summary: Some JobClient methods are not ergonomic, require
ClassLoader argument
Key: FLINK-19124
URL: https://issues.apache.org/jira/browse/FLINK-19124
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189037#comment-17189037
]
Timo Walther commented on FLINK-19112:
--
I was thinking about giving a more helpful exception as
flinkbot commented on pull request #13302:
URL: https://github.com/apache/flink/pull/13302#issuecomment-685404422
## CI report:
* f034b22420e2670b326949b657a61ac5a0dc7185 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481844415
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharingPhysicalSlotRequestBulk.java
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481855755
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java
##
@@ -161,158 +173,66 @@ private
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189057#comment-17189057
]
Till Rohrmann commented on FLINK-18959:
---
I think we can record whether
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481882451
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkCheckerImpl.java
##
@@ -0,0 +1,187 @@
+/*
dianfu closed pull request #13278:
URL: https://github.com/apache/flink/pull/13278
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-19114.
---
Resolution: Fixed
master: a6458f465a9ce422cfd6fc8cf25fe5e51f65ab47
> Introduce Expression class in the
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* bbb019bf30fa08b0055755a4eba7c918683b5aab Azure:
echauchot commented on a change in pull request #13040:
URL: https://github.com/apache/flink/pull/13040#discussion_r481932290
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java
##
@@ -0,0 +1,86 @@
+package
[
https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189138#comment-17189138
]
Yun Tang commented on FLINK-18712:
--
I use [k8s session
[
https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189137#comment-17189137
]
Nico Kruber commented on FLINK-19112:
-
A mock MetricGroup has the disadvantage that the user doesn't
flinkbot edited a comment on pull request #13303:
URL: https://github.com/apache/flink/pull/13303#issuecomment-685551684
## CI report:
* 167e59c5fc3ee18bdc6ecd8175f914e379191816 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-19093.
Resolution: Fixed
Merged in master: 76f37551ad51f7eae9688495130a39b0f202c3bf
> "Elasticsearch (v6.3.1)
flinkbot edited a comment on pull request #13303:
URL: https://github.com/apache/flink/pull/13303#issuecomment-685551684
## CI report:
* 167e59c5fc3ee18bdc6ecd8175f914e379191816 Azure:
flinkbot edited a comment on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836
## CI report:
* 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN
* 8dec9d771581a278dc822712712cac0b08d31b3c Azure:
flinkbot commented on pull request #13305:
URL: https://github.com/apache/flink/pull/13305#issuecomment-685640244
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* b58ab30b48a7405840656ebc26ce55fad7473497 Azure:
wangxiyuan commented on a change in pull request #32:
URL: https://github.com/apache/flink-docker/pull/32#discussion_r481820243
##
File path: generator.sh
##
@@ -0,0 +1,80 @@
+#!/bin/bash -e
+
+# Defaults, can vary between versions
+export SOURCE_VARIANTS=(java11-debian debian
tillrohrmann commented on a change in pull request #13227:
URL: https://github.com/apache/flink/pull/13227#discussion_r481852784
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java
##
@@ -91,37 +91,21 @@ public MiniDispatcher(
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Jiang updated FLINK-19064:
---
Comment: was deleted
(was: [~rmetzger], I got your point of understanding. In InputFormat
dianfu opened a new pull request #13304:
URL: https://github.com/apache/flink/pull/13304
## What is the purpose of the change
*This pull request support Expression in the operations of Python Table API*
## Brief change log
- *Update the operations in Table to
rkhachatryan opened a new pull request #13305:
URL: https://github.com/apache/flink/pull/13305
## What is the purpose of the change
Currently, `MailboxExecutor.isIdle` checks whether the mailbox loop is
running or not.
If not, `ContinuousFileReaderOperator` continues file
WeiZhong94 opened a new pull request #13302:
URL: https://github.com/apache/flink/pull/13302
## What is the purpose of the change
*This pull request flattens the current PyFlink documentation structure.*
## Brief change log
- *Flatten current PyFlink documentation
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189042#comment-17189042
]
Jark Wu commented on FLINK-16528:
-
Hi [~danny0405], they do not conflict. It is valid to submit a query
klion26 commented on pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-685414778
@carp84 thanks for the notice. will review this late today.
This is an automated message from the Apache
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* d9df78ad79b83d10cefa5c9ef8b893737c3fd88c Azure:
flinkbot edited a comment on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-680688340
## CI report:
* 4a0370f30701c680892ec0f934878b18142c742f Azure:
flinkbot edited a comment on pull request #13301:
URL: https://github.com/apache/flink/pull/13301#issuecomment-685356952
## CI report:
* a5a665a041c0a6c2c017289463e5122f2c8f6282 Azure:
flinkbot edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* 44b87544d58616f56eeb8105764a37011c07ea9d Azure:
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* 67048f0564671bfb89f9f1d88a3a717502a9cda8 Azure:
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481295508
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharingPhysicalSlotRequestBulk.java
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed
flinkbot commented on pull request #13303:
URL: https://github.com/apache/flink/pull/13303#issuecomment-685543479
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189012#comment-17189012
]
McClone commented on FLINK-19115:
-
CREATE TEMPORARY FUNCTION UdfPrimaryKey as
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Summary: Avoid accessing HDFS in HiveBulkWriterFactory (was: Avoid access
HDFS in
flinkbot commented on pull request #13301:
URL: https://github.com/apache/flink/pull/13301#issuecomment-685329829
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19121:
---
Labels: pull-request-available (was: )
> Avoid accessing HDFS frequently in
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189016#comment-17189016
]
Danny Chen commented on FLINK-16528:
What is the semantics that for an unbounded stream to have a
[
https://issues.apache.org/jira/browse/FLINK-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19079:
---
Component/s: Table SQL / Runtime
> Support row time deduplicate operator
>
[
https://issues.apache.org/jira/browse/FLINK-19078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19078:
---
Component/s: Table SQL / Runtime
> Import rowtime join temporal operator
>
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-19121:
Assignee: Jingsong Lee
> Avoid accessing HDFS frequently in HiveBulkWriterFactory
>
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Summary: Avoid accessing HDFS frequently in HiveBulkWriterFactory (was:
Avoid accessing HDFS
JingsongLi opened a new pull request #13301:
URL: https://github.com/apache/flink/pull/13301
## What is the purpose of the change
In HadoopPathBasedBulkWriter, getSize will invoke `FileSystem.exists` and
`FileSystem.getFileStatus`, but it is invoked per record.
There will be
1 - 100 of 358 matches
Mail list logo
