O Realtime Compute for Apache Flink oferece duas opções de armazenamento para o workspace, selecionadas durante a ativação: armazenamento totalmente gerenciado ou um bucket do Object Storage Service (OSS) associado. Este tópico explica como gerenciar artefatos para ambos os tipos. Ao criar um workspace, o serviço cria vários diretórios no bucket do OSS fornecido. Esses diretórios armazenam arquivos usados ou criados pelos jobs do Flink, incluindo checkpoints, savepoints, logs e pacotes JAR. Este tópico descreve tais diretórios e explica como gerenciar seus artefatos.
O Realtime Compute for Apache Flink oferece duas opções de armazenamento para o workspace, selecionadas durante a ativação: armazenamento totalmente gerenciado ou um bucket do Object Storage Service (OSS) associado. Este tópico explica como gerenciar artefatos para ambos os tipos.
Bucket do OSS
Conteúdo dos diretórios
Se você selecionar um bucket do OSS como tipo de armazenamento, o Realtime Compute for Apache Flink criará os seguintes diretórios nesse bucket.
|
Diretório |
Conteúdo |
|
artifacts |
Armazena pacotes JAR enviados, dependências adicionais, arquivos Python e respectivas dependências. |
|
sql-artifacts |
Armazena arquivos necessários para funções definidas pelo usuário e conectores registrados. |
|
flink-jobs |
Armazena informações de alta disponibilidade (HA) e dados de checkpoint dos jobs do Flink. |
|
flink-savepoints |
Armazena arquivos de savepoint gerados ao clicar em Create Savepoint no console do Flink. |
|
flink-sessionclusters |
Armazena informações de alta disponibilidade (HA) e dados de checkpoint dos clusters de sessão. |
|
plan |
Armazena informações de configuração de recursos no modo especialista. |
|
logs |
Armazena logs de jobs se o job estiver configurado para gerar logs no OSS. |
Gerenciar artefatos
Ao usar um bucket do OSS, só é possível enviar, baixar e excluir arquivos no diretório artifacts pelo console do Flink.
Faça login no console do Realtime Compute for Apache Flink.
Na coluna Actions do workspace desejado, clique em Console.
-
No console do Object Storage Service (OSS), configure uma regra de CORS (Cross-Origin Resource Sharing) para o bucket do OSS associado ao workspace.
Sem uma regra CORS configurada, o envio de arquivos pode falhar devido a restrições de origem cruzada. Ao configurar a regra CORS, defina Origin como https://vvpsg.console.alibabacloud.com, permita todos os Methods (selecione todos) e defina Allowed Headers como
*. -
No painel de navegação à esquerda, clique em Artifacts. As operações disponíveis estão listadas abaixo.
Ações
Descrição
Upload Artifact
Clique em Upload Artifact e selecione um arquivo local ou arraste-o diretamente para a área da lista de artefatos.
Após o envio, o caminho do arquivo será
oss://<Your bound OSS Bucket name>/artifacts/namespaces/<Project name>/<File name>. Clique no nome do arquivo para copiar o caminho.Para mais informações sobre o nome do projeto, consulte View and delete a project.
Download Artifact
Na coluna Actions, clique em Download para salvar o artefato na máquina local.
Delete Artifact
Na coluna Actions, clique em Delete para remover permanentemente o artefato do bucket do OSS.
Aceleração de transferência
Em caso de lentidão no envio ou download de arquivos grandes em longas distâncias, ative a aceleração de transferência. Para isso, ative a chave Transfer Acceleration no canto superior direito da página.
Para usar este recurso, primeiro ative a transfer acceleration for your OSS bucket. A ativação gera custos adicionais de transferência de dados. Para mais informações sobre faturamento, consulte Transfer acceleration fees.
Tópicos relacionados
Para instruções sobre como implantar jobs SQL, JAR e Python, consulte Deploy a job.
Para visualizar logs detalhados de jobs em execução, consulte View startup and runtime logs.
Para visualizar informações de checkpoint e savepoint de jobs, consulte Manage state sets.