[jira] [Commented] (FLINK-25866) Support additional TLS configuration.
[
https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484555#comment-17484555
]
Fil Karnicki commented on FLINK-25866:
--
Ok that makes sense to me Till.
Here's another proposal - would it make sense to allow the ability to provide
the certificate inline in yaml in addition to being able choose a local path?
Something like:
{code:java}
trust_cacerts:
content: |
-BEGIN CERTIFICATE-
ABCD...
EFGH...==
-END CERTIFICATE-
OR
location: /path/to/cert {code}
The reason why I'm asking is that I believe that these certs would have to be
accessible from all the task executors. Since we're using a shared cloudera
cluster to run statefun uber jar jobs, I'm having a difficult time finding a
way to make the certs available from all the task executors to our jobs while
keeping then unavailable to others' jobs.
> Support additional TLS configuration.
> -
>
> Key: FLINK-25866
> URL: https://issues.apache.org/jira/browse/FLINK-25866
> Project: Flink
> Issue Type: Improvement
> Components: Stateful Functions
>Reporter: Igal Shilman
>Priority: Major
>
> Currently the default HTTP client used to invoke remote functions does not
> support customising the TLS settings as part of the endpoint spec definition.
> This includes
> using self-signed certificates, and providing client side certificates for
> authentication (which is a slightly different requirement).
> This issue is about including additional TLS settings to the default endpoint
> resource definition, and supporting them in statefun-core.
> User mailing list threads:
> * [client cert auth in remote
> function|https://lists.apache.org/thread/97nw245kxqp32qglwfynhhgyhgp2pxvg]
> * [endpoint self-signed certificate
> problem|https://lists.apache.org/thread/y2m2bpwg4n71rxfont6pgky2t8m19n7w]
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable Application/Per-job mode on YARN to use usrlib
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 5eb98df7422ffca67eb4d258189ff1eadb36731e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30492) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP
[
https://issues.apache.org/jira/browse/FLINK-25523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484534#comment-17484534
]
Yun Gao commented on FLINK-25523:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30491=logs=ce8f3cc3-c1ea-5281-f5eb-df9ebd24947f=918e890f-5ed9-5212-a25e-962628fb4bc5=35753
> KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP
> ---
>
> Key: FLINK-25523
> URL: https://issues.apache.org/jira/browse/FLINK-25523
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.15.0
>Reporter: Till Rohrmann
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0
>
>
> The test {{KafkaSourceITCase$KafkaSpecificTests.testTimestamp}} fails on AZP
> with
> {code}
> 2022-01-05T03:08:57.1647316Z java.util.concurrent.TimeoutException: The topic
> metadata failed to propagate to Kafka broker.
> 2022-01-05T03:08:57.1660635Z at
> org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:214)
> 2022-01-05T03:08:57.1667856Z at
> org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:230)
> 2022-01-05T03:08:57.1668778Z at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.createTestTopic(KafkaTestEnvironmentImpl.java:216)
> 2022-01-05T03:08:57.1670072Z at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.createTestTopic(KafkaTestEnvironment.java:98)
> 2022-01-05T03:08:57.1671078Z at
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.createTestTopic(KafkaTestBase.java:216)
> 2022-01-05T03:08:57.1671942Z at
> org.apache.flink.connector.kafka.source.KafkaSourceITCase$KafkaSpecificTests.testTimestamp(KafkaSourceITCase.java:104)
> 2022-01-05T03:08:57.1672619Z at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-01-05T03:08:57.1673715Z at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-01-05T03:08:57.1675000Z at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-01-05T03:08:57.1675907Z at
> java.base/java.lang.reflect.Method.invoke(Method.java:566)
> 2022-01-05T03:08:57.1676587Z at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2022-01-05T03:08:57.1677316Z at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2022-01-05T03:08:57.1678380Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2022-01-05T03:08:57.1679264Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2022-01-05T03:08:57.1680002Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
> 2022-01-05T03:08:57.1680776Z at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
> 2022-01-05T03:08:57.1681682Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2022-01-05T03:08:57.1682442Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2022-01-05T03:08:57.1683450Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2022-01-05T03:08:57.1685362Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2022-01-05T03:08:57.1686284Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2022-01-05T03:08:57.1687152Z at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2022-01-05T03:08:57.1687818Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2022-01-05T03:08:57.1688479Z at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2022-01-05T03:08:57.1689376Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
> 2022-01-05T03:08:57.1690108Z at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-01-05T03:08:57.1690825Z at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
> 2022-01-05T03:08:57.1691470Z at
>
[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure
[
https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484533#comment-17484533
]
Yun Gao commented on FLINK-25825:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30491=logs=e9af9cde-9a65-5281-a58e-2c8511d36983=c520d2c3-4d17-51f1-813b-4b0b74a0c307=14011
> MySqlCatalogITCase fails on azure
> -
>
> Key: FLINK-25825
> URL: https://issues.apache.org/jira/browse/FLINK-25825
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
>Affects Versions: 1.15.0
>Reporter: Roman Khachatryan
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30189=logs=e9af9cde-9a65-5281-a58e-2c8511d36983=c520d2c3-4d17-51f1-813b-4b0b74a0c307=13677
>
> {code}
> 2022-01-26T06:04:42.8019913Z Jan 26 06:04:42 [ERROR]
> org.apache.flink.connector.jdbc.catalog.MySqlCatalogITCase.testFullPath Time
> elapsed: 2.166 *s <<< FAILURE!
> 2022-01-26T06:04:42.8025522Z Jan 26 06:04:42 java.lang.AssertionError:
> expected: java.util.ArrayList<[+I[1, -1, 1, null, true, null, hello, 2021-0
> 8-04, 2021-08-04T01:54:16, -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1, -1, 1,
> \{"k1": "v1"}, null, col_longtext, null, -1, 1, col_mediumtext, -99, 9 9,
> -1.0, 1.0, set_ele1, -1, 1, col_text, 10:32:34, 2021-08-04T01:54:16,
> col_tinytext, -1, 1, null, col_varchar, 2021-08-04T01:54:16.463, 09:33:43,
> 2021-08-04T01:54:16.463, null], +I[2, -1, 1, null, true, null, hello,
> 2021-08-04, 2021-08-04T01:53:19, -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1,
> -1, 1, \{"k1": "v1"}, null, col_longtext, null, -1, 1, col_mediumtext, -99,
> 99, -1.0, 1.0, set_ele1,set_ele12, -1, 1, col_text, 10:32:34, 2021-08-
> 04T01:53:19, col_tinytext, -1, 1, null, col_varchar, 2021-08-04T01:53:19.098,
> 09:33:43, 2021-08-04T01:53:19.098, null]]> but was: java.util.ArrayL
> ist<[+I[1, -1, 1, null, true, null, hello, 2021-08-04, 2021-08-04T01:54:16,
> -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1, -1, 1, \{"k1": "v1"}, null,
> col_longtext, null, -1, 1, col_mediumtext, -99, 99, -1.0, 1.0, set_ele1, -1,
> 1, col_text, 10:32:34, 2021-08-04T01:54:16, col_tinytext, -1, 1, null ,
> col_varchar, 2021-08-04T01:54:16.463, 09:33:43, 2021-08-04T01:54:16.463,
> null], +I[2, -1, 1, null, true, null, hello, 2021-08-04, 2021-08-04T01:
> 53:19, -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1, -1, 1, \{"k1": "v1"}, null,
> col_longtext, null, -1, 1, col_mediumtext, -99, 99, -1.0, 1.0, set_el
> e1,set_ele12, -1, 1, col_text, 10:32:34, 2021-08-04T01:53:19, col_tinytext,
> -1, 1, null, col_varchar, 2021-08-04T01:53:19.098, 09:33:43, 2021-08-0
> 4T01:53:19.098, null]]>
> 2022-01-26T06:04:42.8029336Z Jan 26 06:04:42 at
> org.junit.Assert.fail(Assert.java:89)
> 2022-01-26T06:04:42.8029824Z Jan 26 06:04:42 at
> org.junit.Assert.failNotEquals(Assert.java:835)
> 2022-01-26T06:04:42.8030319Z Jan 26 06:04:42 at
> org.junit.Assert.assertEquals(Assert.java:120)
> 2022-01-26T06:04:42.8030815Z Jan 26 06:04:42 at
> org.junit.Assert.assertEquals(Assert.java:146)
> 2022-01-26T06:04:42.8031419Z Jan 26 06:04:42 at
> org.apache.flink.connector.jdbc.catalog.MySqlCatalogITCase.testFullPath(MySqlCatalogITCase.java*:306)
> {code}
>
> {code}
> 2022-01-26T06:04:43.2899378Z Jan 26 06:04:43 [ERROR] Failures:
> 2022-01-26T06:04:43.2907942Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testFullPath:306 expected: java.util.ArrayList<[+I[1, -1,
> 1, null, true,
> 2022-01-26T06:04:43.2914065Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testGetTable:253 expected:<(
> 2022-01-26T06:04:43.2983567Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testSelectToInsert:323 expected:
> java.util.ArrayList<[+I[1, -1, 1, null,
> 2022-01-26T06:04:43.2997373Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testWithoutCatalog:291 expected:
> java.util.ArrayList<[+I[1, -1, 1, null,
> 2022-01-26T06:04:43.3010450Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testWithoutCatalogDB:278 expected:
> java.util.ArrayList<[+I[1, -1, 1, nul
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Created] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure
Yun Gao created FLINK-25885:
---
Summary:
ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes
failed on azure
Key: FLINK-25885
URL: https://issues.apache.org/jira/browse/FLINK-25885
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.15.0
Reporter: Yun Gao
{code:java}
2022-01-31T05:00:07.3113870Z Jan 31 05:00:07
java.util.concurrent.CompletionException:
org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException: Discard message,
because the rpc endpoint
akka.tcp://flink@127.0.0.1:6123/user/rpc/resourcemanager_2 has not been started
yet.
2022-01-31T05:00:07.3115008Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
2022-01-31T05:00:07.3115778Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
2022-01-31T05:00:07.3116527Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
2022-01-31T05:00:07.3117267Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-01-31T05:00:07.3118011Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-31T05:00:07.3118770Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-01-31T05:00:07.3119608Z Jan 31 05:00:07at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:251)
2022-01-31T05:00:07.3120425Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-31T05:00:07.3121199Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-31T05:00:07.3121957Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-31T05:00:07.3122716Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-01-31T05:00:07.3123457Z Jan 31 05:00:07at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1387)
2022-01-31T05:00:07.3124241Z Jan 31 05:00:07at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
2022-01-31T05:00:07.3125106Z Jan 31 05:00:07at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-01-31T05:00:07.3126063Z Jan 31 05:00:07at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-01-31T05:00:07.3127207Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-01-31T05:00:07.3127982Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-01-31T05:00:07.3128741Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-01-31T05:00:07.3129497Z Jan 31 05:00:07at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
2022-01-31T05:00:07.3130385Z Jan 31 05:00:07at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
2022-01-31T05:00:07.3131092Z Jan 31 05:00:07at
akka.dispatch.OnComplete.internal(Future.scala:299)
2022-01-31T05:00:07.3131695Z Jan 31 05:00:07at
akka.dispatch.OnComplete.internal(Future.scala:297)
2022-01-31T05:00:07.3132310Z Jan 31 05:00:07at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-01-31T05:00:07.3132943Z Jan 31 05:00:07at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-01-31T05:00:07.3133577Z Jan 31 05:00:07at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-01-31T05:00:07.3134340Z Jan 31 05:00:07at
org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-01-31T05:00:07.3135149Z Jan 31 05:00:07at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-01-31T05:00:07.3135898Z Jan 31 05:00:07at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-01-31T05:00:07.3136692Z Jan 31 05:00:07at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-01-31T05:00:07.3137454Z Jan 31 05:00:07at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-01-31T05:00:07.3138127Z Jan 31 05:00:07at
akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-01-31T05:00:07.3138726Z Jan 31 05:00:07at
[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable
[
https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484532#comment-17484532
]
Yun Gao commented on FLINK-23944:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30491=logs=5cae8624-c7eb-5c51-92d3-4d2dacedd221=5acec1b4-945b-59ca-34f8-168928ce5199=25035
> PulsarSourceITCase.testTaskManagerFailure is instable
> -
>
> Key: FLINK-23944
> URL: https://issues.apache.org/jira/browse/FLINK-23944
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
>Affects Versions: 1.14.0
>Reporter: Dian Fu
>Assignee: Yufei Zhang
>Priority: Critical
> Labels: pull-request-available, test-stability
> Fix For: 1.15.0
>
>
> [https://dev.azure.com/dianfu/Flink/_build/results?buildId=430=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d]
> It's from my personal azure pipeline, however, I'm pretty sure that I have
> not touched any code related to this.
> {code:java}
> Aug 24 10:44:13 [ERROR] testTaskManagerFailure{TestEnvironment,
> ExternalContext, ClusterControllable}[1] Time elapsed: 258.397 s <<< FAILURE!
> Aug 24 10:44:13 java.lang.AssertionError: Aug 24 10:44:13 Aug 24 10:44:13
> Expected: Records consumed by Flink should be identical to test data and
> preserve the order in split Aug 24 10:44:13 but: Mismatched record at
> position 7: Expected '0W6SzacX7MNL4xLL3BZ8C3ljho4iCydbvxIl' but was
> 'wVi5JaJpNvgkDEOBRC775qHgw0LyRW2HBxwLmfONeEmr' Aug 24 10:44:13 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) Aug 24 10:44:13
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8) Aug 24
> 10:44:13 at
> org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:271)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-24345) Translate "File Systems" page of "Internals" into Chinese
[
https://issues.apache.org/jira/browse/FLINK-24345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484531#comment-17484531
]
baisike commented on FLINK-24345:
-
Hi [~jark], I submit a pr
[{color:#4c9aff}+#18564+{color}|https://github.com/apache/flink/pull/18564] ,
please review it. Thanks!
> Translate "File Systems" page of "Internals" into Chinese
> -
>
> Key: FLINK-24345
> URL: https://issues.apache.org/jira/browse/FLINK-24345
> Project: Flink
> Issue Type: Improvement
> Components: chinese-translation, Documentation
>Reporter: Liebing Yu
>Priority: Major
> Labels: pull-request-available
>
> The page url is
> https://nightlies.apache.org/flink/flink-docs-master/docs/internals/filesystems/
> The markdown file is located in
> flink/docs/content/docs/internals/filesystems.md
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25851) CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP
[ https://issues.apache.org/jira/browse/FLINK-25851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484530#comment-17484530 ] Yun Gao commented on FLINK-25851: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30466=logs=c91190b6-40ae-57b2-5999-31b869b0a7c1=41463ccd-0694-5d4d-220d-8f771e7d098b=11600 > CassandraConnectorITCase.testRetrialAndDropTables shows table already exists > errors on AZP > -- > > Key: FLINK-25851 > URL: https://issues.apache.org/jira/browse/FLINK-25851 > Project: Flink > Issue Type: Bug > Components: Connectors / Cassandra >Affects Versions: 1.15.0 >Reporter: Etienne Chauchot >Assignee: Etienne Chauchot >Priority: Major > Labels: pull-request-available, test-stability > > It happens even if the whole keyspace is dropped in a BeforeClass method and > the table noticed in the stacktrace is dropped in an After method and this > after method is executed even in case of retrials through the Rule. > Jan 24 20:21:33 com.datastax.driver.core.exceptions.AlreadyExistsException: > Table flink.batches already exists > Jan 24 20:21:33 at > com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:111) > > Jan 24 20:21:33 at > com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37) > > Jan 24 20:21:33 at > com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245) > > Jan 24 20:21:33 at > com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63) > Jan 24 20:21:33 at > com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39) > Jan 24 20:21:33 at > org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.testRetrialAndDropTables(CassandraConnectorITCase.java:554) > > Jan 24 20:21:33 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Jan 24 20:21:33 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Jan 24 20:21:33 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > Jan 24 20:21:33 at java.lang.reflect.Method.invoke(Method.java:498) > Jan 24 20:21:33 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > > Jan 24 20:21:33 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > > Jan 24 20:21:33 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > > Jan 24 20:21:33 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > > Jan 24 20:21:33 at > org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) > Jan 24 20:21:33 at > org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) > Jan 24 20:21:33 at > org.apache.flink.testutils.junit.RetryRule$RetryOnExceptionStatement.evaluate(RetryRule.java:192) > > Jan 24 20:21:33 at > org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45) > Jan 24 20:21:33 at > org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61) > Jan 24 20:21:33 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Jan 24 20:21:33 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > > Jan 24 20:21:33 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Jan 24 20:21:33 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > > Jan 24 20:21:33 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > > Jan 24 20:21:33 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Jan 24 20:21:33 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Jan 24 20:21:33 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Jan 24 20:21:33 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Jan 24 20:21:33 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Jan 24 20:21:33 at > org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) > > cf: > [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30050=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=ae4f8708-9994-57d3-c2d7-b892156e7812=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d=11999] -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure
[
https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484529#comment-17484529
]
Yun Gao commented on FLINK-25825:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30466=logs=e9af9cde-9a65-5281-a58e-2c8511d36983=c520d2c3-4d17-51f1-813b-4b0b74a0c307=14010
> MySqlCatalogITCase fails on azure
> -
>
> Key: FLINK-25825
> URL: https://issues.apache.org/jira/browse/FLINK-25825
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
>Affects Versions: 1.15.0
>Reporter: Roman Khachatryan
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30189=logs=e9af9cde-9a65-5281-a58e-2c8511d36983=c520d2c3-4d17-51f1-813b-4b0b74a0c307=13677
>
> {code}
> 2022-01-26T06:04:42.8019913Z Jan 26 06:04:42 [ERROR]
> org.apache.flink.connector.jdbc.catalog.MySqlCatalogITCase.testFullPath Time
> elapsed: 2.166 *s <<< FAILURE!
> 2022-01-26T06:04:42.8025522Z Jan 26 06:04:42 java.lang.AssertionError:
> expected: java.util.ArrayList<[+I[1, -1, 1, null, true, null, hello, 2021-0
> 8-04, 2021-08-04T01:54:16, -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1, -1, 1,
> \{"k1": "v1"}, null, col_longtext, null, -1, 1, col_mediumtext, -99, 9 9,
> -1.0, 1.0, set_ele1, -1, 1, col_text, 10:32:34, 2021-08-04T01:54:16,
> col_tinytext, -1, 1, null, col_varchar, 2021-08-04T01:54:16.463, 09:33:43,
> 2021-08-04T01:54:16.463, null], +I[2, -1, 1, null, true, null, hello,
> 2021-08-04, 2021-08-04T01:53:19, -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1,
> -1, 1, \{"k1": "v1"}, null, col_longtext, null, -1, 1, col_mediumtext, -99,
> 99, -1.0, 1.0, set_ele1,set_ele12, -1, 1, col_text, 10:32:34, 2021-08-
> 04T01:53:19, col_tinytext, -1, 1, null, col_varchar, 2021-08-04T01:53:19.098,
> 09:33:43, 2021-08-04T01:53:19.098, null]]> but was: java.util.ArrayL
> ist<[+I[1, -1, 1, null, true, null, hello, 2021-08-04, 2021-08-04T01:54:16,
> -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1, -1, 1, \{"k1": "v1"}, null,
> col_longtext, null, -1, 1, col_mediumtext, -99, 99, -1.0, 1.0, set_ele1, -1,
> 1, col_text, 10:32:34, 2021-08-04T01:54:16, col_tinytext, -1, 1, null ,
> col_varchar, 2021-08-04T01:54:16.463, 09:33:43, 2021-08-04T01:54:16.463,
> null], +I[2, -1, 1, null, true, null, hello, 2021-08-04, 2021-08-04T01:
> 53:19, -1, 1, -1.0, 1.0, enum2, -9.1, 9.1, -1, 1, -1, 1, \{"k1": "v1"}, null,
> col_longtext, null, -1, 1, col_mediumtext, -99, 99, -1.0, 1.0, set_el
> e1,set_ele12, -1, 1, col_text, 10:32:34, 2021-08-04T01:53:19, col_tinytext,
> -1, 1, null, col_varchar, 2021-08-04T01:53:19.098, 09:33:43, 2021-08-0
> 4T01:53:19.098, null]]>
> 2022-01-26T06:04:42.8029336Z Jan 26 06:04:42 at
> org.junit.Assert.fail(Assert.java:89)
> 2022-01-26T06:04:42.8029824Z Jan 26 06:04:42 at
> org.junit.Assert.failNotEquals(Assert.java:835)
> 2022-01-26T06:04:42.8030319Z Jan 26 06:04:42 at
> org.junit.Assert.assertEquals(Assert.java:120)
> 2022-01-26T06:04:42.8030815Z Jan 26 06:04:42 at
> org.junit.Assert.assertEquals(Assert.java:146)
> 2022-01-26T06:04:42.8031419Z Jan 26 06:04:42 at
> org.apache.flink.connector.jdbc.catalog.MySqlCatalogITCase.testFullPath(MySqlCatalogITCase.java*:306)
> {code}
>
> {code}
> 2022-01-26T06:04:43.2899378Z Jan 26 06:04:43 [ERROR] Failures:
> 2022-01-26T06:04:43.2907942Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testFullPath:306 expected: java.util.ArrayList<[+I[1, -1,
> 1, null, true,
> 2022-01-26T06:04:43.2914065Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testGetTable:253 expected:<(
> 2022-01-26T06:04:43.2983567Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testSelectToInsert:323 expected:
> java.util.ArrayList<[+I[1, -1, 1, null,
> 2022-01-26T06:04:43.2997373Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testWithoutCatalog:291 expected:
> java.util.ArrayList<[+I[1, -1, 1, null,
> 2022-01-26T06:04:43.3010450Z Jan 26 06:04:43 [ERROR]
> MySqlCatalogITCase.testWithoutCatalogDB:278 expected:
> java.util.ArrayList<[+I[1, -1, 1, nul
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18564: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…
flinkbot edited a comment on pull request #18564: URL: https://github.com/apache/flink/pull/18564#issuecomment-1025426056 ## CI report: * 35abc632db9a1244bab14ed9188e0e7a88fe40e9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30493) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint
[
https://issues.apache.org/jira/browse/FLINK-25456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484528#comment-17484528
]
Yun Gao commented on FLINK-25456:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30465=logs=c5612577-f1f7-5977-6ff6-7432788526f7=53f6305f-55e6-561c-8f1e-3a1dde2c77df=6906
> FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint
> ---
>
> Key: FLINK-25456
> URL: https://issues.apache.org/jira/browse/FLINK-25456
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.14.2
>Reporter: Till Rohrmann
>Priority: Critical
> Labels: test-stability
>
> The test {{FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint}}
> fails with
> {code}
> 2021-12-27T02:54:54.8464375Z Dec 27 02:54:54 [ERROR] Tests run: 15, Failures:
> 1, Errors: 0, Skipped: 0, Time elapsed: 285.279 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase
> 2021-12-27T02:54:54.8465354Z Dec 27 02:54:54 [ERROR]
> testScaleDownBeforeFirstCheckpoint Time elapsed: 85.514 s <<< FAILURE!
> 2021-12-27T02:54:54.8468827Z Dec 27 02:54:54 java.lang.AssertionError:
> Detected producer leak. Thread name: kafka-producer-network-thread |
> producer-MockTask-002a002c-18
> 2021-12-27T02:54:54.8469779Z Dec 27 02:54:54 at
> org.junit.Assert.fail(Assert.java:89)
> 2021-12-27T02:54:54.8470485Z Dec 27 02:54:54 at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:847)
> 2021-12-27T02:54:54.8471842Z Dec 27 02:54:54 at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint(FlinkKafkaProducerITCase.java:381)
> 2021-12-27T02:54:54.8472724Z Dec 27 02:54:54 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-12-27T02:54:54.8473509Z Dec 27 02:54:54 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-12-27T02:54:54.8474704Z Dec 27 02:54:54 at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-12-27T02:54:54.8475523Z Dec 27 02:54:54 at
> java.base/java.lang.reflect.Method.invoke(Method.java:566)
> 2021-12-27T02:54:54.8476258Z Dec 27 02:54:54 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2021-12-27T02:54:54.8476949Z Dec 27 02:54:54 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2021-12-27T02:54:54.8477632Z Dec 27 02:54:54 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2021-12-27T02:54:54.8478451Z Dec 27 02:54:54 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2021-12-27T02:54:54.8479282Z Dec 27 02:54:54 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2021-12-27T02:54:54.8479976Z Dec 27 02:54:54 at
> org.apache.flink.testutils.junit.RetryRule$RetryOnFailureStatement.evaluate(RetryRule.java:135)
> 2021-12-27T02:54:54.8480696Z Dec 27 02:54:54 at
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> 2021-12-27T02:54:54.8481410Z Dec 27 02:54:54 at
> org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
> 2021-12-27T02:54:54.8482009Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-12-27T02:54:54.8482636Z Dec 27 02:54:54 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2021-12-27T02:54:54.8483267Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2021-12-27T02:54:54.8483900Z Dec 27 02:54:54 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2021-12-27T02:54:54.8484574Z Dec 27 02:54:54 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2021-12-27T02:54:54.8485214Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2021-12-27T02:54:54.8485838Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2021-12-27T02:54:54.8486441Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2021-12-27T02:54:54.8487037Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2021-12-27T02:54:54.8487620Z Dec 27 02:54:54 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2021-12-27T02:54:54.8488391Z Dec 27 02:54:54 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
>
[GitHub] [flink] flinkbot commented on pull request #18564: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…
flinkbot commented on pull request #18564: URL: https://github.com/apache/flink/pull/18564#issuecomment-1025426552 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the progress of the review. ## Automated Checks Last check on commit 35abc632db9a1244bab14ed9188e0e7a88fe40e9 (Mon Jan 31 06:40:09 UTC 2022) **Warnings:** * No documentation files were touched! Remember to keep the Flink docs up to date! * **This pull request references an unassigned [Jira ticket](https://issues.apache.org/jira/browse/FLINK-24345).** According to the [code contribution guide](https://flink.apache.org/contributing/contribute-code.html), tickets need to be assigned before starting with the implementation work. Mention the bot in a comment to re-run the automated checks. ## Review Progress * ❓ 1. The [description] looks good. * ❓ 2. There is [consensus] that the contribution should go into to Flink. * ❓ 3. Needs [attention] from. * ❓ 4. The change fits into the overall [architecture]. * ❓ 5. Overall code [quality] is good. Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commands The @flinkbot bot supports the following commands: - `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`) - `@flinkbot approve all` to approve all aspects - `@flinkbot approve-until architecture` to approve everything until `architecture` - `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention - `@flinkbot disapprove architecture` to remove an approval you gave earlier -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #18564: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…
flinkbot commented on pull request #18564: URL: https://github.com/apache/flink/pull/18564#issuecomment-1025426056 ## CI report: * 35abc632db9a1244bab14ed9188e0e7a88fe40e9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP
[
https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484526#comment-17484526
]
Yun Gao commented on FLINK-24844:
-
1.13
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30465=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=03dca39c-73e8-5aaf-601d-328ae5c35f20=13913
Hi [~echauchot] could we also pick the fix to 1.13~?
> CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP
> --
>
> Key: FLINK-24844
> URL: https://issues.apache.org/jira/browse/FLINK-24844
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Cassandra
>Affects Versions: 1.14.0
>Reporter: Till Rohrmann
>Assignee: Etienne Chauchot
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0, 1.13.6, 1.14.4
>
>
> The test {{CassandraConnectorITCase.testCassandraBatchPojoFormat}} fails on
> AZP with
> {code}
> 2021-11-09T00:32:42.1369473Z Nov 09 00:32:42 [ERROR] Tests run: 17, Failures:
> 0, Errors: 1, Skipped: 0, Time elapsed: 152.962 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase
> 2021-11-09T00:32:42.1371638Z Nov 09 00:32:42 [ERROR]
> testCassandraBatchPojoFormat Time elapsed: 20.378 s <<< ERROR!
> 2021-11-09T00:32:42.1372881Z Nov 09 00:32:42
> com.datastax.driver.core.exceptions.AlreadyExistsException: Table
> flink.batches already exists
> 2021-11-09T00:32:42.1373913Z Nov 09 00:32:42 at
> com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:111)
> 2021-11-09T00:32:42.1374921Z Nov 09 00:32:42 at
> com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
> 2021-11-09T00:32:42.1379615Z Nov 09 00:32:42 at
> com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
> 2021-11-09T00:32:42.1380668Z Nov 09 00:32:42 at
> com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:63)
> 2021-11-09T00:32:42.1381523Z Nov 09 00:32:42 at
> com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:39)
> 2021-11-09T00:32:42.1382552Z Nov 09 00:32:42 at
> org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase.testCassandraBatchPojoFormat(CassandraConnectorITCase.java:543)
> 2021-11-09T00:32:42.1383487Z Nov 09 00:32:42 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-11-09T00:32:42.1384433Z Nov 09 00:32:42 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-11-09T00:32:42.1385336Z Nov 09 00:32:42 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-11-09T00:32:42.1386119Z Nov 09 00:32:42 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-11-09T00:32:42.1387204Z Nov 09 00:32:42 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2021-11-09T00:32:42.1388225Z Nov 09 00:32:42 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2021-11-09T00:32:42.1389101Z Nov 09 00:32:42 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2021-11-09T00:32:42.1400913Z Nov 09 00:32:42 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2021-11-09T00:32:42.1401588Z Nov 09 00:32:42 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2021-11-09T00:32:42.1402487Z Nov 09 00:32:42 at
> org.apache.flink.testutils.junit.RetryRule$RetryOnExceptionStatement.evaluate(RetryRule.java:192)
> 2021-11-09T00:32:42.1403055Z Nov 09 00:32:42 at
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> 2021-11-09T00:32:42.1403556Z Nov 09 00:32:42 at
> org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
> 2021-11-09T00:32:42.1404008Z Nov 09 00:32:42 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-11-09T00:32:42.1404650Z Nov 09 00:32:42 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2021-11-09T00:32:42.1405151Z Nov 09 00:32:42 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2021-11-09T00:32:42.1405632Z Nov 09 00:32:42 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2021-11-09T00:32:42.1406166Z Nov 09 00:32:42 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2021-11-09T00:32:42.1406670Z Nov 09 00:32:42 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2021-11-09T00:32:42.1407125Z Nov 09 00:32:42 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2021-11-09T00:32:42.1407599Z Nov 09
[jira] [Updated] (FLINK-24345) Translate "File Systems" page of "Internals" into Chinese
[ https://issues.apache.org/jira/browse/FLINK-24345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24345: --- Labels: pull-request-available (was: ) > Translate "File Systems" page of "Internals" into Chinese > - > > Key: FLINK-24345 > URL: https://issues.apache.org/jira/browse/FLINK-24345 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Liebing Yu >Priority: Major > Labels: pull-request-available > > The page url is > https://nightlies.apache.org/flink/flink-docs-master/docs/internals/filesystems/ > The markdown file is located in > flink/docs/content/docs/internals/filesystems.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] MrWhiteSike opened a new pull request #18564: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…
MrWhiteSike opened a new pull request #18564: URL: https://github.com/apache/flink/pull/18564 …o Chinese ## 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 on each deployment (during recovery).)* ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation time as a persistent artifact* - *Deployments RPC transmits only the blob storage reference* - *TaskManagers retrieve the TaskInfo from the blob cache* ## Verifying this change Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing *(Please pick either of the following options)* This change is a trivial rework / code cleanup without any test coverage. *(or)* This change is already covered by existing tests, such as *(please describe tests)*. *(or)* This change added tests and can be verified as follows: *(example:)* - *Added integration tests for end-to-end deployment with large payloads (100MB)* - *Extended integration test for recovery after master (JobManager) failure* - *Added test that validates that TaskInfo is transferred only once across recoveries* - *Manually verified the change by running a 4 node cluser with 2 JobManagers and 4 TaskManagers, a stateful streaming program, and killing one JobManager and two TaskManagers during the execution, verifying that recovery happens correctly.* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / no) - The serializers: (yes / no / don't know) - The runtime per-record code paths (performance sensitive): (yes / no / don't know) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know) - The S3 file system connector: (yes / no / don't know) ## Documentation - Does this pull request introduce a new feature? (yes / no) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484524#comment-17484524
]
Yun Gao commented on FLINK-24119:
-
11.3 KafkaShuffleITCase
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30464=logs=c5612577-f1f7-5977-6ff6-7432788526f7=ffa8837a-b445-534e-cdf4-db364cf8235d=7172
> KafkaITCase.testTimestamps fails due to "Topic xxx already exist"
> -
>
> Key: FLINK-24119
> URL: https://issues.apache.org/jira/browse/FLINK-24119
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.14.0
>Reporter: Xintong Song
>Assignee: Fabian Paul
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23328=logs=c5f0071e-1851-543e-9a45-9ac140befc32=15a22db7-8faa-5b34-3920-d33c9f0ca23c=7419
> {code}
> Sep 01 15:53:20 [ERROR] Tests run: 23, Failures: 1, Errors: 0, Skipped: 0,
> Time elapsed: 162.65 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.kafka.KafkaITCase
> Sep 01 15:53:20 [ERROR] testTimestamps Time elapsed: 23.237 s <<< FAILURE!
> Sep 01 15:53:20 java.lang.AssertionError: Create test topic : tstopic failed,
> org.apache.kafka.common.errors.TopicExistsException: Topic 'tstopic' already
> exists.
> Sep 01 15:53:20 at org.junit.Assert.fail(Assert.java:89)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.createTestTopic(KafkaTestEnvironmentImpl.java:226)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.createTestTopic(KafkaTestEnvironment.java:112)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.createTestTopic(KafkaTestBase.java:212)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaITCase.testTimestamps(KafkaITCase.java:191)
> Sep 01 15:53:20 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Sep 01 15:53:20 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> Sep 01 15:53:20 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> Sep 01 15:53:20 at java.lang.reflect.Method.invoke(Method.java:498)
> Sep 01 15:53:20 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> Sep 01 15:53:20 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> Sep 01 15:53:20 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> Sep 01 15:53:20 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> Sep 01 15:53:20 at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:299)
> Sep 01 15:53:20 at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:293)
> Sep 01 15:53:20 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> Sep 01 15:53:20 at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure
[
https://issues.apache.org/jira/browse/FLINK-25884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484523#comment-17484523
]
Yun Gao commented on FLINK-25884:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30464=logs=8fd975ef-f478-511d-4997-6f15fe8a1fd3=494f6362-8ffa-5ff8-9158-c7f00e541279=27844
> PulsarSourceITCase.testTaskManagerFailure failed on azure
> -
>
> Key: FLINK-25884
> URL: https://issues.apache.org/jira/browse/FLINK-25884
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
>Affects Versions: 1.13.5
>Reporter: Yun Gao
>Priority: Major
> Labels: test-stability
>
> {code:java}
> 022-01-30T04:23:34.0985745Z Jan 30 04:23:34 [ERROR] Tests run: 8, Failures:
> 1, Errors: 0, Skipped: 0, Time elapsed: 146.275 s <<< FAILURE! - in
> org.apache.flink.connector.pulsar.source.PulsarSourceITCase
> 2022-01-30T04:23:34.1007447Z Jan 30 04:23:34 [ERROR]
> testTaskManagerFailure{TestEnvironment, ExternalContext,
> ClusterControllable}[2] Time elapsed: 24.029 s <<< FAILURE!
> 2022-01-30T04:23:34.1008053Z Jan 30 04:23:34 java.lang.AssertionError:
> 2022-01-30T04:23:34.1008387Z Jan 30 04:23:34
> 2022-01-30T04:23:34.1016908Z Jan 30 04:23:34 Expected: Records consumed by
> Flink should be identical to test data and preserve the order in split
> 2022-01-30T04:23:34.1018207Z Jan 30 04:23:34 but: Mismatched record at
> position 35: Expected '0-Xyr234aDNWfV4C55F3Wvxcsm3EkA0Egx3adKqxG' but was
> '0-iFyyNpKte8Lu4wWK8NPz1BFSoc0XYI5yqnemcNr8Wv7avyQqP'
> 2022-01-30T04:23:34.1018923Z Jan 30 04:23:34 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
> 2022-01-30T04:23:34.1019506Z Jan 30 04:23:34 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
> 2022-01-30T04:23:34.1020251Z Jan 30 04:23:34 at
> org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:289)
> 2022-01-30T04:23:34.1020934Z Jan 30 04:23:34 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-01-30T04:23:34.1021596Z Jan 30 04:23:34 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-01-30T04:23:34.1022260Z Jan 30 04:23:34 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-01-30T04:23:34.1022853Z Jan 30 04:23:34 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-01-30T04:23:34.1023453Z Jan 30 04:23:34 at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2022-01-30T04:23:34.1024245Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2022-01-30T04:23:34.1025020Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2022-01-30T04:23:34.1026041Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2022-01-30T04:23:34.1026766Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
> 2022-01-30T04:23:34.1027523Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
> 2022-01-30T04:23:34.1028326Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2022-01-30T04:23:34.1029128Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2022-01-30T04:23:34.1029926Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2022-01-30T04:23:34.1030893Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2022-01-30T04:23:34.1031683Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2022-01-30T04:23:34.1032466Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2022-01-30T04:23:34.1033188Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2022-01-30T04:23:34.1033870Z Jan 30 04:23:34 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2022-01-30T04:23:34.1034612Z Jan 30 04:23:34 at
>
[jira] [Created] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure
Yun Gao created FLINK-25884:
---
Summary: PulsarSourceITCase.testTaskManagerFailure failed on azure
Key: FLINK-25884
URL: https://issues.apache.org/jira/browse/FLINK-25884
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.13.5
Reporter: Yun Gao
{code:java}
022-01-30T04:23:34.0985745Z Jan 30 04:23:34 [ERROR] Tests run: 8, Failures: 1,
Errors: 0, Skipped: 0, Time elapsed: 146.275 s <<< FAILURE! - in
org.apache.flink.connector.pulsar.source.PulsarSourceITCase
2022-01-30T04:23:34.1007447Z Jan 30 04:23:34 [ERROR]
testTaskManagerFailure{TestEnvironment, ExternalContext,
ClusterControllable}[2] Time elapsed: 24.029 s <<< FAILURE!
2022-01-30T04:23:34.1008053Z Jan 30 04:23:34 java.lang.AssertionError:
2022-01-30T04:23:34.1008387Z Jan 30 04:23:34
2022-01-30T04:23:34.1016908Z Jan 30 04:23:34 Expected: Records consumed by
Flink should be identical to test data and preserve the order in split
2022-01-30T04:23:34.1018207Z Jan 30 04:23:34 but: Mismatched record at
position 35: Expected '0-Xyr234aDNWfV4C55F3Wvxcsm3EkA0Egx3adKqxG' but was
'0-iFyyNpKte8Lu4wWK8NPz1BFSoc0XYI5yqnemcNr8Wv7avyQqP'
2022-01-30T04:23:34.1018923Z Jan 30 04:23:34at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
2022-01-30T04:23:34.1019506Z Jan 30 04:23:34at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
2022-01-30T04:23:34.1020251Z Jan 30 04:23:34at
org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:289)
2022-01-30T04:23:34.1020934Z Jan 30 04:23:34at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-01-30T04:23:34.1021596Z Jan 30 04:23:34at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-01-30T04:23:34.1022260Z Jan 30 04:23:34at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-01-30T04:23:34.1022853Z Jan 30 04:23:34at
java.lang.reflect.Method.invoke(Method.java:498)
2022-01-30T04:23:34.1023453Z Jan 30 04:23:34at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
2022-01-30T04:23:34.1024245Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-01-30T04:23:34.1025020Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-01-30T04:23:34.1026041Z Jan 30 04:23:34at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2022-01-30T04:23:34.1026766Z Jan 30 04:23:34at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2022-01-30T04:23:34.1027523Z Jan 30 04:23:34at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2022-01-30T04:23:34.1028326Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2022-01-30T04:23:34.1029128Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2022-01-30T04:23:34.1029926Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-01-30T04:23:34.1030893Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-01-30T04:23:34.1031683Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-01-30T04:23:34.1032466Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-01-30T04:23:34.1033188Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2022-01-30T04:23:34.1033870Z Jan 30 04:23:34at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2022-01-30T04:23:34.1034612Z Jan 30 04:23:34at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
2022-01-30T04:23:34.1035407Z Jan 30 04:23:34at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-01-30T04:23:34.1036188Z Jan 30 04:23:34at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
2022-01-30T04:23:34.1036961Z Jan 30 04:23:34at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484520#comment-17484520
]
Yun Gao commented on FLINK-24119:
-
1.13 KafkaSourceLegacyITCase
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30464=logs=c5f0071e-1851-543e-9a45-9ac140befc32=15a22db7-8faa-5b34-3920-d33c9f0ca23c=7646
> KafkaITCase.testTimestamps fails due to "Topic xxx already exist"
> -
>
> Key: FLINK-24119
> URL: https://issues.apache.org/jira/browse/FLINK-24119
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.14.0
>Reporter: Xintong Song
>Assignee: Fabian Paul
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23328=logs=c5f0071e-1851-543e-9a45-9ac140befc32=15a22db7-8faa-5b34-3920-d33c9f0ca23c=7419
> {code}
> Sep 01 15:53:20 [ERROR] Tests run: 23, Failures: 1, Errors: 0, Skipped: 0,
> Time elapsed: 162.65 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.kafka.KafkaITCase
> Sep 01 15:53:20 [ERROR] testTimestamps Time elapsed: 23.237 s <<< FAILURE!
> Sep 01 15:53:20 java.lang.AssertionError: Create test topic : tstopic failed,
> org.apache.kafka.common.errors.TopicExistsException: Topic 'tstopic' already
> exists.
> Sep 01 15:53:20 at org.junit.Assert.fail(Assert.java:89)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.createTestTopic(KafkaTestEnvironmentImpl.java:226)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.createTestTopic(KafkaTestEnvironment.java:112)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.createTestTopic(KafkaTestBase.java:212)
> Sep 01 15:53:20 at
> org.apache.flink.streaming.connectors.kafka.KafkaITCase.testTimestamps(KafkaITCase.java:191)
> Sep 01 15:53:20 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Sep 01 15:53:20 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> Sep 01 15:53:20 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> Sep 01 15:53:20 at java.lang.reflect.Method.invoke(Method.java:498)
> Sep 01 15:53:20 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> Sep 01 15:53:20 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> Sep 01 15:53:20 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> Sep 01 15:53:20 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> Sep 01 15:53:20 at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:299)
> Sep 01 15:53:20 at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:293)
> Sep 01 15:53:20 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> Sep 01 15:53:20 at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable Application/Per-job mode on YARN to use usrlib
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 3f40a37a2124c9627b9b839e2cce9f4d2d7edba9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30482) * 5eb98df7422ffca67eb4d258189ff1eadb36731e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30492) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable Application/Per-job mode on YARN to use usrlib
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 3f40a37a2124c9627b9b839e2cce9f4d2d7edba9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30482) * 5eb98df7422ffca67eb4d258189ff1eadb36731e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-23687) Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys
[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484491#comment-17484491 ] WilliamSong commented on FLINK-23687: - hi [~jingzhang] , Happy Spring Festival , May I ask if you are in charge of blink related development work now . Can I get involved, the current Flip or the related Flink later . Can we communicate on wechat . wechat / _DingTalk_ : 13521869069 > Introduce partitioned lookup join to enforce input of LookupJoin to hash > shuffle by lookup keys > --- > > Key: FLINK-23687 > URL: https://issues.apache.org/jira/browse/FLINK-23687 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / Planner >Reporter: Jing Zhang >Assignee: Jing Zhang >Priority: Major > Labels: pull-request-available > > Add Sql query hint to enable LookupJoin shuffle by join key of left input -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large
[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484487#comment-17484487 ] Kyle edited comment on FLINK-25670 at 1/31/22, 3:12 AM: Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? If sharding request if needed, how could we make large state partitioned in StateFun cluster and sent/received by remote function? Thanks in advance. was (Author: JIRAUSER283693): Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? If sharding request if needed, how could we make large state partitioned in StateFun cluster? Thanks in advance. > StateFun: Unable to handle oversize HTTP message if state size is large > --- > > Key: FLINK-25670 > URL: https://issues.apache.org/jira/browse/FLINK-25670 > Project: Flink > Issue Type: Bug > Components: Stateful Functions >Affects Versions: statefun-3.1.1 >Reporter: Kyle >Priority: Major > Attachments: 00-module.yaml, functions.py > > > Per requirement we need to handle state which is about 500MB large (72MB > state allocated in commented code as attached). However the HTTP message > limit disallows us to send back large state to StateFun cluster after saving > state in Stateful Function. > Another question is whether large data is allowed to send to Stateful > Function from ingress. > > 2022-01-17 07:57:18,416 WARN > org.apache.flink.statefun.flink.core.nettyclient.NettyRequest [] - Exception > caught while trying to deliver a message: (attempt > #10)ToFunctionRequestSummary(address=Address(example, hello, ), > batchSize=1, totalSizeInBytes=80, numberOfStates=2) > org.apache.flink.shaded.netty4.io.netty.handler.codec.TooLongFrameException: > Response entity too large: DefaultHttpResponse(decodeResult: success, > version: HTTP/1.1) > HTTP/1.1 200 OK > Content-Type: application/octet-stream > Content-Length: 40579630 > Date: Mon, 17 Jan 2022 07:57:18 GMT > Server: Python/3.9 aiohttp/3.8.1 > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:276) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:87) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.invokeHandleOversizedMessage(MessageAggregator.java:404) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.decode(MessageAggregator.java:254) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:88) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at >
[jira] [Comment Edited] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large
[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484487#comment-17484487 ] Kyle edited comment on FLINK-25670 at 1/31/22, 3:11 AM: Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? If sharding request if needed, how could we make large state partitioned in StateFun cluster? Thanks in advance. was (Author: JIRAUSER283693): Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? How could we shard the request and make large state partitioned in StateFun cluster? Thanks in advance. > StateFun: Unable to handle oversize HTTP message if state size is large > --- > > Key: FLINK-25670 > URL: https://issues.apache.org/jira/browse/FLINK-25670 > Project: Flink > Issue Type: Bug > Components: Stateful Functions >Affects Versions: statefun-3.1.1 >Reporter: Kyle >Priority: Major > Attachments: 00-module.yaml, functions.py > > > Per requirement we need to handle state which is about 500MB large (72MB > state allocated in commented code as attached). However the HTTP message > limit disallows us to send back large state to StateFun cluster after saving > state in Stateful Function. > Another question is whether large data is allowed to send to Stateful > Function from ingress. > > 2022-01-17 07:57:18,416 WARN > org.apache.flink.statefun.flink.core.nettyclient.NettyRequest [] - Exception > caught while trying to deliver a message: (attempt > #10)ToFunctionRequestSummary(address=Address(example, hello, ), > batchSize=1, totalSizeInBytes=80, numberOfStates=2) > org.apache.flink.shaded.netty4.io.netty.handler.codec.TooLongFrameException: > Response entity too large: DefaultHttpResponse(decodeResult: success, > version: HTTP/1.1) > HTTP/1.1 200 OK > Content-Type: application/octet-stream > Content-Length: 40579630 > Date: Mon, 17 Jan 2022 07:57:18 GMT > Server: Python/3.9 aiohttp/3.8.1 > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:276) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:87) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.invokeHandleOversizedMessage(MessageAggregator.java:404) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.decode(MessageAggregator.java:254) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:88) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at >
[jira] [Comment Edited] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large
[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484487#comment-17484487 ] Kyle edited comment on FLINK-25670 at 1/31/22, 3:10 AM: Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? How could we shard the request and make large state partitioned in StateFun cluster? Thanks in advance. was (Author: JIRAUSER283693): Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? How could we shard the request and make large state partitioned in StateFun cluster? > StateFun: Unable to handle oversize HTTP message if state size is large > --- > > Key: FLINK-25670 > URL: https://issues.apache.org/jira/browse/FLINK-25670 > Project: Flink > Issue Type: Bug > Components: Stateful Functions >Affects Versions: statefun-3.1.1 >Reporter: Kyle >Priority: Major > Attachments: 00-module.yaml, functions.py > > > Per requirement we need to handle state which is about 500MB large (72MB > state allocated in commented code as attached). However the HTTP message > limit disallows us to send back large state to StateFun cluster after saving > state in Stateful Function. > Another question is whether large data is allowed to send to Stateful > Function from ingress. > > 2022-01-17 07:57:18,416 WARN > org.apache.flink.statefun.flink.core.nettyclient.NettyRequest [] - Exception > caught while trying to deliver a message: (attempt > #10)ToFunctionRequestSummary(address=Address(example, hello, ), > batchSize=1, totalSizeInBytes=80, numberOfStates=2) > org.apache.flink.shaded.netty4.io.netty.handler.codec.TooLongFrameException: > Response entity too large: DefaultHttpResponse(decodeResult: success, > version: HTTP/1.1) > HTTP/1.1 200 OK > Content-Type: application/octet-stream > Content-Length: 40579630 > Date: Mon, 17 Jan 2022 07:57:18 GMT > Server: Python/3.9 aiohttp/3.8.1 > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:276) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:87) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.invokeHandleOversizedMessage(MessageAggregator.java:404) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.decode(MessageAggregator.java:254) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:88) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at >
[jira] [Commented] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large
[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484487#comment-17484487 ] Kyle commented on FLINK-25670: -- Actually we are going to handle about 9 * 100 = 9,000,000 doubles (72MB) received every 15 minutes. During processing, 9,000,000 * 6 = 54,000,000 doubles (432MB) are retrieved and updated. We'd like to make the 432MB data as state with high performance and guaranteed correctness. If they are kept in external storage (e.g. S3/HDFS), then they could be saved into external storage directly and it is not necessary to leverage StateFun or Flink. What is your further suggestion? How could we shard the request and make large state partitioned in StateFun cluster? > StateFun: Unable to handle oversize HTTP message if state size is large > --- > > Key: FLINK-25670 > URL: https://issues.apache.org/jira/browse/FLINK-25670 > Project: Flink > Issue Type: Bug > Components: Stateful Functions >Affects Versions: statefun-3.1.1 >Reporter: Kyle >Priority: Major > Attachments: 00-module.yaml, functions.py > > > Per requirement we need to handle state which is about 500MB large (72MB > state allocated in commented code as attached). However the HTTP message > limit disallows us to send back large state to StateFun cluster after saving > state in Stateful Function. > Another question is whether large data is allowed to send to Stateful > Function from ingress. > > 2022-01-17 07:57:18,416 WARN > org.apache.flink.statefun.flink.core.nettyclient.NettyRequest [] - Exception > caught while trying to deliver a message: (attempt > #10)ToFunctionRequestSummary(address=Address(example, hello, ), > batchSize=1, totalSizeInBytes=80, numberOfStates=2) > org.apache.flink.shaded.netty4.io.netty.handler.codec.TooLongFrameException: > Response entity too large: DefaultHttpResponse(decodeResult: success, > version: HTTP/1.1) > HTTP/1.1 200 OK > Content-Type: application/octet-stream > Content-Length: 40579630 > Date: Mon, 17 Jan 2022 07:57:18 GMT > Server: Python/3.9 aiohttp/3.8.1 > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:276) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator.handleOversizedMessage(HttpObjectAggregator.java:87) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.invokeHandleOversizedMessage(MessageAggregator.java:404) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageAggregator.decode(MessageAggregator.java:254) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:88) > ~[statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) > [statefun-flink-distribution.jar:3.1.1] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324) > [statefun-flink-distribution.jar:3.1.1] > at >
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0e55b5a359ccfa668aa9c783be63962c61ad0d13 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30488) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-25835) The task initialization duration is recorded in logs
[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484481#comment-17484481 ] Bo Cui commented on FLINK-25835: [~yunta] hi The Task initialization log will only be printed once, and we can also see the initialization time of the custom operator, not just the statebackend, so I think we need to print the log here. > The task initialization duration is recorded in logs > > > Key: FLINK-25835 > URL: https://issues.apache.org/jira/browse/FLINK-25835 > Project: Flink > Issue Type: Improvement > Components: Runtime / State Backends >Affects Versions: 1.12.2, 1.15.0 >Reporter: Bo Cui >Priority: Major > Labels: pull-request-available > > [https://github.com/apache/flink/blob/a543e658acfbc22c1579df0d043654037b9ec4b0/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L644] > We are testing the time of state backend initialization for different data > levels.However, the task initialization time cannot be obtained from the log > file and the time taken to restore the status at the backend cannot be > obtained. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25835) The task initialization duration is recorded in logs
[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484481#comment-17484481 ] Bo Cui edited comment on FLINK-25835 at 1/31/22, 12:55 AM: --- [~yunta] hi The Task initialization log will only be printed once, and we can also see the initialization time of the custom operator, not just the statebackend, so I think we need to print the log here. was (Author: bo cui): [~yunta] hi The Task initialization log will only be printed once, and we can also see the initialization time of the custom operator, not just the statebackend, so I think we need to print the log here. > The task initialization duration is recorded in logs > > > Key: FLINK-25835 > URL: https://issues.apache.org/jira/browse/FLINK-25835 > Project: Flink > Issue Type: Improvement > Components: Runtime / State Backends >Affects Versions: 1.12.2, 1.15.0 >Reporter: Bo Cui >Priority: Major > Labels: pull-request-available > > [https://github.com/apache/flink/blob/a543e658acfbc22c1579df0d043654037b9ec4b0/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L644] > We are testing the time of state backend initialization for different data > levels.However, the task initialization time cannot be obtained from the log > file and the time taken to restore the status at the backend cannot be > obtained. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25883) The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
[
https://issues.apache.org/jira/browse/FLINK-25883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail updated FLINK-25883:
Description:
In [this
line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
315360. This is more than the default value of threading.TIMEOUT_MAX on
Windows Python. Due to this, "OverflowError: timeout value is too large" error
is produced.
Full traceback:
{code:java}
File
"G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not self._finished.wait(next_call - time.time()):
File "C:\Python38\lib\threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "C:\Python38\lib\threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large{code}
was:
In [this
line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
315360. This is more than the default value of threading.TIMEOUT_MAX on
Windows Python. Due to this, "OverflowError: timeout value is too large" error
is produced.
Full traceback:
File
"G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not self._finished.wait(next_call - time.time()):
File "C:\Python38\lib\threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "C:\Python38\lib\threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large
> The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
> --
>
> Key: FLINK-25883
> URL: https://issues.apache.org/jira/browse/FLINK-25883
> Project: Flink
> Issue Type: Bug
> Environment: Windows, Python 3.8
>Reporter: Mikhail
>Priority: Minor
>
> In [this
> line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
> the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
> 315360. This is more than the default value of threading.TIMEOUT_MAX on
> Windows Python. Due to this, "OverflowError: timeout value is too large"
> error is produced.
> Full traceback:
> {code:java}
> File
> "G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
> line 218, in run
> while not self._finished.wait(next_call - time.time()):
> File "C:\Python38\lib\threading.py", line 558, in wait
> signaled = self._cond.wait(timeout)
> File "C:\Python38\lib\threading.py", line 306, in wait
> gotit = waiter.acquire(True, timeout)
> OverflowError: timeout value is too large{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-25883) The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
[
https://issues.apache.org/jira/browse/FLINK-25883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail updated FLINK-25883:
Description:
In [this
line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
315360. This is more than the default value of threading.TIMEOUT_MAX on
Windows Python, which is 4294967. Due to this, "OverflowError: timeout value is
too large" error is produced.
Full traceback:
{code:java}
File
"G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not self._finished.wait(next_call - time.time()):
File "C:\Python38\lib\threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "C:\Python38\lib\threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large{code}
was:
In [this
line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
315360. This is more than the default value of threading.TIMEOUT_MAX on
Windows Python. Due to this, "OverflowError: timeout value is too large" error
is produced.
Full traceback:
{code:java}
File
"G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not self._finished.wait(next_call - time.time()):
File "C:\Python38\lib\threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "C:\Python38\lib\threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large{code}
> The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
> --
>
> Key: FLINK-25883
> URL: https://issues.apache.org/jira/browse/FLINK-25883
> Project: Flink
> Issue Type: Bug
> Environment: Windows, Python 3.8
>Reporter: Mikhail
>Priority: Minor
>
> In [this
> line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
> the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
> 315360. This is more than the default value of threading.TIMEOUT_MAX on
> Windows Python, which is 4294967. Due to this, "OverflowError: timeout value
> is too large" error is produced.
> Full traceback:
> {code:java}
> File
> "G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
> line 218, in run
> while not self._finished.wait(next_call - time.time()):
> File "C:\Python38\lib\threading.py", line 558, in wait
> signaled = self._cond.wait(timeout)
> File "C:\Python38\lib\threading.py", line 306, in wait
> gotit = waiter.acquire(True, timeout)
> OverflowError: timeout value is too large{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-25883) The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
[
https://issues.apache.org/jira/browse/FLINK-25883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail updated FLINK-25883:
Description:
In [this
line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
315360. This is more than the default value of threading.TIMEOUT_MAX on
Windows Python. Due to this, "OverflowError: timeout value is too large" error
is produced.
Full traceback:
{code:java}
File
"G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not self._finished.wait(next_call - time.time()):
File "C:\Python38\lib\threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "C:\Python38\lib\threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large{code}
was:
In [this
line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
315360. This is more than the default value of threading.TIMEOUT_MAX on
Windows Python. Due to this, "OverflowError: timeout value is too large" error
is produced.
Full traceback:
{code:java}
File
"G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not self._finished.wait(next_call - time.time()):
File "C:\Python38\lib\threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "C:\Python38\lib\threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large{code}
> The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
> --
>
> Key: FLINK-25883
> URL: https://issues.apache.org/jira/browse/FLINK-25883
> Project: Flink
> Issue Type: Bug
> Environment: Windows, Python 3.8
>Reporter: Mikhail
>Priority: Minor
>
> In [this
> line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30],
> the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to
> 315360. This is more than the default value of threading.TIMEOUT_MAX on
> Windows Python. Due to this, "OverflowError: timeout value is too large"
> error is produced.
> Full traceback:
> {code:java}
> File
> "G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py",
> line 218, in run
> while not self._finished.wait(next_call - time.time()):
> File "C:\Python38\lib\threading.py", line 558, in wait
> signaled = self._cond.wait(timeout)
> File "C:\Python38\lib\threading.py", line 306, in wait
> gotit = waiter.acquire(True, timeout)
> OverflowError: timeout value is too large{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Created] (FLINK-25883) The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large
Mikhail created FLINK-25883: --- Summary: The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large Key: FLINK-25883 URL: https://issues.apache.org/jira/browse/FLINK-25883 Project: Flink Issue Type: Bug Environment: Windows, Python 3.8 Reporter: Mikhail In [this line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30], the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to 315360. This is more than the default value of threading.TIMEOUT_MAX on Windows Python. Due to this, "OverflowError: timeout value is too large" error is produced. Full traceback: File "G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py", line 218, in run while not self._finished.wait(next_call - time.time()): File "C:\Python38\lib\threading.py", line 558, in wait signaled = self._cond.wait(timeout) File "C:\Python38\lib\threading.py", line 306, in wait gotit = waiter.acquire(True, timeout) OverflowError: timeout value is too large -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable
[
https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484473#comment-17484473
]
Yufan Sheng commented on FLINK-23944:
-
Finally, I think I have found the real cause for this issue. It was a mistake
in my test tool class `PulsarRuntimeOperator`.
I wouldn't recreate the existed topic. Instead, I would clean the messages on
this topic. But the method I used for cleaning messages could be wrong. It
asynchronously removes the messages. So the consumed records could be wrong
when the test machine is a bit slow.
> PulsarSourceITCase.testTaskManagerFailure is instable
> -
>
> Key: FLINK-23944
> URL: https://issues.apache.org/jira/browse/FLINK-23944
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
>Affects Versions: 1.14.0
>Reporter: Dian Fu
>Assignee: Yufei Zhang
>Priority: Critical
> Labels: pull-request-available, test-stability
> Fix For: 1.15.0
>
>
> [https://dev.azure.com/dianfu/Flink/_build/results?buildId=430=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d]
> It's from my personal azure pipeline, however, I'm pretty sure that I have
> not touched any code related to this.
> {code:java}
> Aug 24 10:44:13 [ERROR] testTaskManagerFailure{TestEnvironment,
> ExternalContext, ClusterControllable}[1] Time elapsed: 258.397 s <<< FAILURE!
> Aug 24 10:44:13 java.lang.AssertionError: Aug 24 10:44:13 Aug 24 10:44:13
> Expected: Records consumed by Flink should be identical to test data and
> preserve the order in split Aug 24 10:44:13 but: Mismatched record at
> position 7: Expected '0W6SzacX7MNL4xLL3BZ8C3ljho4iCydbvxIl' but was
> 'wVi5JaJpNvgkDEOBRC775qHgw0LyRW2HBxwLmfONeEmr' Aug 24 10:44:13 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) Aug 24 10:44:13
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8) Aug 24
> 10:44:13 at
> org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:271)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 054ffb84a4dab1330d23e1a3309b2ca324b26e3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30487) * 0e55b5a359ccfa668aa9c783be63962c61ad0d13 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30488) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 054ffb84a4dab1330d23e1a3309b2ca324b26e3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30487) * 0e55b5a359ccfa668aa9c783be63962c61ad0d13 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 054ffb84a4dab1330d23e1a3309b2ca324b26e3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30487) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18563: Fix the java example in interval-join
flinkbot edited a comment on pull request #18563: URL: https://github.com/apache/flink/pull/18563#issuecomment-1025217420 ## CI report: * f3ed7b176c1005171f2f9a19623bb164cafcf66d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30486) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * 054ffb84a4dab1330d23e1a3309b2ca324b26e3d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30487) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * 054ffb84a4dab1330d23e1a3309b2ca324b26e3d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30487) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * 054ffb84a4dab1330d23e1a3309b2ca324b26e3d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * cbe30d48f2df59f78de1b9adfd166a77f57c92c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * cbe30d48f2df59f78de1b9adfd166a77f57c92c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * cbe30d48f2df59f78de1b9adfd166a77f57c92c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * cbe30d48f2df59f78de1b9adfd166a77f57c92c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * cbe30d48f2df59f78de1b9adfd166a77f57c92c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * cbe30d48f2df59f78de1b9adfd166a77f57c92c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18563: Fix the java example in interval-join
flinkbot edited a comment on pull request #18563: URL: https://github.com/apache/flink/pull/18563#issuecomment-1025217420 ## CI report: * f3ed7b176c1005171f2f9a19623bb164cafcf66d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30486) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #18563: fix typo in example
flinkbot commented on pull request #18563: URL: https://github.com/apache/flink/pull/18563#issuecomment-1025217680 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the progress of the review. ## Automated Checks Last check on commit f3ed7b176c1005171f2f9a19623bb164cafcf66d (Sun Jan 30 19:51:59 UTC 2022) **Warnings:** * Documentation files were touched, but no `docs/content.zh/` files: Update Chinese documentation or file Jira ticket. * **Invalid pull request title: No valid Jira ID provided** Mention the bot in a comment to re-run the automated checks. ## Review Progress * ❓ 1. The [description] looks good. * ❓ 2. There is [consensus] that the contribution should go into to Flink. * ❓ 3. Needs [attention] from. * ❓ 4. The change fits into the overall [architecture]. * ❓ 5. Overall code [quality] is good. Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commands The @flinkbot bot supports the following commands: - `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`) - `@flinkbot approve all` to approve all aspects - `@flinkbot approve-until architecture` to approve everything until `architecture` - `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention - `@flinkbot disapprove architecture` to remove an approval you gave earlier -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #18563: fix typo in example
flinkbot commented on pull request #18563: URL: https://github.com/apache/flink/pull/18563#issuecomment-1025217420 ## CI report: * f3ed7b176c1005171f2f9a19623bb164cafcf66d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * 48357d9d1cfb071f7c4c387594f284100b48e104 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] tiraffe opened a new pull request #18563: fix typo in example
tiraffe opened a new pull request #18563: URL: https://github.com/apache/flink/pull/18563 ## 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 on each deployment (during recovery).)* ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation time as a persistent artifact* - *Deployments RPC transmits only the blob storage reference* - *TaskManagers retrieve the TaskInfo from the blob cache* ## Verifying this change Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing *(Please pick either of the following options)* This change is a trivial rework / code cleanup without any test coverage. *(or)* This change is already covered by existing tests, such as *(please describe tests)*. *(or)* This change added tests and can be verified as follows: *(example:)* - *Added integration tests for end-to-end deployment with large payloads (100MB)* - *Extended integration test for recovery after master (JobManager) failure* - *Added test that validates that TaskInfo is transferred only once across recoveries* - *Manually verified the change by running a 4 node cluser with 2 JobManagers and 4 TaskManagers, a stateful streaming program, and killing one JobManager and two TaskManagers during the execution, verifying that recovery happens correctly.* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / no) - The serializers: (yes / no / don't know) - The runtime per-record code paths (performance sensitive): (yes / no / don't know) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know) - The S3 file system connector: (yes / no / don't know) ## Documentation - Does this pull request introduce a new feature? (yes / no) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * 48357d9d1cfb071f7c4c387594f284100b48e104 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) * 48357d9d1cfb071f7c4c387594f284100b48e104 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30485) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a409ce5dbaffb0b41f31dfe4ed059d31ba7a486 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30463) * 067d456df50b5cd5889cfa299b6b81b4da172626 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-25874) PyFlink package dependencies conflict
[
https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484416#comment-17484416
]
Martin Liu commented on FLINK-25874:
[~hxbks2ks] [~nicholasjiang] Thanks for quick response, I created a PR
[https://github.com/apache/flink/pull/18561] for this, can you take a look?
> PyFlink package dependencies conflict
> -
>
> Key: FLINK-25874
> URL: https://issues.apache.org/jira/browse/FLINK-25874
> Project: Flink
> Issue Type: Improvement
>Reporter: Martin Liu
>Priority: Blocker
> Labels: pull-request-available
>
> I need to install PyFlink with some other libraries in a project, and I found
> there's dependency conflict with `great-expectations` because PyFlink has
> pined dependency `python-dateutil==2.8.0`.
> {code:java}
> There are incompatible versions in the resolved dependencies:
> python-dateutil==2.8.0 (from apache-flink==1.14.3->-r requirements.in (line
> 4))
> python-dateutil>=2.8.1 (from great-expectations==0.14.4->-r requirements.in
> (line 5)) {code}
> I have to use newer version of great-expectations (>=0.13.1) for some
> features, so this is blocking me.
> I found `python-dateutil` v2.8.0 is released in 2019-02-05, see
> [https://github.com/dateutil/dateutil/releases/tag/2.8.0], is there any way
> to loose the dependency, e.g. >=2.8.0 ?
> (BTW, `cloudpickle==1.2.2` is also old which released in 2019-09-10, see
> [https://github.com/cloudpipe/cloudpickle/releases/tag/v1.2.2] )
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] martin-liu commented on pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'
martin-liu commented on pull request #18561: URL: https://github.com/apache/flink/pull/18561#issuecomment-1025199385 @HuangXingBo Can you take a look? Thanks! -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-25882) Translate updated privacy policy to Chinese
[
https://issues.apache.org/jira/browse/FLINK-25882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484406#comment-17484406
]
Yubin Li commented on FLINK-25882:
--
Hi, Could you please assign this to me? thanks!
> Translate updated privacy policy to Chinese
> ---
>
> Key: FLINK-25882
> URL: https://issues.apache.org/jira/browse/FLINK-25882
> Project: Flink
> Issue Type: Sub-task
> Components: Project Website
>Reporter: Martijn Visser
>Priority: Major
> Labels: chinese-translation
>
> After https://github.com/apache/flink-web/pull/503 is merged, it requires
> {{privacy-policy.zh.md}} to be translated to Chinese.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable Application/Per-job mode on YARN to use usrlib
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 3f40a37a2124c9627b9b839e2cce9f4d2d7edba9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30482) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Comment Edited] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes
[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484182#comment-17484182 ] Till Rohrmann edited comment on FLINK-25486 at 1/30/22, 4:23 PM: - Fixed via 1.15.0: 8ba13f37afb9164f3bb17de78c4b0d85b1633638 1.14.4: 0b519c24222f61306f9faba2389c0958daa9cc0a 1.13.6: fe5a1718368e62eb7ac47c00aabbd94173dae668 was (Author: till.rohrmann): Fixed via 1.15.0: 8ba13f37afb9164f3bb17de78c4b0d85b1633638 1.14.4: (will be added) 1.13.6: (will be added) > Perjob can not recover from checkpoint when zookeeper leader changes > > > Key: FLINK-25486 > URL: https://issues.apache.org/jira/browse/FLINK-25486 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination >Affects Versions: 1.15.0, 1.13.5, 1.14.2 >Reporter: Liu >Assignee: Liu >Priority: Blocker > Labels: pull-request-available > Fix For: 1.15.0, 1.13.6, 1.14.4 > > > When the config > high-availability.zookeeper.client.tolerate-suspended-connections is default > false, the appMaster will failover once zk leader changes. In this case, the > old appMaster will clean up all the zk info and the new appMaster will not > recover from the latest checkpoint. > The process is as following: > # Start a perJob application. > # kill zk's leade node which cause the perJob to suspend. > # In MiniDispatcher's function jobReachedTerminalState, shutDownFuture is > set to UNKNOWN . > # The future is transferred to ClusterEntrypoint, the method is called with > cleanupHaData true. > # Clean up zk data and exit. > # The new appMaster will not find any checkpoints to start and the state is > lost. > Since the job can recover automatically when the zk leader changes, it is > reasonable to keep zk info for the coming recovery. > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] tillrohrmann merged pull request #18559: [BP-1.14][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes
tillrohrmann merged pull request #18559: URL: https://github.com/apache/flink/pull/18559 -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] tillrohrmann closed pull request #18560: [BP-1.13][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes
tillrohrmann closed pull request #18560: URL: https://github.com/apache/flink/pull/18560 -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18560: [BP-1.13][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes
flinkbot edited a comment on pull request #18560: URL: https://github.com/apache/flink/pull/18560#issuecomment-1024935636 ## CI report: * 965155a54839fae3143ca194fdbe59fa76e9b275 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30480) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18562: [MINOR] ResourceManager_Refactor
flinkbot edited a comment on pull request #18562: URL: https://github.com/apache/flink/pull/18562#issuecomment-1025140068 ## CI report: * 459a41a35a5c561c08a6a1c4675515b2f370048a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30481) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable Application/Per-job mode on YARN to use usrlib
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * b5b32982734f41ea6f6c8693f2a62585de39b408 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30397) * 3f40a37a2124c9627b9b839e2cce9f4d2d7edba9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30482) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable Application/Per-job mode on YARN to use usrlib
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * b5b32982734f41ea6f6c8693f2a62585de39b408 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30397) * 3f40a37a2124c9627b9b839e2cce9f4d2d7edba9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-21232: -- Labels: security (was: ) > Introduce pluggable Hadoop delegation token providers > - > > Key: FLINK-21232 > URL: https://issues.apache.org/jira/browse/FLINK-21232 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common, Deployment / Kubernetes, Deployment > / YARN >Affects Versions: 1.15.0 >Reporter: jackwangcs >Assignee: Gabor Somogyi >Priority: Major > Labels: security > > Introduce a pluggable delegation provider via SPI. > Delegation provider could be placed in connector related code and is more > extendable comparing using reflection way to obtain DTs. > Email dicussion thread: > [https://lists.apache.org/thread.html/rbedb6e769358a10c6426c4c42b3b51cdbed48a3b6537e4ebde912bc0%40%3Cdev.flink.apache.org%3E] > > [https://lists.apache.org/thread.html/r20d4be431ff2f6faff94129b5321a047fcbb0c71c8e092504cd91183%40%3Cdev.flink.apache.org%3E] > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-21232: -- Labels: (was: auto-unassigned pull-request-available) > Introduce pluggable Hadoop delegation token providers > - > > Key: FLINK-21232 > URL: https://issues.apache.org/jira/browse/FLINK-21232 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common, Deployment / Kubernetes, Deployment > / YARN >Affects Versions: 1.15.0 >Reporter: jackwangcs >Assignee: Gabor Somogyi >Priority: Major > > Introduce a pluggable delegation provider via SPI. > Delegation provider could be placed in connector related code and is more > extendable comparing using reflection way to obtain DTs. > Email dicussion thread: > [https://lists.apache.org/thread.html/rbedb6e769358a10c6426c4c42b3b51cdbed48a3b6537e4ebde912bc0%40%3Cdev.flink.apache.org%3E] > > [https://lists.apache.org/thread.html/r20d4be431ff2f6faff94129b5321a047fcbb0c71c8e092504cd91183%40%3Cdev.flink.apache.org%3E] > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18559: [BP-1.14][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes
flinkbot edited a comment on pull request #18559: URL: https://github.com/apache/flink/pull/18559#issuecomment-1024935073 ## CI report: * 440967fa0b1ba42ee2c0b72fab35729aa543f333 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30477) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 8813b2eec4b0004ac1a180c92ce6fbc5604d898d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30467) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Assigned] (FLINK-25880) Implement Matomo in Flink documentation
[ https://issues.apache.org/jira/browse/FLINK-25880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25880: -- Assignee: Martijn Visser > Implement Matomo in Flink documentation > --- > > Key: FLINK-25880 > URL: https://issues.apache.org/jira/browse/FLINK-25880 > Project: Flink > Issue Type: Sub-task > Components: Documentation >Reporter: Martijn Visser >Assignee: Martijn Visser >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Assigned] (FLINK-25878) Update privacy policy to reflect change from Google Analytics to Matomo
[ https://issues.apache.org/jira/browse/FLINK-25878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25878: -- Assignee: Martijn Visser > Update privacy policy to reflect change from Google Analytics to Matomo > --- > > Key: FLINK-25878 > URL: https://issues.apache.org/jira/browse/FLINK-25878 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Project Website >Reporter: Martijn Visser >Assignee: Martijn Visser >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Assigned] (FLINK-25879) Track used search terms in Matomo
[ https://issues.apache.org/jira/browse/FLINK-25879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25879: -- Assignee: Martijn Visser > Track used search terms in Matomo > - > > Key: FLINK-25879 > URL: https://issues.apache.org/jira/browse/FLINK-25879 > Project: Flink > Issue Type: Sub-task > Components: Documentation >Reporter: Martijn Visser >Assignee: Martijn Visser >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Assigned] (FLINK-25881) Measure visits on flink.apache.org and nightlies.apache.org/flink as the same visit
[ https://issues.apache.org/jira/browse/FLINK-25881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25881: -- Assignee: Martijn Visser > Measure visits on flink.apache.org and nightlies.apache.org/flink as the same > visit > --- > > Key: FLINK-25881 > URL: https://issues.apache.org/jira/browse/FLINK-25881 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Project Website >Reporter: Martijn Visser >Assignee: Martijn Visser >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25882) Translate updated privacy policy to Chinese
[
https://issues.apache.org/jira/browse/FLINK-25882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25882:
---
Description: After https://github.com/apache/flink-web/pull/503 is merged,
it requires {{privacy-policy.zh.md}} to be translated to Chinese.
> Translate updated privacy policy to Chinese
> ---
>
> Key: FLINK-25882
> URL: https://issues.apache.org/jira/browse/FLINK-25882
> Project: Flink
> Issue Type: Sub-task
> Components: Project Website
>Reporter: Martijn Visser
>Priority: Major
> Labels: chinese-translation
>
> After https://github.com/apache/flink-web/pull/503 is merged, it requires
> {{privacy-policy.zh.md}} to be translated to Chinese.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Created] (FLINK-25882) Translate updated privacy policy to Chinese
Martijn Visser created FLINK-25882: -- Summary: Translate updated privacy policy to Chinese Key: FLINK-25882 URL: https://issues.apache.org/jira/browse/FLINK-25882 Project: Flink Issue Type: Sub-task Components: Project Website Reporter: Martijn Visser -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink-web] MartijnVisser opened a new pull request #503: Subdomain tracking and privacy policy
MartijnVisser opened a new pull request #503: URL: https://github.com/apache/flink-web/pull/503 This PR addresses two things: * e2377218c6ed9a8be3ae6e257776c8f08457ea96 makes sure that visits to flink.apache.org and nightlies.apache.org/flink are recognized from one to another * 01f687376764106696efce2ea056ba54f68e7ae4 updates the privacy policy, removes all references to Google Analytics and includes and opt-out. Since there was no Chinese translation, the English version is now also available. https://issues.apache.org/jira/browse/FLINK-25882 has been created for a Chinese translation, after this PR is approved and merged. -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] Airblader commented on pull request #18537: [FLINK-25852][Connectors] Annotate SourceFunction and SinkFunction as deprecated
Airblader commented on pull request #18537: URL: https://github.com/apache/flink/pull/18537#issuecomment-1025145469 The new Sink interface is still marked experimental. I find it somewhat odd that the stable API is deprecated before its replacement is semi-stable (or even stable). -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 8813b2eec4b0004ac1a180c92ce6fbc5604d898d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30467) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * c2edf18f8b15d31568a71eaf0df79de904982e84 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30479) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 8813b2eec4b0004ac1a180c92ce6fbc5604d898d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30467) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] TanYuxin-tyx removed a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock
TanYuxin-tyx removed a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1025046217 @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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] TanYuxin-tyx commented on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock
TanYuxin-tyx commented on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1025142458 @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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Created] (FLINK-25881) Measure visits on flink.apache.org and nightlies.apache.org/flink as the same visit
Martijn Visser created FLINK-25881: -- Summary: Measure visits on flink.apache.org and nightlies.apache.org/flink as the same visit Key: FLINK-25881 URL: https://issues.apache.org/jira/browse/FLINK-25881 Project: Flink Issue Type: Sub-task Components: Documentation, Project Website Reporter: Martijn Visser -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25835) The task initialization duration is recorded in logs
[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484354#comment-17484354 ] Yun Tang commented on FLINK-25835: -- Current state backend would print the time to restore the state handles, should that be enough? > The task initialization duration is recorded in logs > > > Key: FLINK-25835 > URL: https://issues.apache.org/jira/browse/FLINK-25835 > Project: Flink > Issue Type: Improvement > Components: Runtime / State Backends >Affects Versions: 1.12.2, 1.15.0 >Reporter: Bo Cui >Priority: Major > Labels: pull-request-available > > [https://github.com/apache/flink/blob/a543e658acfbc22c1579df0d043654037b9ec4b0/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L644] > We are testing the time of state backend initialization for different data > levels.However, the task initialization time cannot be obtained from the log > file and the time taken to restore the status at the backend cannot be > obtained. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25879) Track used search terms in Matomo
[ https://issues.apache.org/jira/browse/FLINK-25879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25879: --- Component/s: Documentation > Track used search terms in Matomo > - > > Key: FLINK-25879 > URL: https://issues.apache.org/jira/browse/FLINK-25879 > Project: Flink > Issue Type: Sub-task > Components: Documentation >Reporter: Martijn Visser >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25878) Update privacy policy to reflect change from Google Analytics to Matomo
[ https://issues.apache.org/jira/browse/FLINK-25878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25878: --- Component/s: Documentation Project Website > Update privacy policy to reflect change from Google Analytics to Matomo > --- > > Key: FLINK-25878 > URL: https://issues.apache.org/jira/browse/FLINK-25878 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Project Website >Reporter: Martijn Visser >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18562: [MINOR] ResourceManager_Refactor
flinkbot edited a comment on pull request #18562: URL: https://github.com/apache/flink/pull/18562#issuecomment-1025140068 ## CI report: * 459a41a35a5c561c08a6a1c4675515b2f370048a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=30481) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Created] (FLINK-25880) Implement Matomo in Flink documentation
Martijn Visser created FLINK-25880: -- Summary: Implement Matomo in Flink documentation Key: FLINK-25880 URL: https://issues.apache.org/jira/browse/FLINK-25880 Project: Flink Issue Type: Sub-task Components: Documentation Reporter: Martijn Visser -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-25879) Track used search terms in Matomo
Martijn Visser created FLINK-25879: -- Summary: Track used search terms in Matomo Key: FLINK-25879 URL: https://issues.apache.org/jira/browse/FLINK-25879 Project: Flink Issue Type: Sub-task Reporter: Martijn Visser -- This message was sent by Atlassian Jira (v8.20.1#820001)
