[jira] [Commented] (FLINK-29860) Pulsar connector bug when using Hybrid.Builder

2022-11-07 Thread Noel O'Connor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630251#comment-17630251 ] Noel O'Connor commented on FLINK-29860: --- [~syhily] yep I do have a patch so assign me. I assume

[jira] [Updated] (FLINK-29925) table ui of configure value is strange

2022-11-07 Thread jiadong.lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiadong.lu updated FLINK-29925: --- Description: As shown in the figure below, when the configure value is very large, the ui of the

[jira] [Created] (FLINK-29925) table ui of configure value is strange

2022-11-07 Thread jiadong.lu (Jira)
jiadong.lu created FLINK-29925: -- Summary: table ui of configure value is strange Key: FLINK-29925 URL: https://issues.apache.org/jira/browse/FLINK-29925 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630244#comment-17630244 ] Weijie Guo commented on FLINK-29923: Through offline discussion with [~AlexXXX] , it is true that

[jira] [Commented] (FLINK-29835) BlobServer fails to provide artifacts

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630243#comment-17630243 ] Matthias Pohl commented on FLINK-29835: ---

[jira] [Updated] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29427: -- Affects Version/s: 1.17.0 > LookupJoinITCase failed with classloader problem >

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630242#comment-17630242 ] Matthias Pohl commented on FLINK-29427: ---

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630241#comment-17630241 ] Matthias Pohl commented on FLINK-26037: ---

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630240#comment-17630240 ] Matthias Pohl commented on FLINK-29461: ---

[jira] [Commented] (FLINK-29594) RMQSourceITCase.testMessageDelivery timed out

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630239#comment-17630239 ] Matthias Pohl commented on FLINK-29594: ---

[jira] [Updated] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2022-11-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28786: - Fix Version/s: 1.17.0 1.16.1 > Cannot run PyFlink 1.16 on MacOS with M1 chip

[jira] [Reopened] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2022-11-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reopened FLINK-28786: -- Assignee: Huang Xingbo > Cannot run PyFlink 1.16 on MacOS with M1 chip >

[GitHub] [flink] flinkbot commented on pull request #21258: [Flink]Support accumulator in source reader.

2022-11-07 Thread GitBox
flinkbot commented on PR #21258: URL: https://github.com/apache/flink/pull/21258#issuecomment-1306739139 ## CI report: * 546e95ec02bd54371b06675ad930f7d07e7afcb8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] snuyanzin commented on a diff in pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

2022-11-07 Thread GitBox
snuyanzin commented on code in PR #21203: URL: https://github.com/apache/flink/pull/21203#discussion_r1016217693 ## flink-table/flink-table-planner/pom.xml: ## @@ -49,6 +49,18 @@ under the License. +

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630236#comment-17630236 ] Matthias Pohl commented on FLINK-29387: ---

[GitHub] [flink] hk-lrzy opened a new pull request, #21258: [Flink]Support accumulator in source reader.

2022-11-07 Thread GitBox
hk-lrzy opened a new pull request, #21258: URL: https://github.com/apache/flink/pull/21258 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink-table-store] tsreaper opened a new pull request, #362: [FLINK-29876] Explicitly throw exception from Table Store sink when unaligned checkpoint is enabled or at least once checkpoint m

2022-11-07 Thread GitBox
tsreaper opened a new pull request, #362: URL: https://github.com/apache/flink-table-store/pull/362 (Cherry-picked from #352) Currently table store sink does not support unaligned checkpoint or at least once checkpoint mode, but no exception is explicitly thrown. We should throw

[GitHub] [flink] czy006 commented on pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-11-07 Thread GitBox
czy006 commented on PR #21012: URL: https://github.com/apache/flink/pull/21012#issuecomment-1306725733 @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.

[jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-23238: -- Priority: Major (was: Not a Priority) >

[jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-23238: -- Affects Version/s: 1.14.6 >

[jira] [Commented] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630234#comment-17630234 ] Matthias Pohl commented on FLINK-23238: --- Raising the priority of the issue to Major again. >

[jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-23238: -- Affects Version/s: 1.15.2 >

[jira] [Commented] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630233#comment-17630233 ] Matthias Pohl commented on FLINK-23238: ---

[jira] [Commented] (FLINK-29860) Pulsar connector bug when using Hybrid.Builder

2022-11-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630232#comment-17630232 ] Zili Chen commented on FLINK-29860: --- [~syhily] [~noelo] I'd prefer the solution by setting

[jira] [Commented] (FLINK-29322) Expose savepoint format on Web UI

2022-11-07 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630231#comment-17630231 ] Yu Chen commented on FLINK-29322: - I have already implemented it, if no one has any objection, I can

[jira] [Closed] (FLINK-29805) Table Store sink continuously fails with "Trying to add file which is already added" when snapshot committing is slow

2022-11-07 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-29805. --- Resolution: Fixed master: 0a193a8110aa4716250fed3c4223018ab519c9b1 release-0.2:

[GitHub] [flink-table-store] tsreaper merged pull request #360: [FLINK-29805] Fix incorrect snapshot filter when snapshots are committing too slow

2022-11-07 Thread GitBox
tsreaper merged PR #360: URL: https://github.com/apache/flink-table-store/pull/360 -- 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:

[jira] [Commented] (FLINK-20184) update hive streaming read and temporal table documents

2022-11-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630229#comment-17630229 ] luoyuxia commented on FLINK-20184: -- [~heigebupahei] Thanks for you attention . Left my comments in here 

[jira] [Updated] (FLINK-29752) Modify Flink Table Store connector to trigger full compaction constantly when full changelog is needed

2022-11-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29752: --- Labels: pull-request-available (was: ) > Modify Flink Table Store connector to trigger

[GitHub] [flink-table-store] tsreaper opened a new pull request, #361: [FLINK-29752] Modify Flink Table Store connector to trigger full compaction constantly when full changelog is needed

2022-11-07 Thread GitBox
tsreaper opened a new pull request, #361: URL: https://github.com/apache/flink-table-store/pull/361 The last step to produce full compaction changelog is to modify Flink Table Store connector, so that full compaction will be triggered once in a while. If not, changelog files are not

[jira] [Closed] (FLINK-29495) PulsarSinkE2ECase hang

2022-11-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29495. - Resolution: Fixed follow-up to fix 1.15 via b37999514cbbd019b31fb2d9c4ae751a956f6c87 >

[jira] [Resolved] (FLINK-29095) Improve logging in SharedStateRegistry

2022-11-07 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu resolved FLINK-29095. -- Resolution: Fixed > Improve logging in SharedStateRegistry >

[GitHub] [flink] tisonkun merged pull request #21250: [FLINK-29495][Connector/Pulsar] Bump the Pulsar to latest 2.10.2

2022-11-07 Thread GitBox
tisonkun merged PR #21250: URL: https://github.com/apache/flink/pull/21250 -- 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:

[GitHub] [flink] tisonkun commented on pull request #21250: [FLINK-29495][Connector/Pulsar] Bump the Pulsar to latest 2.10.2

2022-11-07 Thread GitBox
tisonkun commented on PR #21250: URL: https://github.com/apache/flink/pull/21250#issuecomment-1306718736 Merging.. -- 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

[jira] [Commented] (FLINK-29095) Improve logging in SharedStateRegistry

2022-11-07 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630226#comment-17630226 ] Congxian Qiu commented on FLINK-29095: -- merged into master 9a4250d248e93f3e87b211df98ce3d3c66aabca0

[jira] [Closed] (FLINK-28083) PulsarSource cannot work with object-reusing DeserializationSchema.

2022-11-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28083. - Resolution: Fixed master via 27d42b2e599d4fafc45698711167810407ea0fa2 > PulsarSource cannot work with

[GitHub] [flink] klion26 merged pull request #21136: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-11-07 Thread GitBox
klion26 merged PR #21136: URL: https://github.com/apache/flink/pull/21136 -- 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:

[GitHub] [flink] tisonkun merged pull request #21205: [FLINK-28083][Connector/Pulsar] Object-reusing for Pulsar source

2022-11-07 Thread GitBox
tisonkun merged PR #21205: URL: https://github.com/apache/flink/pull/21205 -- 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:

[GitHub] [flink] tisonkun commented on pull request #21205: [FLINK-28083][Connector/Pulsar] Object-reusing for Pulsar source

2022-11-07 Thread GitBox
tisonkun commented on PR #21205: URL: https://github.com/apache/flink/pull/21205#issuecomment-1306717201 Merging... -- 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

[GitHub] [flink] klion26 commented on pull request #21136: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-11-07 Thread GitBox
klion26 commented on PR #21136: URL: https://github.com/apache/flink/pull/21136#issuecomment-1306717133 @fredia thanks for the contribution, merging it now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-11-07 Thread GitBox
flinkbot commented on PR #21257: URL: https://github.com/apache/flink/pull/21257#issuecomment-1306713547 ## CI report: * f9ea72353323159ccceb94b9d97322692c2efc70 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29879) Introduce operators for files merging in batch mode

2022-11-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29879: --- Labels: pull-request-available (was: ) > Introduce operators for files merging in batch

[GitHub] [flink] luoyuxia opened a new pull request, #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-11-07 Thread GitBox
luoyuxia opened a new pull request, #21257: URL: https://github.com/apache/flink/pull/21257 ## What is the purpose of the change Introduce operators for merging files in batch mode. The whole pipeline will be `BatchFileWriter ` -> `BatchCompactCoordinator ` ->

[jira] [Commented] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

2022-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630218#comment-17630218 ] Matthias Pohl commented on FLINK-29092: ---

[GitHub] [flink] luoyuxia commented on pull request #21242: [FLINK-29878][hive] Fix flink-sql-connector hive error

2022-11-07 Thread GitBox
luoyuxia commented on PR #21242: URL: https://github.com/apache/flink/pull/21242#issuecomment-1306706377 @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.

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #428: [FLINK-29851] Correctly depend on flink-kubernetes-standalone shaded classifier

2022-11-07 Thread GitBox
gyfora merged PR #428: URL: https://github.com/apache/flink-kubernetes-operator/pull/428 -- 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:

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #430: [FLINK-29851] Remove deprecated fabric8 api usage

2022-11-07 Thread GitBox
gyfora merged PR #430: URL: https://github.com/apache/flink-kubernetes-operator/pull/430 -- 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:

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #430: [FLINK-29851] Remove deprecated fabric8 api usage

2022-11-07 Thread GitBox
gyfora commented on code in PR #430: URL: https://github.com/apache/flink-kubernetes-operator/pull/430#discussion_r1016190856 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventUtils.java: ## @@ -107,7 +104,7 @@ public static boolean

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #427: [FLINK-29871] Add 1.16 to CI tests

2022-11-07 Thread GitBox
gyfora commented on code in PR #427: URL: https://github.com/apache/flink-kubernetes-operator/pull/427#discussion_r1016189226 ## e2e-tests/data/multi-sessionjob.yaml: ## @@ -74,7 +74,7 @@ metadata: namespace: flink name: session-cluster-1 spec: - image: flink:1.15 +

[jira] [Assigned] (FLINK-29924) Update official document

2022-11-07 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-29924: --- Assignee: Hang HOU > Update official document > > >

[jira] [Closed] (FLINK-29924) Update official document

2022-11-07 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-29924. --- Resolution: Fixed master: 5e176d286c87a422a5eaab7a9b3e0a3d1546b45d > Update official document >

[GitHub] [flink-table-store] tsreaper merged pull request #359: [FLINK-29924] Fix missing a period in the description of kafka.bootstrap.servers.

2022-11-07 Thread GitBox
tsreaper merged PR #359: URL: https://github.com/apache/flink-table-store/pull/359 -- 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:

[GitHub] [flink-table-store] tsreaper opened a new pull request, #360: [FLINK-29805] Fix incorrect snapshot filter when snapshots are committing too slow

2022-11-07 Thread GitBox
tsreaper opened a new pull request, #360: URL: https://github.com/apache/flink-table-store/pull/360 (Cherry-picked from #350) Table Store sink continuously fails with "Trying to add file which is already added" when snapshot committing is slow. This is due to a bug in

[GitHub] [flink] czy006 commented on a diff in pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-11-07 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r1016183568 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -69,6 +71,11 @@ enum ProgramArgsParType {

[jira] [Closed] (FLINK-29842) Change commitIdentifier in Table Store snapshot to long value

2022-11-07 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-29842. --- Resolution: Fixed master: 350627439a70b187f7270278b497841fa3f2c554 release-0.2:

[GitHub] [flink-table-store] tsreaper merged pull request #358: [FLINK-29842] Change commitIdentifier in Table Store snapshot to long value

2022-11-07 Thread GitBox
tsreaper merged PR #358: URL: https://github.com/apache/flink-table-store/pull/358 -- 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:

[jira] [Commented] (FLINK-22587) Support aggregations in batch mode with DataStream API

2022-11-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630193#comment-17630193 ] Yun Gao commented on FLINK-22587: - Hi, sorry for forgetting to update here, with some more try we found

[jira] [Updated] (FLINK-29924) Update official document

2022-11-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29924: --- Labels: pull-request-available (was: ) > Update official document >

[GitHub] [flink-table-store] houhang1005 opened a new pull request, #359: [FLINK-29924] Fix missing a period in the description of kafka.bootstrap.servers.

2022-11-07 Thread GitBox
houhang1005 opened a new pull request, #359: URL: https://github.com/apache/flink-table-store/pull/359 Just add a missing period about description of "kafka.bootstrap.servers". -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation

2022-11-07 Thread wangzhewenyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630174#comment-17630174 ] wangzhewenyi commented on FLINK-5463: - We had the same problem。 We use flink version 1.11 and submit

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #156: [FLINK-29323] Refine Transformer for VectorAssembler

2022-11-07 Thread GitBox
zhipeng93 commented on code in PR #156: URL: https://github.com/apache/flink-ml/pull/156#discussion_r1016126953 ## docs/content/docs/operators/feature/vectorassembler.md: ## @@ -26,10 +26,20 @@ under the License. --> ## Vector Assembler - -Vector Assembler combines a given

[jira] [Commented] (FLINK-29873) CannotPlanException raised after "CROSS JOIN UNNEST"

2022-11-07 Thread Daeyeon Bae (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630173#comment-17630173 ] Daeyeon Bae commented on FLINK-29873: - If it works well on the master branch, does it mean that the

[GitHub] [flink] Samrat002 commented on pull request #21242: [FLINK-29878][hive] Fix flink-sql-connector hive error

2022-11-07 Thread GitBox
Samrat002 commented on PR #21242: URL: https://github.com/apache/flink/pull/21242#issuecomment-1306616040 ``` Nov 07 19:06:18 java.lang.AssertionError: Create test topic : partition_failure_recovery_EventTime failed, org.apache.kafka.common.errors.TopicExistsException: Topic

[jira] [Commented] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630171#comment-17630171 ] Weijie Guo commented on FLINK-29923: [~AlexXXX] Thanks for the feedback. If I'm not wrong, the

[jira] [Updated] (FLINK-29924) Update official document

2022-11-07 Thread Hang HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang HOU updated FLINK-29924: - Description: Common missing of a period,in Description of "kafka.bootstrap.servers".

[jira] [Created] (FLINK-29924) Update official document

2022-11-07 Thread Hang HOU (Jira)
Hang HOU created FLINK-29924: Summary: Update official document Key: FLINK-29924 URL: https://issues.apache.org/jira/browse/FLINK-29924 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630168#comment-17630168 ] Xintong Song commented on FLINK-29923: -- Thanks for reporting this, [~AlexXXX]. [~Weijie Guo],

[jira] [Updated] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29923: - Description: The flink 1.16 offers hybrid shuffle to combine the superiority of blocking

[jira] [Updated] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29923: - Affects Version/s: 1.16.0 (was: 1.11.6) > Hybrid Shuffle may face

[jira] [Created] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread AlexHu (Jira)
AlexHu created FLINK-29923: -- Summary: Hybrid Shuffle may face deadlock when running a task need to execute big size data Key: FLINK-29923 URL: https://issues.apache.org/jira/browse/FLINK-29923 Project:

[GitHub] [flink-table-store] tsreaper merged pull request #354: [FLINK-29840] Fix bug that old record may overwrite new record in Table Store when snapshot committing is slow

2022-11-07 Thread GitBox
tsreaper merged PR #354: URL: https://github.com/apache/flink-table-store/pull/354 -- 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:

[GitHub] [flink-table-store] tsreaper opened a new pull request, #358: [FLINK-29842] Change commitIdentifier in Table Store snapshot to long value

2022-11-07 Thread GitBox
tsreaper opened a new pull request, #358: URL: https://github.com/apache/flink-table-store/pull/358 (Cherry-picked from #346) Currently `commitIdentifier` in `Snapshot` is a `String` value. However there are many scenarios where we need to compare two identifiers to find out which

[jira] [Updated] (FLINK-29922) Table store hive catalog support create external table

2022-11-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29922: --- Labels: pull-request-available (was: ) > Table store hive catalog support create external

[GitHub] [flink-table-store] wxplovecc opened a new pull request, #357: [FLINK-29922] Support create external table for hive catalog

2022-11-07 Thread GitBox
wxplovecc opened a new pull request, #357: URL: https://github.com/apache/flink-table-store/pull/357 support hive catalog to create external table -- 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

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #156: [FLINK-29323] Refine Transformer for VectorAssembler

2022-11-07 Thread GitBox
weibozhao commented on code in PR #156: URL: https://github.com/apache/flink-ml/pull/156#discussion_r1016098840 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssemblerParams.java: ## @@ -21,11 +21,44 @@ import

[jira] [Created] (FLINK-29922) Table store hive catalog support create external table

2022-11-07 Thread konwu (Jira)
konwu created FLINK-29922: - Summary: Table store hive catalog support create external table Key: FLINK-29922 URL: https://issues.apache.org/jira/browse/FLINK-29922 Project: Flink Issue Type:

[GitHub] [flink] liuzhuang2017 commented on pull request #21255: [hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.

2022-11-07 Thread GitBox
liuzhuang2017 commented on PR #21255: URL: https://github.com/apache/flink/pull/21255#issuecomment-1306550847 @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

[GitHub] [flink] liuzhuang2017 commented on pull request #21256: [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.

2022-11-07 Thread GitBox
liuzhuang2017 commented on PR #21256: URL: https://github.com/apache/flink/pull/21256#issuecomment-1306550196 @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

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on pull request #425: [hotfix][docs] Typo fix in doc pages

2022-11-07 Thread GitBox
yangjf2019 commented on PR #425: URL: https://github.com/apache/flink-kubernetes-operator/pull/425#issuecomment-1306547321 @gyfora I ran the maven build locally before committing. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-07 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630134#comment-17630134 ] Caizhi Weng commented on FLINK-27246: - [~KristoffSC] Thanks for the clarification. The general

[jira] [Commented] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

2022-11-07 Thread Sun Shun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630132#comment-17630132 ] Sun Shun commented on FLINK-29527: -- [~lirui] could you please help take a look at this PR when you are

[GitHub] [flink] zhyg closed pull request #20311: [hotfix][docs-zh]Fixed syntax error

2022-11-07 Thread GitBox
zhyg closed pull request #20311: [hotfix][docs-zh]Fixed syntax error URL: https://github.com/apache/flink/pull/20311 -- 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

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #427: [FLINK-29871] Add 1.16 to CI tests

2022-11-07 Thread GitBox
wangyang0918 commented on code in PR #427: URL: https://github.com/apache/flink-kubernetes-operator/pull/427#discussion_r1016076388 ## e2e-tests/data/multi-sessionjob.yaml: ## @@ -74,7 +74,7 @@ metadata: namespace: flink name: session-cluster-1 spec: - image:

[GitHub] [flink] liuzhuang2017 commented on pull request #21255: [hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.

2022-11-07 Thread GitBox
liuzhuang2017 commented on PR #21255: URL: https://github.com/apache/flink/pull/21255#issuecomment-1306512674 @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

[GitHub] [flink] liuzhuang2017 commented on pull request #21256: [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.

2022-11-07 Thread GitBox
liuzhuang2017 commented on PR #21256: URL: https://github.com/apache/flink/pull/21256#issuecomment-1306512146 @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

[jira] [Closed] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29892. Resolution: Duplicate > flink-conf.yaml does not accept hash (#) in the env.java.opts property >

[jira] [Reopened] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-29892: -- > flink-conf.yaml does not accept hash (#) in the env.java.opts property >

[jira] [Closed] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29892. Resolution: Fixed Let's close this duplicated ticket and keep the discussion in FLINK-15358 >

[jira] [Commented] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

2022-11-07 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630126#comment-17630126 ] dalongliu commented on FLINK-29890: --- [~afedulov] Thanks, I will see it as soon as possible. > UDFs

[GitHub] [flink] flinkbot commented on pull request #21256: [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.

2022-11-07 Thread GitBox
flinkbot commented on PR #21256: URL: https://github.com/apache/flink/pull/21256#issuecomment-1306499192 ## CI report: * 97c7322423aeec681f88de40d8e0ccf76b8f9269 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #21256: [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.

2022-11-07 Thread GitBox
liuzhuang2017 opened a new pull request, #21256: URL: https://github.com/apache/flink/pull/21256 ## What is the purpose of the change - Fix the typo of RecordingChannelStateWriter class. ## Brief change log - Fix the typo of RecordingChannelStateWriter class.

[jira] [Updated] (FLINK-29592) Add Transformer and Estimator for RobustScaler

2022-11-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29592: --- Labels: pull-request-available (was: ) > Add Transformer and Estimator for RobustScaler >

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #172: [FLINK-29592] Add Estimator and Transformer for RobustScaler

2022-11-07 Thread GitBox
jiangxin369 opened a new pull request, #172: URL: https://github.com/apache/flink-ml/pull/172 ## What is the purpose of the change Add Estimator and Transformer for RobustScaler. ## Brief change log - Adds Transformer and Estimator implementation of

[GitHub] [flink] flinkbot commented on pull request #21255: [hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.

2022-11-07 Thread GitBox
flinkbot commented on PR #21255: URL: https://github.com/apache/flink/pull/21255#issuecomment-1306475668 ## CI report: * c690977c1258074b090f8912c2d188c6997cfaec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #21255: [hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.

2022-11-07 Thread GitBox
liuzhuang2017 opened a new pull request, #21255: URL: https://github.com/apache/flink/pull/21255 ## What is the purpose of the change - Update the missing parts of this fault_tolerance Chinese documentation. ## Brief change log - Update the missing parts of this

[GitHub] [flink] flinkbot commented on pull request #21254: Update docker.md

2022-11-07 Thread GitBox
flinkbot commented on PR #21254: URL: https://github.com/apache/flink/pull/21254#issuecomment-1306451186 ## CI report: * a11193c407491a278b0cfb53c48a1cf53c5ffbf1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] mattfysh opened a new pull request, #21254: Update docker.md

2022-11-07 Thread GitBox
mattfysh opened a new pull request, #21254: URL: https://github.com/apache/flink/pull/21254 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] snuyanzin commented on a diff in pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

2022-11-07 Thread GitBox
snuyanzin commented on code in PR #21203: URL: https://github.com/apache/flink/pull/21203#discussion_r1015947724 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/AbstractCodeGeneratorCastRule.java: ## @@ -204,9 +204,10 @@ public

[jira] [Updated] (FLINK-29912) jdbc scan.partition.column can specify any type of field

2022-11-07 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29912: - Description: scan.partition. column can specify any type of field.  At present, scan.partition. column

[GitHub] [flink] snuyanzin commented on a diff in pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

2022-11-07 Thread GitBox
snuyanzin commented on code in PR #21203: URL: https://github.com/apache/flink/pull/21203#discussion_r1016031451 ## flink-table/flink-table-planner/pom.xml: ## @@ -49,6 +49,18 @@ under the License. +

  1   2   3   >