[GitHub] [flink] KarmaGYZ commented on pull request #20042: [FLINK-19358][runtime] Make the job id distinct in application mode w…

2022-06-28 Thread GitBox
KarmaGYZ commented on PR #20042: URL: https://github.com/apache/flink/pull/20042#issuecomment-1169561842 Thanks for the comments. PR updated. @xintongsong @wangyang0918 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-28282) Planner free in flink-table-store-codegen

2022-06-28 Thread Jingsong Lee (Jira)
Title: Message Title Jingsong Lee updated

[jira] [Updated] (FLINK-28292) Get rid of BulkReaderFormatFactory and BulkWriterFormatFactory

2022-06-28 Thread ASF GitHub Bot (Jira)
Title: Message Title ASF GitHub Bot

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #180: [FLINK-28292] Get rid of BulkReaderFormatFactory and BulkWriterFormatFactory

2022-06-28 Thread GitBox
JingsongLi opened a new pull request, #180: URL: https://github.com/apache/flink-table-store/pull/180 These APIs were changed significantly in 1.14 and 1.15 and are not compatible. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-28292) Get rid of BulkReaderFormatFactory and BulkWriterFormatFactory

2022-06-28 Thread Jingsong Lee (Jira)
Title: Message Title Jingsong Lee created

[jira] [Updated] (FLINK-28073) Table Store supports Flink 1.14

2022-06-28 Thread Jingsong Lee (Jira)
Title: Message Title Jingsong Lee updated

[GitHub] [flink] 6591812 commented on pull request #20072: [FLINK-28136][runtime] Implement ExecutionTimeBasedSlowTaskDetector

2022-06-28 Thread GitBox
6591812 commented on PR #20072: URL: https://github.com/apache/flink/pull/20072#issuecomment-1169530980 @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] 1996fanrui commented on a diff in pull request #20075: [FLINK-27789][network] Disable overdraft buffer for LegacySource

2022-06-28 Thread GitBox
1996fanrui commented on code in PR #20075: URL: https://github.com/apache/flink/pull/20075#discussion_r909185339 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java: ## @@ -385,11 +385,16 @@ public Task(

[GitHub] [flink-table-store] JingsongLi closed pull request #178: [FLINK-28244] Introduce changelog file for DataFile

2022-06-28 Thread GitBox
JingsongLi closed pull request #178: [FLINK-28244] Introduce changelog file for DataFile URL: https://github.com/apache/flink-table-store/pull/178 -- 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] wangyang0918 commented on a diff in pull request #20056: [FLINK-28142][runtime] Enrich TaskManagerLocation with node information

2022-06-28 Thread GitBox
wangyang0918 commented on code in PR #20056: URL: https://github.com/apache/flink/pull/20056#discussion_r909164865 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecorator.java: ## @@ -149,7 +153,16 @@ private Container

[jira] [Updated] (FLINK-28286) move “enablechangelog” constant out of flink-streaming-java module

2022-06-28 Thread Yanfei Lei (Jira)
Title: Message Title Yanfei Lei updated

[GitHub] [flink] Myasuka commented on pull request #19998: [FLINK-27822][docs-zh] Translate the doc of checkpoint/savepoint guar…

2022-06-28 Thread GitBox
Myasuka commented on PR #19998: URL: https://github.com/apache/flink/pull/19998#issuecomment-1169492816 > Hi @Myasuka , It seems that test can't be triggered, have you ever come across this ? No, @zentol do you know what happened here? -- This is an automated message from the

[GitHub] [flink] zoltar9264 commented on pull request #19998: [FLINK-27822][docs-zh] Translate the doc of checkpoint/savepoint guar…

2022-06-28 Thread GitBox
zoltar9264 commented on PR #19998: URL: https://github.com/apache/flink/pull/19998#issuecomment-1169491021 Hi @Myasuka , It seems that test can't be triggered, have you ever come across this ? -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20057: [FLINK-28213][runtime] StreamExecutionEnvironment configure method support override pipeline.jars option

2022-06-28 Thread GitBox
zhuzhurk commented on code in PR #20057: URL: https://github.com/apache/flink/pull/20057#discussion_r909160467 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java: ## @@ -1023,6 +1025,19 @@ public void

[jira] [Commented] (FLINK-28206) EOFException on Checkpoint Recovery

2022-06-28 Thread Yun Tang (Jira)
Title: Message Title Yun Tang commented

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-06-28 Thread Yun Tang (Jira)
Title: Message Title Yun Tang commented

[GitHub] [flink-table-store] JingsongLi closed pull request #178: [FLINK-28244] Introduce changelog file for DataFile

2022-06-28 Thread GitBox
JingsongLi closed pull request #178: [FLINK-28244] Introduce changelog file for DataFile URL: https://github.com/apache/flink-table-store/pull/178 -- 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

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-06-28 Thread jiulong.zhu (Jira)
Title: Message Title jiulong.zhu updated

[jira] [Created] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-06-28 Thread jiulong.zhu (Jira)
Title: Message Title jiulong.zhu created

[jira] [Commented] (FLINK-26979) JsonFunctionsITCase.test failed on azure

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Updated] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo updated

[jira] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Commented] (FLINK-28198) CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[GitHub] [flink] masteryhx commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

2022-06-28 Thread GitBox
masteryhx commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r909148359 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java: ## @@ -477,6 +478,50 @@

[jira] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Commented] (FLINK-28290) SessionManagerTest.testSessionNumberLimit failed with AssertionFailedError

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[jira] [Created] (FLINK-28290) SessionManagerTest.testSessionNumberLimit failed with AssertionFailedError

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo created

[jira] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[GitHub] [flink] fsk119 commented on a diff in pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

2022-06-28 Thread GitBox
fsk119 commented on code in PR #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r909145606 ## flink-core/src/main/java/org/apache/flink/util/FileLock.java: ## @@ -0,0 +1,166 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more

[GitHub] [flink] fsk119 commented on a diff in pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

2022-06-28 Thread GitBox
fsk119 commented on code in PR #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r909145606 ## flink-core/src/main/java/org/apache/flink/util/FileLock.java: ## @@ -0,0 +1,166 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more

[GitHub] [flink-ml] lindong28 closed pull request #74: [FLINK-26828][example] add new examples sub module and create KMeans example

2022-06-28 Thread GitBox
lindong28 closed pull request #74: [FLINK-26828][example] add new examples sub module and create KMeans example URL: https://github.com/apache/flink-ml/pull/74 -- 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-ml] lindong28 commented on pull request #74: [FLINK-26828][example] add new examples sub module and create KMeans example

2022-06-28 Thread GitBox
lindong28 commented on PR #74: URL: https://github.com/apache/flink-ml/pull/74#issuecomment-1169469111 Thanks for the PR. We have added examples and the corresponding doc in https://github.com/apache/flink-ml/pull/119. I will close this PR as discussed offline. -- This is an

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-06-28 Thread Huang Xingbo (Jira)
Title: Message Title Huang Xingbo

[GitHub] [flink-ml] lindong28 merged pull request #121: [FLINK-27715] Add pyflink examples

2022-06-28 Thread GitBox
lindong28 merged PR #121: URL: https://github.com/apache/flink-ml/pull/121 -- 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-ml] lindong28 commented on pull request #121: [FLINK-27715] Add pyflink examples

2022-06-28 Thread GitBox
lindong28 commented on PR #121: URL: https://github.com/apache/flink-ml/pull/121#issuecomment-1169468374 Thanks for the update. 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

[GitHub] [flink] flinkbot commented on pull request #20098: [FLINK-28288][table][python] Support decode and encode in Table API

2022-06-28 Thread GitBox
flinkbot commented on PR #20098: URL: https://github.com/apache/flink/pull/20098#issuecomment-1169465743 ## CI report: * aaf82b9952009cc3fc131cd86d0f0201a5986855 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread ASF GitHub Bot (Jira)
Title: Message Title ASF GitHub Bot

[GitHub] [flink] deadwind4 opened a new pull request, #20098: [FLINK-28288][table][python] Support decode and encode in Table API

2022-06-28 Thread GitBox
deadwind4 opened a new pull request, #20098: URL: https://github.com/apache/flink/pull/20098 ## What is the purpose of the change Support decode and encode built-in functions in Table API. ## Brief change log - *Support decode and encode built-in functions in Table

[jira] [Created] (FLINK-28289) Introduce Spark2 Reader for table store

2022-06-28 Thread Jingsong Lee (Jira)
Title: Message Title Jingsong Lee created

[jira] [Updated] (FLINK-27907) Implement disk read and write logic for hybrid shuffle

2022-06-28 Thread Weijie Guo (Jira)
Title: Message Title Weijie Guo updated

[jira] [Updated] (FLINK-27907) Implement disk read and write logic for hybrid shuffle

2022-06-28 Thread Weijie Guo (Jira)
Title: Message Title Weijie Guo updated

[jira] [Updated] (FLINK-27907) Implement disk read and write logic for hybrid shuffle

2022-06-28 Thread Weijie Guo (Jira)
Title: Message Title Weijie Guo updated

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-06-28 Thread Feifan Wang (Jira)
Title: Message Title Feifan Wang

[jira] [Updated] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang updated

[jira] [Updated] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang updated

[jira] [Created] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang created

[GitHub] [flink] HuangXingBo commented on a diff in pull request #19878: [FLINK-27584][python] Support non-keyed co-broadcast processing

2022-06-28 Thread GitBox
HuangXingBo commented on code in PR #19878: URL: https://github.com/apache/flink/pull/19878#discussion_r906952038 ## flink-python/src/main/java/org/apache/flink/streaming/api/transformations/python/PythonBroadcastStateTransformation.java: ## @@ -0,0 +1,90 @@ +/* + * Licensed to

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #121: [FLINK-27715] Add pyflink examples

2022-06-28 Thread GitBox
yunfengzhou-hub commented on code in PR #121: URL: https://github.com/apache/flink-ml/pull/121#discussion_r909134520 ## flink-ml-python/pyflink/examples/ml/__init__.py: ## @@ -15,3 +15,80 @@ # See the License for the specific language governing permissions and # limitations

[GitHub] [flink] lsyldliu commented on pull request #20003: [FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

2022-06-28 Thread GitBox
lsyldliu commented on PR #20003: URL: https://github.com/apache/flink/pull/20003#issuecomment-1169449211 @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] lsyldliu commented on pull request #20057: [FLINK-28213][runtime] StreamExecutionEnvironment configure method support override pipeline.jars option

2022-06-28 Thread GitBox
lsyldliu commented on PR #20057: URL: https://github.com/apache/flink/pull/20057#issuecomment-1169448529 @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] [Commented] (FLINK-28172) Scatter dstl files into separate directories by job id

2022-06-28 Thread Feifan Wang (Jira)
Title: Message Title Feifan Wang

[GitHub] [flink] zoltar9264 commented on pull request #20093: [FLINK-28172][changelog] Scatter dstl files into separate directories…

2022-06-28 Thread GitBox
zoltar9264 commented on PR #20093: URL: https://github.com/apache/flink/pull/20093#issuecomment-1169447489 @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-9970) Add ASCII/CHR function for Table API

2022-06-28 Thread Dian Fu (Jira)
Title: Message Title Dian Fu closed an

[jira] [Updated] (FLINK-28092) Support ASCII and CHR built-in function in the Table API

2022-06-28 Thread Dian Fu (Jira)
Title: Message Title Dian Fu updated an

[GitHub] [flink] xintongsong commented on pull request #20031: [FLINK-27906][runtime] Introduce HsDataIndex.

2022-06-28 Thread GitBox
xintongsong commented on PR #20031: URL: https://github.com/apache/flink/pull/20031#issuecomment-1169445372 @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-28092) Support ASCII and CHR built-in function in the Table API

2022-06-28 Thread Dian Fu (Jira)
Title: Message Title Dian Fu closed an

[GitHub] [flink] dianfu closed pull request #19988: [FLINK-28092][table] Support ASCII and CHR built-in function in the Table API

2022-06-28 Thread GitBox
dianfu closed pull request #19988: [FLINK-28092][table] Support ASCII and CHR built-in function in the Table API URL: https://github.com/apache/flink/pull/19988 -- 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] dianfu commented on pull request #19988: [FLINK-28092][table] Support ASCII and CHR built-in function in the Table API

2022-06-28 Thread GitBox
dianfu commented on PR #19988: URL: https://github.com/apache/flink/pull/19988#issuecomment-1169444531 LGTM. Merging... > If we migrate all built-in functions to the new stack, we could create a new Jira ticket to target this. Agree. Let's do that in a separate ticket if we

[GitHub] [flink] zoltar9264 commented on pull request #19998: [FLINK-27822][docs-zh] Translate the doc of checkpoint/savepoint guar…

2022-06-28 Thread GitBox
zoltar9264 commented on PR #19998: URL: https://github.com/apache/flink/pull/19998#issuecomment-1169443111 @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] Aitozi commented on a diff in pull request #283: [FLINK-28228] Never skip generations when observing already upgraded deployment

2022-06-28 Thread GitBox
Aitozi commented on code in PR #283: URL: https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r909107158 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -279,21

[GitHub] [flink-kubernetes-operator] tweise commented on pull request #281: [FLINK-26891] Record important deployment events

2022-06-28 Thread GitBox
tweise commented on PR #281: URL: https://github.com/apache/flink-kubernetes-operator/pull/281#issuecomment-1169419765 > The PR looks pretty good! > > My only question whether we should trigger events before or after executing the actions using the Flink service. > > For

[GitHub] [flink] nyingping commented on pull request #20028: [hotfix][docs] Remove redundant "." from sample code

2022-06-28 Thread GitBox
nyingping commented on PR #20028: URL: https://github.com/apache/flink/pull/20028#issuecomment-1169414641 @Myasuka @MartijnVisser 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

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #283: [FLINK-28228] Never skip generations when observing already upgraded deployment

2022-06-28 Thread GitBox
Aitozi commented on code in PR #283: URL: https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r909093534 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -279,21

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #283: [FLINK-28228] Never skip generations when observing already upgraded deployment

2022-06-28 Thread GitBox
Aitozi commented on code in PR #283: URL: https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r908605561 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java: ## @@ -352,22 +382,33 @@

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #283: [FLINK-28228] Never skip generations when observing already upgraded deployment

2022-06-28 Thread GitBox
Aitozi commented on code in PR #283: URL: https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r908605561 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java: ## @@ -352,22 +382,33 @@

[jira] [Updated] (FLINK-28287) Should TaskManagerRunner need a ShutdownHook

2022-06-28 Thread JieFang.He (Jira)
Title: Message Title JieFang.He updated

[jira] [Created] (FLINK-28287) Should TaskManagerRunner need a ShutdownHook

2022-06-28 Thread JieFang.He (Jira)
Title: Message Title JieFang.He created

[GitHub] [flink] syhily commented on pull request #19473: [FLINK-27199][Connector/Pulsar] Bump pulsar to 2.10.0

2022-06-28 Thread GitBox
syhily commented on PR #19473: URL: https://github.com/apache/flink/pull/19473#issuecomment-1169400631 > Thanks for the patch @syhily. I notice that this PR touches a lot of components including Pulsar client version, docs even default value of sink options. What about breaking these

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-06-28 Thread Roman Khachatryan (Jira)
Title: Message Title Roman Khachatryan

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

2022-06-28 Thread GitBox
rkhachatryan commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r909048188 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java: ## @@ -477,6 +478,50 @@

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

2022-06-28 Thread Yordan Pavlov (Jira)
Title: Message Title Yordan Pavlov

[GitHub] [flink] flinkbot commented on pull request #20097: [FLINK-28284][Connectors/Jdbc] Add JdbcSink with new format

2022-06-28 Thread GitBox
flinkbot commented on PR #20097: URL: https://github.com/apache/flink/pull/20097#issuecomment-1169146748 ## CI report: * 8bcbd05a6b7eeb2000685b729f860eae3c1b50aa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-18096) Generated avro formats should support user specified name and namespace

2022-06-28 Thread Robin Neufeld (Jira)
Title: Message Title Robin Neufeld

[GitHub] [flink] eskabetxe commented on pull request #20097: [FLINK-28284] Add JdbcSink with new format

2022-06-28 Thread GitBox
eskabetxe commented on PR #20097: URL: https://github.com/apache/flink/pull/20097#issuecomment-1169141734 @leonardBang @MartijnVisser could you check this? -- 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

[jira] [Updated] (FLINK-28284) Add JdbcSink based on new Sink (sink2)

2022-06-28 Thread ASF GitHub Bot (Jira)
Title: Message Title ASF GitHub Bot

[GitHub] [flink] eskabetxe opened a new pull request, #20097: [FLINK-28284] Add JdbcSink with new format

2022-06-28 Thread GitBox
eskabetxe opened a new pull request, #20097: URL: https://github.com/apache/flink/pull/20097 ## What is the purpose of the change Add a JdbcSink with new format (sink2) ## Brief change log - *JdbcSink* the new sink - *JdbcSinkWriter* the writer used by the new

[jira] [Closed] (FLINK-28268) Elasticsearch6SinkE2ECase failed with no space left on device

2022-06-28 Thread Martijn Visser (Jira)
Title: Message Title Martijn Visser

[jira] [Closed] (FLINK-28263) TPC-DS Bash e2e tests don't clean-up after completing

2022-06-28 Thread Martijn Visser (Jira)
Title: Message Title Martijn Visser

[GitHub] [flink] MartijnVisser merged pull request #20096: [FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser merged PR #20096: URL: https://github.com/apache/flink/pull/20096 -- 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] MartijnVisser merged pull request #20095: [FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser merged PR #20095: URL: https://github.com/apache/flink/pull/20095 -- 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] MartijnVisser opened a new pull request, #20096: [FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser opened a new pull request, #20096: URL: https://github.com/apache/flink/pull/20096 Unchanged backport of https://github.com/apache/flink/pull/20083 -- 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] MartijnVisser opened a new pull request, #20095: [FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser opened a new pull request, #20095: URL: https://github.com/apache/flink/pull/20095 Unchanged backport of https://github.com/apache/flink/pull/20083 -- 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] MartijnVisser merged pull request #20083: [FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser merged PR #20083: URL: https://github.com/apache/flink/pull/20083 -- 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] [Comment Edited] (FLINK-28206) EOFException on Checkpoint Recovery

2022-06-28 Thread uharaqo (Jira)
Title: Message Title uharaqo edited a

[GitHub] [flink] MartijnVisser commented on pull request #20083: [FLINK-28263][TPCDS][Tests] Clean-up generated folders by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser commented on PR #20083: URL: https://github.com/apache/flink/pull/20083#issuecomment-1169074724 @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] [Commented] (FLINK-28269) Kubernetes test failed with permission denied

2022-06-28 Thread Martijn Visser (Jira)
Title: Message Title Martijn Visser

[GitHub] [flink] zentol commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

2022-06-28 Thread GitBox
zentol commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r908766389 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java: ## @@ -685,13 +687,27 @@ public CompletableFuture submitTask(

[jira] [Updated] (FLINK-28263) TPC-DS Bash e2e tests don't clean-up after completing

2022-06-28 Thread ASF GitHub Bot (Jira)
Title: Message Title ASF GitHub Bot

[GitHub] [flink] MartijnVisser commented on pull request #20083: [FLINK-28263][TPCDS][Tests] Clean-up generated folders by TPCDS test

2022-06-28 Thread GitBox
MartijnVisser commented on PR #20083: URL: https://github.com/apache/flink/pull/20083#issuecomment-1169016409 @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] [Commented] (FLINK-28216) Hadoop S3FileSystemFactory does not honor fs.s3.impl

2022-06-28 Thread Martijn Visser (Jira)
Title: Message Title Martijn Visser

[jira] [Commented] (FLINK-27852) Contribute k8s operator to OperatorHub

2022-06-28 Thread Jira
Title: Message Title Márton Balassi

[jira] [Commented] (FLINK-28206) EOFException on Checkpoint Recovery

2022-06-28 Thread uharaqo (Jira)
Title: Message Title uharaqo commented on

[jira] [Assigned] (FLINK-27852) Contribute k8s operator to OperatorHub

2022-06-28 Thread Jira
Title: Message Title Márton Balassi

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-06-28 Thread Sebastian Mattheis (Jira)
Title: Message Title Sebastian Mattheis

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-06-28 Thread Sebastian Mattheis (Jira)
Title: Message Title Sebastian Mattheis

[jira] [Assigned] (FLINK-27852) Contribute k8s operator to OperatorHub

2022-06-28 Thread Jira
Title: Message Title Márton Balassi

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #284: [tooling] Use 7 letter hash in release scripts

2022-06-28 Thread GitBox
mbalassi merged PR #284: URL: https://github.com/apache/flink-kubernetes-operator/pull/284 -- 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:

  1   2   3   >