DeFOX created FLINK-18535:
-
Summary: Elasticsearch connector hangs for threads deadlocked
Key: FLINK-18535
URL: https://issues.apache.org/jira/browse/FLINK-18535
Project: Flink
Issue Type: Bug
dianfu commented on a change in pull request #12841:
URL: https://github.com/apache/flink/pull/12841#discussion_r451938393
##
File path:
flink-python/src/main/java/org/apache/flink/python/env/ProcessEnvironment.java
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software F
klion26 commented on a change in pull request #12420:
URL: https://github.com/apache/flink/pull/12420#discussion_r451970665
##
File path: docs/dev/table/streaming/joins.zh.md
##
@@ -300,25 +285,26 @@ FROM
ON r.currency = o.currency
{% endhighlight %}
-Each record from the
klion26 commented on pull request #12798:
URL: https://github.com/apache/flink/pull/12798#issuecomment-655904944
@RocMarshal thanks for the quick fix, as the change is too big, I'll give
response asap.
This is an automated m
flinkbot edited a comment on pull request #12856:
URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024
## CI report:
* fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12858:
URL: https://github.com/apache/flink/pull/12858#issuecomment-655892754
## CI report:
* f0b3ee3b40e8f357d0e02f35e2486865648eda3c Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #12858:
URL: https://github.com/apache/flink/pull/12858#issuecomment-655892754
## CI report:
* f0b3ee3b40e8f357d0e02f35e2486865648eda3c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #12856:
URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024
## CI report:
* fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wuchong commented on a change in pull request #12756:
URL: https://github.com/apache/flink/pull/12756#discussion_r451954436
##
File path:
flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java
##
@@ -502,9 +516,17 @@ private void t
wuchong commented on pull request #12756:
URL: https://github.com/apache/flink/pull/12756#issuecomment-655888642
Others looks good to me. Could you please fix the `thrown` problem?
This is an automated message from the Apache
wuchong commented on a change in pull request #12805:
URL: https://github.com/apache/flink/pull/12805#discussion_r451951070
##
File path: docs/dev/table/connectors/kafka.md
##
@@ -207,6 +214,19 @@ However, it will cause a lot of network connections
between all the Flink instan
wuchong commented on a change in pull request #12805:
URL: https://github.com/apache/flink/pull/12805#discussion_r451950734
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java
##
@@ -222,8
flinkbot commented on pull request #12858:
URL: https://github.com/apache/flink/pull/12858#issuecomment-655884468
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 pro
[
https://issues.apache.org/jira/browse/FLINK-18534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18534:
---
Labels: pull-request-available test-stability (was: test-stability)
> KafkaTableITCase.test
wuchong opened a new pull request #12858:
URL: https://github.com/apache/flink/pull/12858
## What is the purpose of the change
This fix the unstable test with "Topic 'changelog_topic' already exists"
exception.
## Brief change log
Currently `testKafkaDeb
wuchong commented on pull request #12858:
URL: https://github.com/apache/flink/pull/12858#issuecomment-655884001
Could you help to review this @leonardBang ?
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/FLINK-18534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-18534:
---
Assignee: Jark Wu
> KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic
> 'change
godfreyhe commented on pull request #12851:
URL: https://github.com/apache/flink/pull/12851#issuecomment-655857964
@liuyongvs @wuchong I will review this today
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/FLINK-18533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154137#comment-17154137
]
Dian Fu commented on FLINK-18533:
-
Another instance:
https://dev.azure.com/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-18534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18534:
Labels: test-stability (was: )
> KafkaTableITCase.testKafkaDebeziumChangelogSource failed with "Topic
>
Dian Fu created FLINK-18534:
---
Summary: KafkaTableITCase.testKafkaDebeziumChangelogSource failed
with "Topic 'changelog_topic' already exists"
Key: FLINK-18534
URL: https://issues.apache.org/jira/browse/FLINK-18534
wuchong commented on pull request #12851:
URL: https://github.com/apache/flink/pull/12851#issuecomment-655853748
Hi @godfreyhe , do you have time to review this?
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-18533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18533:
Labels: test-stability (was: )
> AccumulatorLiveITCase.testStreaming hangs
>
Dian Fu created FLINK-18533:
---
Summary: AccumulatorLiveITCase.testStreaming hangs
Key: FLINK-18533
URL: https://issues.apache.org/jira/browse/FLINK-18533
Project: Flink
Issue Type: Test
Co
[
https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangyunyun resolved FLINK-18525.
-
Resolution: Done
> Running yarn-session.sh occurs error
>
>
[
https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154124#comment-17154124
]
zhangyunyun commented on FLINK-18525:
-
It resolved! Thank [~fly_in_gis]
> Running
[
https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154121#comment-17154121
]
zhangyunyun commented on FLINK-18525:
-
I configured \{{fs.default-scheme}} to a hdfs
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154117#comment-17154117
]
Dian Fu edited comment on FLINK-16795 at 7/9/20, 1:51 AM:
--
[htt
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154117#comment-17154117
]
Dian Fu edited comment on FLINK-16795 at 7/9/20, 1:51 AM:
--
[htt
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154117#comment-17154117
]
Dian Fu commented on FLINK-16795:
-
[https://dev.azure.com/apache-flink/apache-flink/_bui
[
https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154115#comment-17154115
]
Dian Fu commented on FLINK-16768:
-
[https://dev.azure.com/apache-flink/apache-flink/_bui
liuyongvs commented on pull request #12851:
URL: https://github.com/apache/flink/pull/12851#issuecomment-655842803
hi @wuchong , azure passed, could you speed some of time reviewing this PR?
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-18525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154111#comment-17154111
]
Yang Wang commented on FLINK-18525:
---
It is strange that the
{{YarnApplicationFileUplo
miaogr86 commented on pull request #12848:
URL: https://github.com/apache/flink/pull/12848#issuecomment-655831527
@haijohn thx
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-18498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154015#comment-17154015
]
Seth Wiesman commented on FLINK-18498:
--
Fixed in master: a18385d7202f39cd3eb5e4ae7c
[
https://issues.apache.org/jira/browse/FLINK-18498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman resolved FLINK-18498.
--
Resolution: Fixed
> Update Flink Playgrounds to 1.11
>
>
>
sjwiesman closed pull request #15:
URL: https://github.com/apache/flink-playgrounds/pull/15
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 t
[
https://issues.apache.org/jira/browse/FLINK-18510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18510:
-
Priority: Major (was: Blocker)
> Job Listener Interface failed
> -
[
https://issues.apache.org/jira/browse/FLINK-18510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-18510.
Resolution: Duplicate
> Job Listener Interface failed
> --
>
[
https://issues.apache.org/jira/browse/FLINK-18097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153865#comment-17153865
]
Chesnay Schepler edited comment on FLINK-18097 at 7/8/20, 7:11 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-18097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153865#comment-17153865
]
Chesnay Schepler edited comment on FLINK-18097 at 7/8/20, 7:11 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-18097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-18097.
Fix Version/s: 1.11.1
1.12.0
1.10.2
Resolution
[
https://issues.apache.org/jira/browse/FLINK-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-16463:
-
Issue Type: Bug (was: Wish)
> CodeGenUtils generates code that has two semicolons for
flinkbot edited a comment on pull request #12857:
URL: https://github.com/apache/flink/pull/12857#issuecomment-655543169
## CI report:
* d52c63e8e43456629c23a571eefcb60bd26a11be Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-15617:
-
Issue Type: Improvement (was: Wish)
> Remove useless JobRetrievalException
> --
[
https://issues.apache.org/jira/browse/FLINK-15601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-15601:
-
Issue Type: Improvement (was: Wish)
> Remove useless constant field NUM_STOP_CALL_TRIES
[
https://issues.apache.org/jira/browse/FLINK-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-15558:
-
Issue Type: Improvement (was: Wish)
> Bump Elasticsearch version from 7.3.2 to 7.5.1 fo
[
https://issues.apache.org/jira/browse/FLINK-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-14351:
-
Fix Version/s: (was: 1.11.0)
1.12.0
> Refactor MetricRegistry del
[
https://issues.apache.org/jira/browse/FLINK-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-12336:
-
Fix Version/s: (was: 1.11.0)
1.12.0
> Add HTTPS support to Influx
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153821#comment-17153821
]
Dawid Wysakowicz edited comment on FLINK-16795 at 7/8/20, 6:03 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reopened FLINK-16795:
--
> End to end tests timeout on Azure
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-16795:
-
Affects Version/s: 1.12.0
> End to end tests timeout on Azure
>
[
https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153821#comment-17153821
]
Dawid Wysakowicz commented on FLINK-16795:
--
New instances:
https://dev.azure.co
[
https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153813#comment-17153813
]
Thomas Weise commented on FLINK-16510:
--
We are not able to reliably run our applica
flinkbot edited a comment on pull request #12856:
URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024
## CI report:
* fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Seth Wiesman created FLINK-18532:
Summary: Remove Beta tag from MATCH_RECOGNIZE docs
Key: FLINK-18532
URL: https://issues.apache.org/jira/browse/FLINK-18532
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-18531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18531:
-
Component/s: Runtime / REST
Runtime / Configuration
> Minicluster optio
[
https://issues.apache.org/jira/browse/FLINK-18531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-18531.
Resolution: Won't Fix
This is not possible.
If you want the port to remain stable, you wi
flinkbot edited a comment on pull request #12851:
URL: https://github.com/apache/flink/pull/12851#issuecomment-655384097
## CI report:
* 7a1f2dd7590a3b1816e619db2c80d543cbdcf7d2 UNKNOWN
* b79337059dea45b43d88cf3e4b07309dcd711d2b Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-18531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18531:
-
Issue Type: Wish (was: Test)
> Minicluster option to reuse same port if 0 is applied
>
David Chen created FLINK-18531:
--
Summary: Minicluster option to reuse same port if 0 is applied
Key: FLINK-18531
URL: https://issues.apache.org/jira/browse/FLINK-18531
Project: Flink
Issue Type:
flinkbot edited a comment on pull request #12846:
URL: https://github.com/apache/flink/pull/12846#issuecomment-654978676
## CI report:
* 5b3a4da61a337a80a70a5125ed135d3095def41e Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12852:
URL: https://github.com/apache/flink/pull/12852#issuecomment-655468923
## CI report:
* 5b8d05081345063348bad6375c2567a0ebf59bed Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153698#comment-17153698
]
Benchao Li commented on FLINK-18520:
[~twalthr] Thanks for your quick fix, I've revi
libenchao commented on a change in pull request #12857:
URL: https://github.com/apache/flink/pull/12857#discussion_r451634594
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/FunctionCatalogOperatorTable.java
##
@@ -208,1
flinkbot edited a comment on pull request #12420:
URL: https://github.com/apache/flink/pull/12420#issuecomment-636504607
## CI report:
* d0f0b15cc5289803cdbde65b26bc66f0542da5f1 UNKNOWN
* bc4b8b49834d751271c7f0976f62f91923217420 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-18499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18499:
---
Labels: pull-request-available (was: )
> Update Flink Exercises to 1.11
> -
alpinegizmo opened a new pull request #12:
URL: https://github.com/apache/flink-training/pull/12
Clean-up the keyBys for Flink 1.11.
This is an automated message from the Apache Git Service.
To respond to the message, please
sjwiesman closed pull request #14:
URL: https://github.com/apache/flink-playgrounds/pull/14
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 t
sjwiesman commented on pull request #14:
URL: https://github.com/apache/flink-playgrounds/pull/14#issuecomment-655590061
Thank you
This is an automated message from the Apache Git Service.
To respond to the message, please l
flinkbot edited a comment on pull request #12856:
URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024
## CI report:
* fc30e2ca58b435e43e6b569f0c21347667c28c8f Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12857:
URL: https://github.com/apache/flink/pull/12857#issuecomment-655543169
## CI report:
* d52c63e8e43456629c23a571eefcb60bd26a11be Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12420:
URL: https://github.com/apache/flink/pull/12420#issuecomment-636504607
## CI report:
* d0f0b15cc5289803cdbde65b26bc66f0542da5f1 UNKNOWN
* 4dbc7b88a9fdf589c0c339378576cdda755fd77c Azure:
[FAILURE](https://dev.azure.com/apache-fl
zentol closed pull request #12844:
URL: https://github.com/apache/flink/pull/12844
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 t
authuir commented on a change in pull request #12420:
URL: https://github.com/apache/flink/pull/12420#discussion_r451581064
##
File path: docs/dev/table/streaming/joins.zh.md
##
@@ -22,37 +22,38 @@ specific language governing permissions and limitations
under the License.
-->
flinkbot edited a comment on pull request #12853:
URL: https://github.com/apache/flink/pull/12853#issuecomment-655469013
## CI report:
* dac055b0d95b136897bd699014290322c4dc22ce Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #12857:
URL: https://github.com/apache/flink/pull/12857#issuecomment-655543169
## CI report:
* d52c63e8e43456629c23a571eefcb60bd26a11be UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #12856:
URL: https://github.com/apache/flink/pull/12856#issuecomment-655543024
## CI report:
* fc30e2ca58b435e43e6b569f0c21347667c28c8f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #12853:
URL: https://github.com/apache/flink/pull/12853#issuecomment-655469013
## CI report:
* dac055b0d95b136897bd699014290322c4dc22ce Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153617#comment-17153617
]
Timo Walther commented on FLINK-18520:
--
I opened a PR for this problem. [~libenchao
flinkbot commented on pull request #12857:
URL: https://github.com/apache/flink/pull/12857#issuecomment-655528313
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 pro
flinkbot commented on pull request #12856:
URL: https://github.com/apache/flink/pull/12856#issuecomment-655527283
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 pro
[
https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18520:
---
Labels: pull-request-available (was: )
> New Table Function type inference fails
>
[
https://issues.apache.org/jira/browse/FLINK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18529:
---
Labels: pull-request-available (was: )
> Query Hive table and filter by timestamp partition
twalthr opened a new pull request #12857:
URL: https://github.com/apache/flink/pull/12857
## What is the purpose of the change
Improves the validation logic for scalar/table function usage. It made
catalog functions unresolvable before.
## Brief change log
Remove checki
lirui-apache opened a new pull request #12856:
URL: https://github.com/apache/flink/pull/12856
…n can fail
## What is the purpose of the change
Fix the issue that querying a Hive table and filter by timestamp partition
column can fail.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153572#comment-17153572
]
Roc Marshal edited comment on FLINK-18502 at 7/8/20, 1:27 PM:
flinkbot edited a comment on pull request #12855:
URL: https://github.com/apache/flink/pull/12855#issuecomment-655500427
## CI report:
* cbd3259908d23c419e97595704e59af2ce970cab Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12854:
URL: https://github.com/apache/flink/pull/12854#issuecomment-655500315
## CI report:
* a343769ca9bec4a73587c55daa0e265f8a3a6ce6 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #12798:
URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680
## CI report:
* ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN
* f1fb24d628f66f3f2929fe4e737a835e8391c0a8 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153605#comment-17153605
]
Roc Marshal commented on FLINK-18502:
-
[~jark]
OK. There's nothing better!
> Add
twalthr commented on pull request #12853:
URL: https://github.com/apache/flink/pull/12853#issuecomment-655515610
Thanks @aljoscha. I will merge this once the build is green.
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/FLINK-18530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
humengyu updated FLINK-18530:
-
Description:
I read data from kafka and write to hdfs by StreamingFileSink:
# in version 1.11.0, Parque
[
https://issues.apache.org/jira/browse/FLINK-18530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
humengyu updated FLINK-18530:
-
Description:
I read data from kafka and write to hdfs by StreamingFileSink:
# in version 1.11.0, Parque
[
https://issues.apache.org/jira/browse/FLINK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-18529:
---
Description:
The following example
{code}
create table foo (x int) partitioned by (ts timestamp);
select x f
humengyu created FLINK-18530:
Summary: ParquetAvroWriters can not write data to hdfs
Key: FLINK-18530
URL: https://issues.apache.org/jira/browse/FLINK-18530
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153589#comment-17153589
]
Jark Wu edited comment on FLINK-18502 at 7/8/20, 1:11 PM:
--
It's
[
https://issues.apache.org/jira/browse/FLINK-18502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153589#comment-17153589
]
Jark Wu commented on FLINK-18502:
-
It's fine to fix them in the single PR.
> Add the p
RocMarshal commented on pull request #12798:
URL: https://github.com/apache/flink/pull/12798#issuecomment-655508679
@klion26
Thank you so much for your efforts in the `review` of this PR whose workload
is havey !
It's very significant for the translation of this page. And I mad
[
https://issues.apache.org/jira/browse/FLINK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-18529:
---
Summary: Query Hive table and filter by timestamp partition can fail (was:
Query Hive table and filter by t
1 - 100 of 239 matches
Mail list logo
