lsyldliu commented on code in PR #20855:
URL: https://github.com/apache/flink/pull/20855#discussion_r991797046
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserUtils.java:
##
@@ -1689,4 +1694,61 @@ public static bool
[
https://issues.apache.org/jira/browse/FLINK-29446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-29446.
Fix Version/s: 1.17.0
Assignee: Sergey Nuyanzin
Resolution: Fixed
Fixed in master:
twalthr closed pull request #20909: [FLINK-29446][Table SQL/API] Remove
Calcite classes since they were fixed in 1.24
URL: https://github.com/apache/flink/pull/20909
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
zoucao commented on PR #19250:
URL: https://github.com/apache/flink/pull/19250#issuecomment-1274149231
>
Sure, I will rebase the master and fix it as soon as possible.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
luoyuxia commented on code in PR #19250:
URL: https://github.com/apache/flink/pull/19250#discussion_r991856228
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/ContinuousHiveSplitEnumeratorTest.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-29126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615497#comment-17615497
]
godfrey he commented on FLINK-29126:
Fixed in master: cf70844a56a0994dfcd7fb18594086
mas-chen commented on code in PR #20343:
URL: https://github.com/apache/flink/pull/20343#discussion_r991847890
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriterTest.java:
##
@@ -141,6 +142,73 @@ public
[
https://issues.apache.org/jira/browse/FLINK-29126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-29126:
--
Assignee: luoyuxia
> Fix spliting file optimization doesn't work for orc format
> ---
[
https://issues.apache.org/jira/browse/FLINK-29126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-29126:
---
Fix Version/s: 1.16.0
> Fix spliting file optimization doesn't work for orc format
> ---
yuzelin commented on PR #20931:
URL: https://github.com/apache/flink/pull/20931#issuecomment-1274130610
@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 specific comment.
godfreyhe closed pull request #20694: [FLINK-29126][hive] Fix wrong logic for
spliting file for orc format
URL: https://github.com/apache/flink/pull/20694
--
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 g
hlteoh37 commented on PR #21009:
URL: https://github.com/apache/flink/pull/21009#issuecomment-1274126688
@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 specific comment.
[
https://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615480#comment-17615480
]
Samrat Deb commented on FLINK-29432:
Thanks [~luoyuxia] for your view on the issue !
[
https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615467#comment-17615467
]
RocMarshal commented on FLINK-26999:
[~rmetzger] , The FLIP current content should b
yuzelin commented on PR #20931:
URL: https://github.com/apache/flink/pull/20931#issuecomment-1274069957
@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 specific comment.
flinkbot commented on PR #21012:
URL: https://github.com/apache/flink/pull/21012#issuecomment-1274042879
## CI report:
* 35800afb006d8268985089c7829eba83192a0ace UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-29526:
--
Assignee: Feifan Wang
> Java doc mistake in SequenceNumberRange#contains()
>
zoltar9264 commented on PR #20975:
URL: https://github.com/apache/flink/pull/20975#issuecomment-1274040459
@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 specific comment
zoltar9264 commented on code in PR #20975:
URL: https://github.com/apache/flink/pull/20975#discussion_r991782319
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/SequenceNumberRange.java:
##
@@ -29,7 +29,7 @@ public interface SequenceNumberRange {
lon
[
https://issues.apache.org/jira/browse/FLINK-29543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29543:
---
Labels: pull-request-available (was: )
> Jar Run Rest Handler Support Flink Configuration
>
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615441#comment-17615441
]
Paul Lin commented on FLINK-27344:
--
[~ekoblov] Sure. It's documented in the FLIP
[http
czy006 opened a new pull request, #21012:
URL: https://github.com/apache/flink/pull/21012
# What is the purpose of the change
Add new feature from FLIP-256 about support jm rest API flinkconfiguration
# Brief change log
- Add JM Rest Api Jar Run Rest Handler Support Flink
zoltar9264 commented on PR #20965:
URL: https://github.com/apache/flink/pull/20965#issuecomment-1274037452
@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 specific comment
zoltar9264 commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r991780193
##
docs/content.zh/docs/ops/metrics.md:
##
@@ -1581,6 +1581,11 @@ Note that the metrics are only available via reporters.
The number of failed materializations
zoltar9264 commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r991779836
##
flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java:
##
@@ -251,6 +254,8 @@ private void
zoltar9264 commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r991779398
##
docs/content.zh/docs/ops/metrics.md:
##
@@ -1581,6 +1581,11 @@ Note that the metrics are only available via reporters.
The number of failed materializations
flinkbot commented on PR #21011:
URL: https://github.com/apache/flink/pull/21011#issuecomment-1274031819
## CI report:
* 4bc7cb104b31f5c7abd3b52b3b926b0051507b87 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29333:
---
Labels: pull-request-available (was: )
> Flink SQL Planner Module doesn't read config from
hehuiyuan opened a new pull request, #21011:
URL: https://github.com/apache/flink/pull/21011
## What is the purpose of the change
Support the tableconfig object get configuration infos from flink-conf.yaml
file
## Does this pull request potentially affect one of th
[
https://issues.apache.org/jira/browse/FLINK-27423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-27423.
--
Resolution: Fixed
Close it seems it has been fixed. Feel free to open it if not.
> Upgrade Hive 3.1 c
[
https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615432#comment-17615432
]
luoyuxia commented on FLINK-27384:
--
[~leonard] Seems the prs for release-1.4&1.15 branc
[
https://issues.apache.org/jira/browse/FLINK-27604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-27604.
--
Resolution: Fixed
> flink sql read hive on hbase throw NPE
> --
>
[
https://issues.apache.org/jira/browse/FLINK-27604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615429#comment-17615429
]
luoyuxia edited comment on FLINK-27604 at 10/11/22 2:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-27604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615429#comment-17615429
]
luoyuxia commented on FLINK-27604:
--
[~18579099...@163.com] Thanks for reporting it. Cur
[
https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-26990.
Resolution: Cannot Reproduce
> BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinish
[
https://issues.apache.org/jira/browse/FLINK-27598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-27598:
Assignee: Xingbo Huang
> Improve the exception message when mixing use Python UDF and Pan
[
https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-27715.
Resolution: Fixed
Merged into master via 91e74648bf47d1027ef3362c61456b90fcf89535
> Add more Pyth
[
https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-28394.
Resolution: Cannot Reproduce
> Python py36-cython: InvocationError for command install_command.sh
[
https://issues.apache.org/jira/browse/FLINK-28526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-28526:
Assignee: Xingbo Huang
> Fail to lateral join with UDTF from Table with timstamp column
>
[
https://issues.apache.org/jira/browse/FLINK-28742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-28742:
Assignee: Xingbo Huang
> Table.to_pandas fails with lit("xxx")
>
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-28528:
Assignee: Xingbo Huang
> Table.getSchema fails on table with watermark
>
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-28786.
Resolution: Not A Problem
> Cannot run PyFlink 1.16 on MacOS with M1 chip
> --
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r991765238
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given l
HuangXingBo commented on code in PR #20756:
URL: https://github.com/apache/flink/pull/20756#discussion_r991762362
##
flink-python/setup.py:
##
@@ -316,16 +316,10 @@ def extracted_output_files(base_dir, file_path,
output_directory):
'python_full_version
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615420#comment-17615420
]
Xintong Song commented on FLINK-29572:
--
I think this was introduced by FLINK-24474.
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-29572:
-
Issue Type: Bug (was: Improvement)
> Flink Task Manager skip loopback interface for resource ma
[
https://issues.apache.org/jira/browse/FLINK-29000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29000:
Assignee: Xingbo Huang
> Support python UDF in the SQL Gateway
>
[
https://issues.apache.org/jira/browse/FLINK-29575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615418#comment-17615418
]
Xingbo Huang commented on FLINK-29575:
--
This feature is introduced in release-1.16,
luoyuxia commented on PR #20907:
URL: https://github.com/apache/flink/pull/20907#issuecomment-1274002208
@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 specific comment.
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-29427:
-
Assignee: Alexander Smirnov
> LookupJoinITCase failed with classloader problem
> --
[
https://issues.apache.org/jira/browse/FLINK-29462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29462.
Resolution: Duplicate
> LookupJoinITCase failed on azure due to classloader leaking
>
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615416#comment-17615416
]
xiaogang zhou commented on FLINK-29545:
---
[~martijnvisser] this can also happen in
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615413#comment-17615413
]
Xingbo Huang commented on FLINK-29419:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-29559:
--
Description: For these tables without table statistics, we need to disable
join reorder for th
[
https://issues.apache.org/jira/browse/FLINK-29559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-29559:
--
Summary: Disable Join Reorder for these tables whose statistics are
unavailable in batch mode
lsyldliu commented on code in PR #20652:
URL: https://github.com/apache/flink/pull/20652#discussion_r991742960
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableSchema.java:
##
@@ -72,4 +87,14 @@ public Optional getWatermark() {
publ
hehuiyuan closed pull request #20995: [FLINK-29553][table]Support
UNIX_TIMESTAMP built-in function in Table API
URL: https://github.com/apache/flink/pull/20995
--
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
fsk119 commented on PR #20931:
URL: https://github.com/apache/flink/pull/20931#issuecomment-1273985394
@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 specific comment.
T
luoyuxia commented on code in PR #20987:
URL: https://github.com/apache/flink/pull/20987#discussion_r991746653
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserTypeCheckProcFactory.java:
##
@@ -1216,7 +1216,7 @@ prot
[
https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29483:
---
Assignee: jackylau
> flink python udf arrow in thread model bug
> -
[
https://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615410#comment-17615410
]
luoyuxia commented on FLINK-29432:
--
Thanks for contribution. But to put it briefly, I p
Angelo Kastroulis created FLINK-29575:
-
Summary: Can't Add Temporary Function USING JAR
Key: FLINK-29575
URL: https://issues.apache.org/jira/browse/FLINK-29575
Project: Flink
Issue Type:
yunfengzhou-hub commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r991744425
##
flink-ml-python/pyflink/ml/lib/feature/vectorassembler.py:
##
@@ -31,17 +33,38 @@ class _VectorAssemblerParams(
Params for :class:`VectorAssembler`.
luoyuxia commented on PR #20999:
URL: https://github.com/apache/flink/pull/20999#issuecomment-1273971517
The `load data inpath` statement in `HiveDialectQueryITCase` will **move**
`/csv/test.csv` to other place, then other tests will get `null` by
`getClass().getResource("/csv/test.csv")
flinkbot commented on PR #21010:
URL: https://github.com/apache/flink/pull/21010#issuecomment-1273971304
## CI report:
* 19da765ddf23e66964531ff98b7bb5691d67ae60 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily opened a new pull request, #21010:
URL: https://github.com/apache/flink/pull/21010
## What is the purpose of the change
There are known issues with Pulsar on Java 11, which is why we want to
disable test runs on Java 11. However, the tests still use the JUnit4
annotation for d
bzhaoopenstack commented on PR #20498:
URL: https://github.com/apache/flink/pull/20498#issuecomment-1273954844
@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 specific com
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-29545:
--
Description:
the task dag is like attached file. the task is started to consume from
earliest
[
https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615386#comment-17615386
]
Yufan Sheng edited comment on FLINK-24302 at 10/11/22 12:35 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615386#comment-17615386
]
Yufan Sheng commented on FLINK-24302:
-
Support flink-connector-pulsar on Java 11 see
flinkbot commented on PR #21009:
URL: https://github.com/apache/flink/pull/21009#issuecomment-1273892680
## CI report:
* f378d869c73dc9253d151971c9292b11400d20eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29574:
---
Labels: pull-request-available (was: )
> Upgrade software.amazon.glue:schema-registry-commo
hlteoh37 opened a new pull request, #21009:
URL: https://github.com/apache/flink/pull/21009
… software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14
## What is the purpose of the change
- Update Glue schema registry dependencies
## Brief change log
Hong Liang Teoh created FLINK-29574:
---
Summary: Upgrade software.amazon.glue:schema-registry-common and
software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14
Key: FLINK-29574
URL: https://iss
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615377#comment-17615377
]
Yufan Sheng commented on FLINK-29495:
-
[~martijnvisser] Tks, but how could we know y
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
[
https://issues.apache.org/jira/browse/FLINK-29513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29513.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Also fixed in release-1.16 via 90fba507a824eab2
MartijnVisser merged PR #20977:
URL: https://github.com/apache/flink/pull/20977
--
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...@flink
ferenc-csaky commented on code in PR #20987:
URL: https://github.com/apache/flink/pull/20987#discussion_r991586643
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserTypeCheckProcFactory.java:
##
@@ -1216,7 +1216,7 @@
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615279#comment-17615279
]
Martijn Visser commented on FLINK-29495:
Test disabled in master via be32eddd3a7
MartijnVisser merged PR #21005:
URL: https://github.com/apache/flink/pull/21005
--
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...@flink
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
[
https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-29395:
Description:
*Background*
The consumer fails when an EFO record publisher uses a timestam
mxm commented on code in PR #20953:
URL: https://github.com/apache/flink/pull/20953#discussion_r991532503
##
flink-core/src/main/java/org/apache/flink/configuration/ConfigOption.java:
##
@@ -64,22 +64,37 @@
*
*
* typeClass == atomic class (e.g. {@code Intege
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1273650082
Hi folks, @pnowojski @stevenzwu @zentol Thanks for your review again. I
believe I addressed all comments, except the pending naming of the old
CheckpointType class name (will add in a lat
[
https://issues.apache.org/jira/browse/FLINK-29573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kris wang updated FLINK-29573:
--
Description:
{{ flink_service.bat }}-{-}> \{{flink_inner.bat }}{-}{-}> \{{start-cluster.sh
}}{-}->\{{
kris wang created FLINK-29573:
-
Summary: Flink does not work for windows if installing on other
drive except for C drive
Key: FLINK-29573
URL: https://issues.apache.org/jira/browse/FLINK-29573
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Li updated FLINK-29572:
-
Description:
Currently Flink Task Manager use different local interface to bind to connect
to Resource
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615214#comment-17615214
]
Kevin Li commented on FLINK-29572:
--
{quote}Task Manager Log:
2022-10-08 17:22:32,983 IN
Kevin Li created FLINK-29572:
Summary: Flink Task Manager skip loopback interface for resource
manager registration
Key: FLINK-29572
URL: https://issues.apache.org/jira/browse/FLINK-29572
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-29561.
--
Resolution: Fixed
[{{8e57e5b}}|https://github.com/apache/flink-kubernetes-operator/commit/8e57
mbalassi merged PR #398:
URL: https://github.com/apache/flink-kubernetes-operator/pull/398
--
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-unsubs
mbalassi commented on PR #398:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/398#issuecomment-1273572910
LGTM
--
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
[
https://issues.apache.org/jira/browse/FLINK-29561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29561:
---
Labels: pull-request-available (was: )
> Log the job id when clean up session job failed
>
[
https://issues.apache.org/jira/browse/FLINK-29561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-29561:
--
Assignee: Xin Hao
> Log the job id when clean up session job failed
> ---
[
https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615198#comment-17615198
]
Tiger (Apache) Wang edited comment on FLINK-29503 at 10/10/22 4:25 PM:
---
1 - 100 of 315 matches
Mail list logo
