[
https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-18840.
Resolution: Fixed
Fixed in 1.14.0: 7ff4cbdc25aa971dccaf5ce02aaf46dc1e7345cc
> Add StreamStatement
tillrohrmann closed pull request #16487:
URL: https://github.com/apache/flink/pull/16487
--
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 the specific comment.
To unsubscribe, e-mail: issues-un
tillrohrmann commented on pull request #16487:
URL: https://github.com/apache/flink/pull/16487#issuecomment-899270935
Merged as part of #16484.
--
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 th
wuchong commented on a change in pull request #16723:
URL: https://github.com/apache/flink/pull/16723#discussion_r689235882
##
File path: flink-table/flink-sql-client/src/test/resources/sql/table.q
##
@@ -89,6 +89,193 @@ CREATE TABLE `default_catalog`.`default_database`.`orders
Yun Tang created FLINK-23798:
Summary: Avoid using reflection to get filter when partition
filter is enabled
Key: FLINK-23798
URL: https://issues.apache.org/jira/browse/FLINK-23798
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-23798:
Assignee: PengFei Li
> Avoid using reflection to get filter when partition filter is enabled
> --
zhuzhurk commented on a change in pull request #16724:
URL: https://github.com/apache/flink/pull/16724#discussion_r689286726
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/RestartStrategyOptions.java
##
@@ -63,21 +63,21 @@
dmvk commented on pull request #16807:
URL: https://github.com/apache/flink/pull/16807#issuecomment-899275917
@nicoweidner Thanks for the review! I've addressed your comments, PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot edited a comment on pull request #15237:
URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686
## CI report:
* 883ee4a01230289c733482d4d6e3c7795c119dfb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zhou created FLINK-23799:
Summary: application mode not support pyflink
Key: FLINK-23799
URL: https://issues.apache.org/jira/browse/FLINK-23799
Project: Flink
Issue Type: Improvement
Affects Vers
[
https://issues.apache.org/jira/browse/FLINK-23799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhou updated FLINK-23799:
-
Summary: application mode not support pyflink on yarn (was: application
mode not support pyflink)
> applicatio
flinkbot edited a comment on pull request #16784:
URL: https://github.com/apache/flink/pull/16784#issuecomment-896788454
## CI report:
* 04900c4ecb5bbe923198c7985dd07c0ae7832f40 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16809:
URL: https://github.com/apache/flink/pull/16809#issuecomment-898349192
## CI report:
* 63027684964545d78ff78d25ffbfbfb94f03a5f8 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16822:
URL: https://github.com/apache/flink/pull/16822#issuecomment-898859883
## CI report:
* 3049e0b3134673e9245bd5d27e9dbeb8a641baf0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #16833:
URL: https://github.com/apache/flink/pull/16833#issuecomment-899284371
## CI report:
* b2b1a7d4158a69c9f92ac69799ce9296a8fc49e6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #16835:
URL: https://github.com/apache/flink/pull/16835#issuecomment-899222388
## CI report:
* cb9bab9b91b5aec13f5c4e3174cf5bde201ea88a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
tillrohrmann commented on a change in pull request #16832:
URL: https://github.com/apache/flink/pull/16832#discussion_r689289403
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/InMemoryReporter.java
##
@@ -131,12 +140,12 @@ void applyRemovals() {
twalthr commented on a change in pull request #16776:
URL: https://github.com/apache/flink/pull/16776#discussion_r689296295
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java
##
@@ -1504,6 +1506,23 @@
[
https://issues.apache.org/jira/browse/FLINK-23601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23601:
-
Fix Version/s: 1.14.0
> TPC-DS end-to-end test fail with "File upload failed."
> ---
[
https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23647:
-
Fix Version/s: 1.14.0
> UnalignedCheckpointStressITCase crashed on azure
> -
[
https://issues.apache.org/jira/browse/FLINK-23530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23530:
-
Fix Version/s: 1.14.0
> JoinITCase.testJoinOnCustomTypeInputWithKeyExtractorAndTupleInputWithKey
[
https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23525:
-
Fix Version/s: 1.14.0
> Docker command fails on Azure: Exit code 137 returned from process: file
[
https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23466:
-
Fix Version/s: 1.14.0
> UnalignedCheckpointITCase hangs on Azure
> -
[
https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23409:
-
Fix Version/s: 1.14.0
> CrossITCase fails with "NoResourceAvailableException: Slot request bulk
[
https://issues.apache.org/jira/browse/FLINK-23431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23431:
-
Fix Version/s: 1.14.0
> KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The
[
https://issues.apache.org/jira/browse/FLINK-23105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23105:
-
Fix Version/s: 1.14.0
> YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManage
[
https://issues.apache.org/jira/browse/FLINK-23799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-23799.
---
Resolution: Duplicate
[~zhou_yb] I'm closing it as it's duplicate with FLINK-22871.
BTW: There is already
[
https://issues.apache.org/jira/browse/FLINK-23387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23387:
-
Fix Version/s: 1.14.0
> WindowRankITCase.testEventTimeTumbleWindowWithoutRankNumber fails on azu
[
https://issues.apache.org/jira/browse/FLINK-23323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23323:
-
Fix Version/s: 1.14.0
> HAQueryableStateRocksDBBackendITCase failed due to heap OOM
> --
[
https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23240:
-
Fix Version/s: 1.14.0
> ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRec
[
https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-14482:
--
Labels: pull-request-available (was: auto-deprioritized-major
auto-unassigned pull-request-available)
P
[
https://issues.apache.org/jira/browse/FLINK-22842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22842:
-
Fix Version/s: 1.14.0
> Streaming File Sink end-to-end test fail due to not finish after 900s
>
[
https://issues.apache.org/jira/browse/FLINK-23097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23097:
-
Fix Version/s: 1.14.0
> 'Queryable state (rocksdb) with TM restart end-to-end test' fails on azu
[
https://issues.apache.org/jira/browse/FLINK-22892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22892:
-
Fix Version/s: 1.14.0
> Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to
[
https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-23047:
-
Fix Version/s: 1.14.0
> CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure
>
[
https://issues.apache.org/jira/browse/FLINK-23788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399565#comment-17399565
]
Xi commented on FLINK-23788:
By adding function 'normalize' :
{code}
98 normalize() {
99
fapaul commented on a change in pull request #16817:
URL: https://github.com/apache/flink/pull/16817#discussion_r689302172
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/eventtime/CombinedWatermarkStatus.java
##
@@ -69,7 +69,6 @@ public boolean updateCombin
[
https://issues.apache.org/jira/browse/FLINK-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399570#comment-17399570
]
Yu Li commented on FLINK-13652:
---
[~autophagy] [~chesnay] This seems to be the only sub-tas
zentol merged pull request #16750:
URL: https://github.com/apache/flink/pull/16750
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-23627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-23627.
Resolution: Fixed
master: cb273e5c1201b0177c78dc036987349e872dd4ed
> Migrate all Operator
[
https://issues.apache.org/jira/browse/FLINK-23627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-23627:
Assignee: Shen Zhu
> Migrate all OperatorMG instantiations to factory method
> --
flinkbot edited a comment on pull request #14395:
URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218
## CI report:
* 416c2011bc57e4a94cf46df69f6a31d424393b3c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zentol merged pull request #16747:
URL: https://github.com/apache/flink/pull/16747
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-23625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-23625.
Resolution: Fixed
master: 778fc421e324e15738df9e551b10285ad4f5ae93
> Migrate all TaskMana
[
https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-13973:
Affects Version/s: 1.13.0
> Checkpoint recovery failed after user set uidHash
> --
flinkbot edited a comment on pull request #15237:
URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686
## CI report:
* 61291e34604181a379a8d6ee1b9cb2f078c27035 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Airblader commented on a change in pull request #16776:
URL: https://github.com/apache/flink/pull/16776#discussion_r689306548
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java
##
@@ -1504,6 +1506,23 @@
[
https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-13973:
---
Assignee: Yun Gao
> Checkpoint recovery failed after user set uidHash
> ---
[
https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-13973:
Labels: (was: auto-deprioritized-major)
> Checkpoint recovery failed after user set uidHash
> --
[
https://issues.apache.org/jira/browse/FLINK-22775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22775:
-
Fix Version/s: 1.14.0
> CassandraConnectorITCase.testCassandraTableSink Fail
> -
[
https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-13973:
Fix Version/s: 1.14.0
> Checkpoint recovery failed after user set uidHash
> --
twalthr commented on a change in pull request #16788:
URL: https://github.com/apache/flink/pull/16788#discussion_r689301705
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/PlannerFactory.java
##
@@ -34,25 +34,82 @@
* properties
[
https://issues.apache.org/jira/browse/FLINK-22755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22755:
-
Fix Version/s: 1.14.0
> SequenceStreamingFileSinkITCase.testWriteSequenceFile fail
> ---
[
https://issues.apache.org/jira/browse/FLINK-22567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22567:
-
Fix Version/s: 1.14.0
> OrcFsStreamingSinkITCase crashes JVM
> -
[
https://issues.apache.org/jira/browse/FLINK-22520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22520:
-
Fix Version/s: 1.14.0
> KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs
>
[
https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22342:
-
Fix Version/s: 1.14.0
> FlinkKafkaProducerITCase fails with producer leak
>
[
https://issues.apache.org/jira/browse/FLINK-22710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22710:
-
Fix Version/s: 1.14.0
> ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed
> ---
[
https://issues.apache.org/jira/browse/FLINK-22571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22571:
-
Fix Version/s: 1.14.0
> SavepointITCase.testSavepointForJobWithIteration fails with Timeout
> --
[
https://issues.apache.org/jira/browse/FLINK-22738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22738:
-
Fix Version/s: 1.14.0
> org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output
[
https://issues.apache.org/jira/browse/FLINK-22558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22558:
-
Fix Version/s: 1.14.0
> testcontainers fail to start ResourceReaper
> --
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-21214:
-
Fix Version/s: 1.14.0
> FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed
> ---
[
https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20420:
-
Fix Version/s: 1.14.0
> ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds
> --
[
https://issues.apache.org/jira/browse/FLINK-20523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20523:
-
Fix Version/s: 1.14.0
> OffsetsInitializerTest test failed with "java.net.BindException: Address
[
https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20928:
-
Fix Version/s: 1.14.0
> KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUnti
[
https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-17987:
-
Fix Version/s: 1.14.0
> KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error
[
https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-17274:
-
Fix Version/s: 1.14.0
> Maven: Premature end of Content-Length delimited message body
>
[
https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20461:
-
Fix Version/s: 1.14.0
> YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication
> ---
flinkbot edited a comment on pull request #16513:
URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601
## CI report:
* 8fc237007d1fd4a9150671741d49b3f048726e65 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399576#comment-17399576
]
Chesnay Schepler commented on FLINK-13652:
--
No one has really kept an eye on AR
flinkbot edited a comment on pull request #16732:
URL: https://github.com/apache/flink/pull/16732#issuecomment-893984711
## CI report:
* af08c1af7cdba855f3f68413565bd03e7c6dfa9a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894632163
## CI report:
* ec30ee61c2adc94b71eede27342a6e4a42a23e56 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-23786:
-
Component/s: Runtime / Configuration
Connectors / Hadoop Compatibility
> Avoid multiple
flinkbot edited a comment on pull request #16778:
URL: https://github.com/apache/flink/pull/16778#issuecomment-896639363
## CI report:
* 52f2594db37bf9b4c80b549273505a7ab3b25296 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16784:
URL: https://github.com/apache/flink/pull/16784#issuecomment-896788454
## CI report:
* 04900c4ecb5bbe923198c7985dd07c0ae7832f40 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16807:
URL: https://github.com/apache/flink/pull/16807#issuecomment-898327352
## CI report:
* 161a8355344db790c99236586fa243d7ea41bb1f Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16822:
URL: https://github.com/apache/flink/pull/16822#issuecomment-898859883
## CI report:
* 16b66372e210190f50f49fdb7885a04a3840e17c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16833:
URL: https://github.com/apache/flink/pull/16833#issuecomment-899284371
## CI report:
* b2b1a7d4158a69c9f92ac69799ce9296a8fc49e6 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
mans2singh commented on pull request #16763:
URL: https://github.com/apache/flink/pull/16763#issuecomment-899298184
@wuchong - Can you please review this PR and let me know your
recommendations ? Thanks
--
This is an automated message from the Apache Git Service.
To respond to the messa
[
https://issues.apache.org/jira/browse/FLINK-23771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399578#comment-17399578
]
Yun Gao commented on FLINK-23771:
-
Fixed on 1.14 via fc0d35b0852e3ebbc43b6f6c82d2adba71d
[
https://issues.apache.org/jira/browse/FLINK-23771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-23771.
---
Assignee: Yun Gao
Resolution: Fixed
> FLIP-147 Checkpoint N has not been started at all
>
Tartarus0zm commented on pull request #16778:
URL: https://github.com/apache/flink/pull/16778#issuecomment-899299888
@flinkbot run azure
--
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 the speci
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22457:
-
Fix Version/s: 1.14.0
> KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of
[
https://issues.apache.org/jira/browse/FLINK-22572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22572:
-
Fix Version/s: 1.14.0
> JsonFsStreamSinkITCase.testPart fails running in a timeout
> ---
[
https://issues.apache.org/jira/browse/FLINK-23770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399580#comment-17399580
]
Yun Gao commented on FLINK-23770:
-
I tested that the current implementation indeed has p
Yun Tang created FLINK-23800:
Summary: Expose newly added RocksDB native metrics
Key: FLINK-23800
URL: https://issues.apache.org/jira/browse/FLINK-23800
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399582#comment-17399582
]
Stephan Ewen commented on FLINK-22545:
--
Thanks for reporting the logs, I am taking
dianfu commented on pull request #15813:
URL: https://github.com/apache/flink/pull/15813#issuecomment-899303855
@YikSanChan Thanks a lot~
--
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 the spec
[
https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399584#comment-17399584
]
Xintong Song commented on FLINK-22387:
--
cc [~jark] [~Leonard Xu] [~fsk119]
Could an
carp84 commented on a change in pull request #16834:
URL: https://github.com/apache/flink/pull/16834#discussion_r689308142
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateOptionTest.java
##
@@ -52
Qingsheng Ren created FLINK-23801:
-
Summary: Add FLIP-33 metrics to KafkaSource
Key: FLINK-23801
URL: https://issues.apache.org/jira/browse/FLINK-23801
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-23710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-23710:
---
Assignee: Fabian Paul
> Move sink to org.apache.kafka.conntor.kafka.sink package
>
Danny Cranmer created FLINK-23802:
-
Summary: [kinesis][efo] Reduce ReadTimeoutExceptions for Kinesis
Consumer
Key: FLINK-23802
URL: https://issues.apache.org/jira/browse/FLINK-23802
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399591#comment-17399591
]
Roman Khachatryan commented on FLINK-23770:
---
Thanks for the analysis [~gaoyunh
gaoyunhaii opened a new pull request #16836:
URL: https://github.com/apache/flink/pull/16836
## What is the purpose of the change
This PR fixes the issue if the uidHash is set, then with the checkpoints
taking after restarted, the state assignment process would fail to retrieve the
[
https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13973:
---
Labels: pull-request-available (was: )
> Checkpoint recovery failed after user set uidHash
PatrickRen commented on a change in pull request #16809:
URL: https://github.com/apache/flink/pull/16809#discussion_r689324265
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java
##
@@ -13
gaborgsomogyi commented on pull request #16824:
URL: https://github.com/apache/flink/pull/16824#issuecomment-899312441
I've had a look at the change and not sure why is it needed?
The user has 2 options to provide credentials:
* provide TGT w/ `kinit`
* provide keytab
The cha
fapaul opened a new pull request #16837:
URL: https://github.com/apache/flink/pull/16837
## What is the purpose of the change
This PR relocates the FLIP-143 KafkaSink to the same parent package as the
FLIP-27 KafkaSource. In addition, it also deprecates the FlinkKafkaProucer
[
https://issues.apache.org/jira/browse/FLINK-23786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23786:
---
Labels: pull-request-available (was: )
> Avoid multiple authentication
> --
[
https://issues.apache.org/jira/browse/FLINK-23710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23710:
---
Labels: pull-request-available (was: )
> Move sink to org.apache.kafka.conntor.kafka.sink p
1 - 100 of 715 matches
Mail list logo
